Modifier and Type | Field and Description |
---|---|
Descriptor |
KeyCacheKey.desc |
Constructor and Description |
---|
KeyCacheKey(TableMetadata tableMetadata,
Descriptor desc,
java.nio.ByteBuffer key) |
Modifier and Type | Method and Description |
---|---|
Descriptor |
Directories.find(java.lang.String filename) |
Descriptor |
ColumnFamilyStore.newSSTableDescriptor(java.io.File directory) |
Descriptor |
ColumnFamilyStore.newSSTableDescriptor(java.io.File directory,
SSTableFormat.Type format) |
Descriptor |
ColumnFamilyStore.newSSTableDescriptor(java.io.File directory,
Version version,
SSTableFormat.Type format) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<Descriptor,java.util.Set<Component>> |
Directories.SSTableLister.list() |
Modifier and Type | Method and Description |
---|---|
SSTableMultiWriter |
ColumnFamilyStore.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
int sstableLevel,
SerializationHeader header,
LifecycleNewTracker lifecycleNewTracker) |
SSTableMultiWriter |
ColumnFamilyStore.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
MetadataCollector metadataCollector,
SerializationHeader header,
LifecycleNewTracker lifecycleNewTracker) |
static java.io.File |
Directories.getBackupsDirectory(Descriptor desc) |
int |
DiskBoundaries.getBoundariesFromSSTableDirectory(Descriptor descriptor)
Try to figure out location based on sstable directory
|
Directories.DataDirectory |
Directories.getDataDirectoryForFile(Descriptor descriptor) |
static java.io.File |
Directories.getSnapshotDirectory(Descriptor desc,
java.lang.String snapshotName) |
Modifier and Type | Method and Description |
---|---|
SSTableMultiWriter |
AbstractCompactionStrategy.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
MetadataCollector meta,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
abstract SSTableMultiWriter |
AbstractStrategyHolder.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
MetadataCollector collector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
SSTableMultiWriter |
CompactionStrategyHolder.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
MetadataCollector collector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
SSTableMultiWriter |
CompactionStrategyManager.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
MetadataCollector collector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
SSTableMultiWriter |
PendingRepairHolder.createSSTableMultiWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
MetadataCollector collector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
int |
AbstractStrategyHolder.DestinationRouter.getIndexForSSTableDirectory(Descriptor descriptor) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<?> |
CompactionManager.submitUserDefined(ColumnFamilyStore cfs,
java.util.Collection<Descriptor> dataFiles,
int gcBefore) |
Modifier and Type | Method and Description |
---|---|
default SSTableFlushObserver |
Index.getFlushObserver(Descriptor descriptor,
OperationType opType)
Get flush observer to observe partition/cell events generated by flushing SSTable (memtable flush or compaction).
|
Modifier and Type | Method and Description |
---|---|
SSTableFlushObserver |
SASIIndex.getFlushObserver(Descriptor descriptor,
OperationType opType) |
protected static PerSSTableIndexWriter |
SASIIndex.newWriter(AbstractType<?> keyValidator,
Descriptor descriptor,
java.util.Map<ColumnMetadata,ColumnIndex> indexes,
OperationType opType) |
Modifier and Type | Method and Description |
---|---|
Descriptor |
PerSSTableIndexWriter.getDescriptor() |
Constructor and Description |
---|
PerSSTableIndexWriter(AbstractType<?> keyValidator,
Descriptor descriptor,
OperationType source,
java.util.Map<ColumnMetadata,ColumnIndex> supportedIndexes) |
Constructor and Description |
---|
CompressionMetadata(Descriptor desc,
long compressedLength) |
Modifier and Type | Field and Description |
---|---|
Descriptor |
SSTable.descriptor |
Modifier and Type | Field and Description |
---|---|
protected java.util.function.Function<Descriptor,TableMetadata> |
SSTableHeaderFix.schemaCallback |
Modifier and Type | Method and Description |
---|---|
static Descriptor |
Descriptor.fromFilename(java.io.File file)
Parse a sstable filename into a Descriptor.
|
static Descriptor |
Descriptor.fromFilename(java.lang.String filename)
Parse a sstable filename into a Descriptor.
|
static Descriptor |
SSTable.tryDescriptorFromFilename(java.io.File file)
Parse a sstable filename into a
Descriptor object. |
Descriptor |
Descriptor.withFormatType(SSTableFormat.Type newType) |
Descriptor |
Descriptor.withGeneration(int newGeneration) |
Modifier and Type | Method and Description |
---|---|
static Pair<Descriptor,Component> |
Descriptor.fromFilenameWithComponent(java.io.File file)
Parse a sstable filename, extracting both the
Descriptor and Component part. |
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 |
---|---|
protected static void |
SSTable.appendTOC(Descriptor descriptor,
java.util.Collection<Component> components)
Appends new component names to the TOC component.
|
static java.util.Set<Component> |
SSTable.componentsFor(Descriptor desc)
Discovers existing components for the descriptor.
|
static SSTableTxnWriter |
SSTableTxnWriter.create(ColumnFamilyStore cfs,
Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
int sstableLevel,
SerializationHeader header) |
static SSTableTxnWriter |
SSTableTxnWriter.create(ColumnFamilyStore cfs,
Descriptor desc,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
SerializationHeader header) |
static SSTableMultiWriter |
SimpleSSTableMultiWriter.create(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
TableMetadataRef metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
static SSTableTxnWriter |
SSTableTxnWriter.create(TableMetadataRef metadata,
Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
int sstableLevel,
SerializationHeader header,
java.util.Collection<Index> indexes) |
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.
|
static java.util.Set<Component> |
SSTable.discoverComponentsFor(Descriptor desc) |
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.
|
SSTableHeaderFix.Builder |
SSTableHeaderFix.Builder.withDescriptor(Descriptor descriptor) |
Modifier and Type | Method and Description |
---|---|
SSTableHeaderFix.Builder |
SSTableHeaderFix.Builder.schemaCallback(java.util.function.Supplier<java.util.function.Function<Descriptor,TableMetadata>> schemaCallback)
Schema callback to retrieve the schema of a table.
|
Constructor and Description |
---|
KeyIterator(Descriptor desc,
TableMetadata metadata) |
SSTable(Descriptor descriptor,
java.util.Set<Component> components,
TableMetadataRef metadata,
DiskOptimizationStrategy optimizationStrategy) |
Modifier and Type | Method and Description |
---|---|
static SSTableWriter |
SSTableWriter.create(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
int sstableLevel,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
static SSTableWriter |
SSTableWriter.create(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
static SSTableWriter |
SSTableWriter.create(Descriptor descriptor,
java.lang.Long keyCount,
java.lang.Long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
TableMetadataRef metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
static SSTableWriter |
SSTableWriter.create(TableMetadataRef metadata,
Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
int sstableLevel,
SerializationHeader header,
java.util.Collection<Index> indexes,
LifecycleNewTracker lifecycleNewTracker) |
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) |
abstract SSTableWriter |
SSTableWriter.Factory.open(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
TableMetadataRef metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<SSTableFlushObserver> observers,
LifecycleNewTracker lifecycleNewTracker) |
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 SSTableReader |
SSTableReader.open(Descriptor desc,
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 SSTableReader |
SSTableReader.openNoValidation(Descriptor descriptor,
TableMetadataRef metadata) |
static void |
SSTableWriter.rename(Descriptor tmpdesc,
Descriptor newdesc,
java.util.Set<Component> components) |
static void |
SSTableReader.saveBloomFilter(Descriptor descriptor,
IFilter filter) |
static void |
SSTableReader.saveSummary(Descriptor descriptor,
DecoratedKey first,
DecoratedKey last,
IndexSummary summary)
Save index summary to Summary.db file.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static java.util.Collection<SSTableReader> |
SSTableReader.openAll(java.util.Set<java.util.Map.Entry<Descriptor,java.util.Set<Component>>> entries,
TableMetadataRef metadata) |
Constructor and Description |
---|
SSTableReader(Descriptor desc,
java.util.Set<Component> components,
TableMetadataRef metadata,
long maxDataAge,
StatsMetadata sstableMetadata,
SSTableReader.OpenReason openReason,
SerializationHeader header) |
SSTableWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
TableMetadataRef metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<SSTableFlushObserver> observers) |
Constructor and Description |
---|
BigTableWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
java.util.UUID pendingRepair,
boolean isTransient,
TableMetadataRef metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<SSTableFlushObserver> observers,
LifecycleNewTracker lifecycleNewTracker) |
BigTableZeroCopyWriter(Descriptor descriptor,
TableMetadataRef metadata,
LifecycleNewTracker lifecycleNewTracker,
java.util.Collection<Component> components) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<MetadataType,MetadataComponent> |
IMetadataSerializer.deserialize(Descriptor descriptor,
java.util.EnumSet<MetadataType> types)
Deserialize specified metadata components from given descriptor.
|
java.util.Map<MetadataType,MetadataComponent> |
MetadataSerializer.deserialize(Descriptor descriptor,
java.util.EnumSet<MetadataType> types) |
java.util.Map<MetadataType,MetadataComponent> |
MetadataSerializer.deserialize(Descriptor descriptor,
FileDataInput in,
java.util.EnumSet<MetadataType> selectedTypes) |
MetadataComponent |
IMetadataSerializer.deserialize(Descriptor descriptor,
MetadataType type)
Deserialized only metadata component specified from given descriptor.
|
MetadataComponent |
MetadataSerializer.deserialize(Descriptor descriptor,
MetadataType type) |
void |
IMetadataSerializer.mutate(Descriptor descriptor,
java.util.function.Function<StatsMetadata,StatsMetadata> transform)
Mutate SSTable Metadata
|
void |
MetadataSerializer.mutate(Descriptor descriptor,
java.util.function.Function<StatsMetadata,StatsMetadata> transform) |
void |
IMetadataSerializer.mutateLevel(Descriptor descriptor,
int newLevel)
Mutate SSTable level
|
void |
MetadataSerializer.mutateLevel(Descriptor descriptor,
int newLevel) |
void |
IMetadataSerializer.mutateRepairMetadata(Descriptor descriptor,
long newRepairedAt,
java.util.UUID newPendingRepair,
boolean isTransient)
Mutate the repairedAt time, pendingRepair ID, and transient status
|
void |
MetadataSerializer.mutateRepairMetadata(Descriptor descriptor,
long newRepairedAt,
java.util.UUID newPendingRepair,
boolean isTransient) |
void |
IMetadataSerializer.rewriteSSTableMetadata(Descriptor descriptor,
java.util.Map<MetadataType,MetadataComponent> currentComponents)
Replace the sstable metadata file (
-Statistics.db ) with the given components. |
void |
MetadataSerializer.rewriteSSTableMetadata(Descriptor descriptor,
java.util.Map<MetadataType,MetadataComponent> currentComponents) |
Modifier and Type | Method and Description |
---|---|
static DataIntegrityMetadata.ChecksumValidator |
DataIntegrityMetadata.checksumValidator(Descriptor desc) |
static DataIntegrityMetadata.FileDigestValidator |
DataIntegrityMetadata.fileDigestValidator(Descriptor desc) |
Constructor and Description |
---|
ChecksumValidator(Descriptor descriptor) |
FileDigestValidator(Descriptor descriptor) |
Modifier and Type | Method and Description |
---|---|
TableMetadata |
Schema.getTableMetadata(Descriptor descriptor) |
TableMetadataRef |
Schema.getTableMetadataRef(Descriptor descriptor) |
Modifier and Type | Method and Description |
---|---|
static TableMetadata |
Util.metadataFromSSTable(Descriptor desc)
Construct table schema from info stored in SSTable's Stats.db
|
Modifier and Type | Method and Description |
---|---|
static IPartitioner |
FBUtilities.newPartitioner(Descriptor desc)
Create a new instance of a partitioner defined in an SSTable Descriptor
|
Copyright © 2009-2020 The Apache Software Foundation