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 DescriptorKeyCacheKey. descConstructors 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 DescriptorDirectories. find(java.lang.String filename)DescriptorColumnFamilyStore. newSSTableDescriptor(File directory)DescriptorColumnFamilyStore. newSSTableDescriptor(File directory, SSTableFormat.Type format)DescriptorColumnFamilyStore. newSSTableDescriptor(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()java.util.Map<Descriptor,java.util.Set<Component>>Directories.SSTableLister. list(boolean includeForeignTables)This method is used upon SSTable importing (nodetool import) as there is no strict requirement to place SSTables in a directory structure where name of a directory equals to table name and parent of such directory equals to keyspace name.java.util.List<java.util.Map.Entry<Descriptor,java.util.Set<Component>>>Directories.SSTableLister. sortedList()Returns a sorted version of thelistmethod.Methods in org.apache.cassandra.db with parameters of type Descriptor Modifier and Type Method Description SSTableMultiWriterColumnFamilyStore. createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, int sstableLevel, SerializationHeader header, LifecycleNewTracker lifecycleNewTracker)SSTableMultiWriterColumnFamilyStore. createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, MetadataCollector metadataCollector, SerializationHeader header, LifecycleNewTracker lifecycleNewTracker)static FileDirectories. getBackupsDirectory(Descriptor desc)intDiskBoundaries. getBoundariesFromSSTableDirectory(Descriptor descriptor)Try to figure out location based on sstable directoryDirectories.DataDirectoryDirectories. getDataDirectoryForFile(Descriptor descriptor)static FileDirectories. 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 SSTableMultiWriterAbstractCompactionStrategy. createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, MetadataCollector meta, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)abstract SSTableMultiWriterAbstractStrategyHolder. createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, MetadataCollector collector, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)SSTableMultiWriterCompactionStrategyHolder. createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, MetadataCollector collector, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)SSTableMultiWriterCompactionStrategyManager. createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, MetadataCollector collector, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)SSTableMultiWriterPendingRepairHolder. createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, MetadataCollector collector, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)intAbstractStrategyHolder.DestinationRouter. getIndexForSSTableDirectory(Descriptor descriptor)Method parameters in org.apache.cassandra.db.compaction with type arguments of type Descriptor Modifier and Type Method Description Future<?>CompactionManager. submitUserDefined(ColumnFamilyStore cfs, java.util.Collection<Descriptor> dataFiles, int gcBefore) -
Uses of Descriptor in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable with parameters of type Descriptor Modifier and Type Method Description static SSTableMultiWriterFlushing. createFlushWriter(ColumnFamilyStore cfs, Memtable.FlushablePartitionSet<?> flushSet, LifecycleTransaction txn, Descriptor descriptor, long partitionCount) -
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.FileChannelComponentContext. channel(Descriptor descriptor, Component component, long size)static ComponentContextComponentContext. create(Descriptor descriptor)static ComponentManifestComponentManifest. 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 SSTableFlushObserverIndex. 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 SSTableFlushObserverSASIIndex. getFlushObserver(Descriptor descriptor, OperationType opType)protected static PerSSTableIndexWriterSASIIndex. 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 DescriptorPerSSTableIndexWriter. 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 DescriptorSSTable. descriptorFields 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. schemaCallbackMethods in org.apache.cassandra.io.sstable that return Descriptor Modifier and Type Method Description static DescriptorDescriptor. fromFilename(java.lang.String filename)Parse a sstable filename into a Descriptor.static DescriptorDescriptor. fromFilename(File file)Parse a sstable filename into a Descriptor.static DescriptorSSTable. tryDescriptorFromFilename(File file)Parse a sstable filename into aDescriptorobject.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(File file)Parse a sstable filename, extracting both theDescriptorandComponentpart.static Pair<Descriptor,Component>SSTable. tryComponentFromFilename(File file)Parse a sstable filename into both aDescriptorandComponentobject.Methods in org.apache.cassandra.io.sstable with parameters of type Descriptor Modifier and Type Method Description protected static voidSSTable. 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 SSTableMultiWriterSimpleSSTableMultiWriter. create(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, TableMetadataRef metadata, MetadataCollector metadataCollector, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)static SSTableTxnWriterSSTableTxnWriter. create(ColumnFamilyStore cfs, Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, int sstableLevel, SerializationHeader header)static SSTableTxnWriterSSTableTxnWriter. create(ColumnFamilyStore cfs, Descriptor desc, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SerializationHeader header)static SSTableTxnWriterSSTableTxnWriter. create(TableMetadataRef metadata, Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, int sstableLevel, SerializationHeader header, java.util.Collection<Index> indexes)static booleanSSTable. 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 longSSTable. 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.BuilderSSTableHeaderFix.Builder. withDescriptor(Descriptor descriptor)Method parameters in org.apache.cassandra.io.sstable with type arguments of type Descriptor Modifier and Type Method Description SSTableHeaderFix.BuilderSSTableHeaderFix.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 DescriptorSSTableReaderBuilder. descriptorMethods in org.apache.cassandra.io.sstable.format with parameters of type Descriptor Modifier and Type Method Description static voidSSTableWriter. copy(Descriptor tmpdesc, Descriptor newdesc, java.util.Set<Component> components)static SSTableWriterSSTableWriter. create(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, int sstableLevel, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)static SSTableWriterSSTableWriter. create(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)static SSTableWriterSSTableWriter. create(Descriptor descriptor, java.lang.Long keyCount, java.lang.Long repairedAt, TimeUUID pendingRepair, boolean isTransient, TableMetadataRef metadata, MetadataCollector metadataCollector, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)static SSTableWriterSSTableWriter. create(TableMetadataRef metadata, Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, int sstableLevel, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)static voidSSTableReader. createLinks(Descriptor descriptor, java.util.Set<Component> components, java.lang.String snapshotDirectoryPath)static voidSSTableReader. createLinks(Descriptor descriptor, java.util.Set<Component> components, java.lang.String snapshotDirectoryPath, com.google.common.util.concurrent.RateLimiter limiter)static voidSSTableWriter. hardlink(Descriptor tmpdesc, Descriptor newdesc, java.util.Set<Component> components)static SSTableReaderSSTableReader. 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 SSTableReaderSSTableReader. 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 SSTableReaderSSTableReader. open(Descriptor descriptor)static SSTableReaderSSTableReader. open(Descriptor descriptor, java.util.Set<Component> components, TableMetadataRef metadata)static SSTableReaderSSTableReader. open(Descriptor descriptor, java.util.Set<Component> components, TableMetadataRef metadata, boolean validate, boolean isOffline)Open an SSTable for readingstatic SSTableReaderSSTableReader. open(Descriptor desc, TableMetadataRef metadata)abstract SSTableWriterSSTableWriter.Factory. open(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, TableMetadataRef metadata, MetadataCollector metadataCollector, SerializationHeader header, java.util.Collection<SSTableFlushObserver> observers, LifecycleNewTracker lifecycleNewTracker)static SSTableReaderSSTableReader. openForBatch(Descriptor descriptor, java.util.Set<Component> components, TableMetadataRef metadata)Open SSTable reader to be used in batch mode(such as sstableloader).static SSTableReaderSSTableReader. openNoValidation(Descriptor descriptor, java.util.Set<Component> components, ColumnFamilyStore cfs)static SSTableReaderSSTableReader. openNoValidation(Descriptor descriptor, TableMetadataRef metadata)static voidSSTableWriter. rename(Descriptor tmpdesc, Descriptor newdesc, java.util.Set<Component> components)static voidSSTableReader. saveBloomFilter(Descriptor descriptor, IFilter filter)static voidSSTableReader. saveSummary(Descriptor descriptor, DecoratedKey first, DecoratedKey last, IndexSummary summary)Save index summary to Summary.db file.static voidSSTableReader. 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> RSSTableReader. 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, TimeUUID 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, TimeUUID 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.MetadataComponentIMetadataSerializer. 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)MetadataComponentMetadataSerializer. deserialize(Descriptor descriptor, MetadataType type)java.util.Map<MetadataType,MetadataComponent>MetadataSerializer. deserialize(Descriptor descriptor, FileDataInput in, java.util.EnumSet<MetadataType> selectedTypes)voidIMetadataSerializer. 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.voidMetadataSerializer. mutate(Descriptor descriptor, java.lang.String description, java.util.function.UnaryOperator<StatsMetadata> transform)voidIMetadataSerializer. 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.voidMetadataSerializer. mutateLevel(Descriptor descriptor, int newLevel)voidIMetadataSerializer. mutateRepairMetadata(Descriptor descriptor, long newRepairedAt, TimeUUID newPendingRepair, boolean isTransient)Mutate the repairedAt time, pendingRepair ID, and transient status.voidMetadataSerializer. mutateRepairMetadata(Descriptor descriptor, long newRepairedAt, TimeUUID newPendingRepair, boolean isTransient)voidIMetadataSerializer. rewriteSSTableMetadata(Descriptor descriptor, java.util.Map<MetadataType,MetadataComponent> currentComponents)Replace the sstable metadata file (-Statistics.db) with the given components.voidMetadataSerializer. 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.ChecksumValidatorDataIntegrityMetadata. checksumValidator(Descriptor desc)static DataIntegrityMetadata.FileDigestValidatorDataIntegrityMetadata. 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 TableMetadataSchema. getTableMetadata(Descriptor descriptor)TableMetadataRefSchema. getTableMetadataRef(Descriptor descriptor)default TableMetadataRefSchemaProvider. 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 TableMetadataUtil. 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 IPartitionerFBUtilities. newPartitioner(Descriptor desc)Create a new instance of a partitioner defined in an SSTable Descriptor
-