Uses of Class
org.apache.cassandra.io.sstable.Descriptor
-
-
Uses of Descriptor in org.apache.cassandra.cache
Fields in org.apache.cassandra.cache declared as Descriptor Modifier and Type Field Description Descriptor
KeyCacheKey. desc
Constructors in org.apache.cassandra.cache with parameters of type Descriptor Constructor Description KeyCacheKey(TableMetadata tableMetadata, Descriptor desc, java.nio.ByteBuffer key)
-
Uses of Descriptor in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return Descriptor Modifier and Type Method 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)
Methods in org.apache.cassandra.db that return types with arguments of type Descriptor Modifier and Type Method Description java.util.Map<Descriptor,java.util.Set<Component>>
Directories.SSTableLister. list()
Methods in org.apache.cassandra.db with parameters of type Descriptor Modifier and Type Method 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 directoryDirectories.DataDirectory
Directories. getDataDirectoryForFile(Descriptor descriptor)
static java.io.File
Directories. getSnapshotDirectory(Descriptor desc, java.lang.String snapshotName)
-
Uses of Descriptor in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction with parameters of type Descriptor Modifier and Type Method 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)
Method parameters in org.apache.cassandra.db.compaction with type arguments of type Descriptor Modifier and Type Method Description java.util.concurrent.Future<?>
CompactionManager. submitUserDefined(ColumnFamilyStore cfs, java.util.Collection<Descriptor> dataFiles, int gcBefore)
-
Uses of Descriptor in org.apache.cassandra.db.streaming
Methods in org.apache.cassandra.db.streaming with parameters of type Descriptor Modifier and Type Method Description java.nio.channels.FileChannel
ComponentContext. channel(Descriptor descriptor, Component component, long size)
static ComponentContext
ComponentContext. create(Descriptor descriptor)
static ComponentManifest
ComponentManifest. create(Descriptor descriptor)
-
Uses of Descriptor in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type Descriptor Modifier and Type Method 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). -
Uses of Descriptor in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type Descriptor Modifier and Type Method 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)
-
Uses of Descriptor in org.apache.cassandra.index.sasi.disk
Methods in org.apache.cassandra.index.sasi.disk that return Descriptor Modifier and Type Method Description Descriptor
PerSSTableIndexWriter. getDescriptor()
Constructors in org.apache.cassandra.index.sasi.disk with parameters of type Descriptor Constructor Description PerSSTableIndexWriter(AbstractType<?> keyValidator, Descriptor descriptor, OperationType source, java.util.Map<ColumnMetadata,ColumnIndex> supportedIndexes)
-
Uses of Descriptor in org.apache.cassandra.io.compress
Constructors in org.apache.cassandra.io.compress with parameters of type Descriptor Constructor Description CompressionMetadata(Descriptor desc, long compressedLength)
-
Uses of Descriptor in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable declared as Descriptor Modifier and Type Field Description Descriptor
SSTable. descriptor
Fields in org.apache.cassandra.io.sstable with type parameters of type Descriptor Modifier and Type Field Description protected java.util.function.Function<Descriptor,TableMetadata>
SSTableHeaderFix. schemaCallback
Methods in org.apache.cassandra.io.sstable that return Descriptor Modifier and Type Method 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 aDescriptor
object.Descriptor
Descriptor. withFormatType(SSTableFormat.Type newType)
Descriptor
Descriptor. withGeneration(int newGeneration)
Methods in org.apache.cassandra.io.sstable that return types with arguments of type Descriptor Modifier and Type Method Description static Pair<Descriptor,Component>
Descriptor. fromFilenameWithComponent(java.io.File file)
Parse a sstable filename, extracting both theDescriptor
andComponent
part.static Pair<Descriptor,Component>
SSTable. tryComponentFromFilename(java.io.File file)
Parse a sstable filename into both aDescriptor
andComponent
object.Methods in org.apache.cassandra.io.sstable with parameters of type Descriptor Modifier and Type Method 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 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(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 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)
static long
SSTable. estimateRowsFromIndex(RandomAccessReader ifile, Descriptor descriptor)
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)
Method parameters in org.apache.cassandra.io.sstable with type arguments of type Descriptor Modifier and Type Method 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.Constructors in org.apache.cassandra.io.sstable with parameters of type Descriptor Constructor Description KeyIterator(Descriptor desc, TableMetadata metadata)
SSTable(Descriptor descriptor, java.util.Set<Component> components, TableMetadataRef metadata, DiskOptimizationStrategy optimizationStrategy)
-
Uses of Descriptor in org.apache.cassandra.io.sstable.format
Fields in org.apache.cassandra.io.sstable.format declared as Descriptor Modifier and Type Field Description protected Descriptor
SSTableReaderBuilder. descriptor
Methods in org.apache.cassandra.io.sstable.format with parameters of type Descriptor Modifier and Type Method Description static void
SSTableWriter. copy(Descriptor tmpdesc, Descriptor newdesc, java.util.Set<Component> components)
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 void
SSTableReader. createLinks(Descriptor descriptor, java.util.Set<Component> components, java.lang.String snapshotDirectoryPath, com.google.common.util.concurrent.RateLimiter limiter)
static void
SSTableWriter. hardlink(Descriptor tmpdesc, Descriptor newdesc, java.util.Set<Component> components)
static SSTableReader
SSTableReader. internalOpen(Descriptor desc, java.util.Set<Component> components, TableMetadataRef metadata, FileHandle ifile, FileHandle dfile, IndexSummary summary, 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, boolean copyData)
Moves the sstable in oldDescriptor to a new place (with generation etc) in newDescriptor.static SSTableReader
SSTableReader. open(Descriptor descriptor)
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 readingstatic SSTableReader
SSTableReader. open(Descriptor desc, TableMetadataRef metadata)
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. 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.Method parameters in org.apache.cassandra.io.sstable.format with type arguments of type Descriptor Modifier and Type Method Description static java.util.Collection<SSTableReader>
SSTableReader. openAll(java.util.Set<java.util.Map.Entry<Descriptor,java.util.Set<Component>>> entries, TableMetadataRef metadata)
<R> R
SSTableReader. runWithLock(CheckedFunction<Descriptor,R,java.io.IOException> task)
Execute provided task with sstable lock to avoid racing with index summary redistribution, SEE CASSANDRA-15861.Constructors in org.apache.cassandra.io.sstable.format with parameters of type Descriptor Constructor Description ForBatch(Descriptor descriptor, TableMetadataRef metadataRef, java.util.Set<Component> components, StatsMetadata statsMetadata, SerializationHeader header)
ForRead(Descriptor descriptor, TableMetadataRef metadataRef, ValidationMetadata validationMetadata, boolean isOffline, java.util.Set<Component> components, StatsMetadata statsMetadata, SerializationHeader header)
ForWriter(Descriptor descriptor, TableMetadataRef metadataRef, long maxDataAge, java.util.Set<Component> components, StatsMetadata statsMetadata, SSTableReader.OpenReason openReason, SerializationHeader header)
SSTableReader(Descriptor desc, java.util.Set<Component> components, TableMetadataRef metadata, long maxDataAge, StatsMetadata sstableMetadata, SSTableReader.OpenReason openReason, SerializationHeader header, IndexSummary summary, FileHandle dfile, FileHandle ifile, IFilter bf)
SSTableReaderBuilder(Descriptor descriptor, TableMetadataRef metadataRef, long maxDataAge, java.util.Set<Component> components, StatsMetadata statsMetadata, 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)
-
Uses of Descriptor in org.apache.cassandra.io.sstable.format.big
Constructors in org.apache.cassandra.io.sstable.format.big with parameters of type Descriptor Constructor 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)
-
Uses of Descriptor in org.apache.cassandra.io.sstable.metadata
Methods in org.apache.cassandra.io.sstable.metadata with parameters of type Descriptor Modifier and Type Method Description java.util.Map<MetadataType,MetadataComponent>
IMetadataSerializer. deserialize(Descriptor descriptor, java.util.EnumSet<MetadataType> types)
Deserialize specified metadata components from given descriptor.MetadataComponent
IMetadataSerializer. deserialize(Descriptor descriptor, MetadataType type)
Deserialized only metadata component specified from given descriptor.java.util.Map<MetadataType,MetadataComponent>
MetadataSerializer. deserialize(Descriptor descriptor, java.util.EnumSet<MetadataType> types)
MetadataComponent
MetadataSerializer. deserialize(Descriptor descriptor, MetadataType type)
java.util.Map<MetadataType,MetadataComponent>
MetadataSerializer. deserialize(Descriptor descriptor, FileDataInput in, java.util.EnumSet<MetadataType> selectedTypes)
void
IMetadataSerializer. mutate(Descriptor descriptor, java.lang.String description, java.util.function.UnaryOperator<StatsMetadata> transform)
Mutate SSTable Metadata NOTE: mutating stats metadata of a live sstable will race with entire-sstable-streaming, please useSSTableReader.mutateLevelAndReload(int)
instead on live sstable.void
MetadataSerializer. mutate(Descriptor descriptor, java.lang.String description, java.util.function.UnaryOperator<StatsMetadata> transform)
void
IMetadataSerializer. mutateLevel(Descriptor descriptor, int newLevel)
Mutate SSTable level NOTE: mutating stats metadata of a live sstable will race with entire-sstable-streaming, please useSSTableReader.mutateLevelAndReload(int)
instead on live sstable.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)
-
Uses of Descriptor in org.apache.cassandra.io.util
Methods in org.apache.cassandra.io.util with parameters of type Descriptor Modifier and Type Method Description static DataIntegrityMetadata.ChecksumValidator
DataIntegrityMetadata. checksumValidator(Descriptor desc)
static DataIntegrityMetadata.FileDigestValidator
DataIntegrityMetadata. fileDigestValidator(Descriptor desc)
Constructors in org.apache.cassandra.io.util with parameters of type Descriptor Constructor Description ChecksumValidator(Descriptor descriptor)
FileDigestValidator(Descriptor descriptor)
-
Uses of Descriptor in org.apache.cassandra.schema
Methods in org.apache.cassandra.schema with parameters of type Descriptor Modifier and Type Method Description TableMetadata
Schema. getTableMetadata(Descriptor descriptor)
TableMetadataRef
Schema. getTableMetadataRef(Descriptor descriptor)
default TableMetadataRef
SchemaProvider. getTableMetadataRef(Descriptor descriptor)
-
Uses of Descriptor in org.apache.cassandra.tools
Methods in org.apache.cassandra.tools with parameters of type Descriptor Modifier and Type Method Description static TableMetadata
Util. metadataFromSSTable(Descriptor desc)
Construct table schema from info stored in SSTable's Stats.db -
Uses of Descriptor in org.apache.cassandra.utils
Methods in org.apache.cassandra.utils with parameters of type Descriptor Modifier and Type Method Description static IPartitioner
FBUtilities. newPartitioner(Descriptor desc)
Create a new instance of a partitioner defined in an SSTable Descriptor
-