Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.db.streaming |
File transfer
|
org.apache.cassandra.index.sasi.conf | |
org.apache.cassandra.io.sstable | |
org.apache.cassandra.io.sstable.format | |
org.apache.cassandra.io.sstable.format.big |
Modifier and Type | Method and Description |
---|---|
java.util.Map<Descriptor,java.util.Set<Component>> |
Directories.SSTableLister.list() |
Modifier and Type | Field and Description |
---|---|
static java.util.List<Component> |
CassandraOutgoingFile.STREAM_COMPONENTS |
Modifier and Type | Method and Description |
---|---|
java.util.List<Component> |
ComponentManifest.components() |
java.util.Iterator<Component> |
ComponentManifest.iterator() |
Modifier and Type | Method and Description |
---|---|
long |
ComponentManifest.sizeOf(Component component) |
Modifier and Type | Method and Description |
---|---|
protected BigTableZeroCopyWriter |
CassandraEntireSSTableStreamReader.createWriter(ColumnFamilyStore cfs,
long totalSize,
java.util.Collection<Component> components) |
Constructor and Description |
---|
ComponentManifest(java.util.Map<Component,java.lang.Long> components) |
Modifier and Type | Method and Description |
---|---|
Component |
ColumnIndex.getComponent() |
Modifier and Type | Field and Description |
---|---|
static Component |
Component.COMPRESSION_INFO |
static Component |
Component.CRC |
static Component |
Component.DATA |
static Component |
Component.DIGEST |
static Component |
Component.FILTER |
static Component |
Component.PRIMARY_INDEX |
static Component |
Component.STATS |
static Component |
Component.SUMMARY |
static Component |
Component.TOC |
Modifier and Type | Field and Description |
---|---|
protected java.util.Set<Component> |
SSTable.components |
Modifier and Type | Method and Description |
---|---|
static Component |
Component.parse(java.lang.String name)
Parse the component part of a sstable filename into a
Component object. |
Modifier and Type | Method and Description |
---|---|
static java.util.Set<Component> |
SSTable.componentsFor(Descriptor desc)
Discovers existing components for the descriptor.
|
static java.util.Set<Component> |
SSTable.discoverComponentsFor(Descriptor desc) |
static Pair<Descriptor,Component> |
Descriptor.fromFilenameWithComponent(java.io.File file)
Parse a sstable filename, extracting both the
Descriptor and Component part. |
protected static java.util.Set<Component> |
SSTable.readTOC(Descriptor descriptor)
Reads the list of components from the TOC component.
|
protected static java.util.Set<Component> |
SSTable.readTOC(Descriptor descriptor,
boolean skipMissing)
Reads the list of components from the TOC component.
|
static Pair<Descriptor,Component> |
SSTable.tryComponentFromFilename(java.io.File file)
Parse a sstable filename into both a
Descriptor and Component object. |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
Descriptor.filenameFor(Component component) |
java.lang.String |
Descriptor.relativeFilenameFor(Component component) |
java.lang.String |
Descriptor.tmpFilenameFor(Component component) |
Modifier and Type | Method and Description |
---|---|
void |
SSTable.addComponents(java.util.Collection<Component> newComponents)
Registers new custom components.
|
protected static void |
SSTable.appendTOC(Descriptor descriptor,
java.util.Collection<Component> components)
Appends new component names to the TOC component.
|
static boolean |
SSTable.delete(Descriptor desc,
java.util.Set<Component> components)
We use a ReferenceQueue to manage deleting files that have been compacted
and for which no more SSTable references exist.
|
Constructor and Description |
---|
SSTable(Descriptor descriptor,
java.util.Set<Component> components,
TableMetadataRef metadata,
DiskOptimizationStrategy optimizationStrategy) |
Modifier and Type | Method and Description |
---|---|
long |
SSTableReader.getCreationTimeFor(Component component) |
Modifier and Type | Method and Description |
---|---|
static void |
SSTableReader.createLinks(Descriptor descriptor,
java.util.Set<Component> components,
java.lang.String snapshotDirectoryPath) |
static SSTableReader |
SSTableReader.internalOpen(Descriptor desc,
java.util.Set<Component> components,
TableMetadataRef metadata,
FileHandle ifile,
FileHandle dfile,
IndexSummary isummary,
IFilter bf,
long maxDataAge,
StatsMetadata sstableMetadata,
SSTableReader.OpenReason openReason,
SerializationHeader header)
Open a RowIndexedReader which already has its state initialized (by SSTableWriter).
|
static SSTableReader |
SSTableReader.moveAndOpenSSTable(ColumnFamilyStore cfs,
Descriptor oldDescriptor,
Descriptor newDescriptor,
java.util.Set<Component> components)
Moves the sstable in oldDescriptor to a new place (with generation etc) in newDescriptor.
|
static SSTableReader |
SSTableReader.open(Descriptor descriptor,
java.util.Set<Component> components,
TableMetadataRef metadata) |
static SSTableReader |
SSTableReader.open(Descriptor descriptor,
java.util.Set<Component> components,
TableMetadataRef metadata,
boolean validate,
boolean isOffline)
Open an SSTable for reading
|
abstract SSTableReader |
SSTableReader.Factory.open(Descriptor descriptor,
java.util.Set<Component> components,
TableMetadataRef metadata,
java.lang.Long maxDataAge,
StatsMetadata sstableMetadata,
SSTableReader.OpenReason openReason,
SerializationHeader header) |
static java.util.Collection<SSTableReader> |
SSTableReader.openAll(java.util.Set<java.util.Map.Entry<Descriptor,java.util.Set<Component>>> entries,
TableMetadataRef metadata) |
static SSTableReader |
SSTableReader.openForBatch(Descriptor descriptor,
java.util.Set<Component> components,
TableMetadataRef metadata)
Open SSTable reader to be used in batch mode(such as sstableloader).
|
static SSTableReader |
SSTableReader.openNoValidation(Descriptor descriptor,
java.util.Set<Component> components,
ColumnFamilyStore cfs) |
static void |
SSTableWriter.rename(Descriptor tmpdesc,
Descriptor newdesc,
java.util.Set<Component> components) |
static void |
SSTableReader.verifyCompressionInfoExistenceIfApplicable(Descriptor descriptor,
java.util.Set<Component> actualComponents)
Best-effort checking to verify the expected compression info component exists, according to the TOC file.
|
Constructor and Description |
---|
SSTableReader(Descriptor desc,
java.util.Set<Component> components,
TableMetadataRef metadata,
long maxDataAge,
StatsMetadata sstableMetadata,
SSTableReader.OpenReason openReason,
SerializationHeader header) |
Constructor and Description |
---|
BigTableZeroCopyWriter(Descriptor descriptor,
TableMetadataRef metadata,
LifecycleNewTracker lifecycleNewTracker,
java.util.Collection<Component> components) |
Copyright © 2009-2020 The Apache Software Foundation