Uses of Class
org.apache.cassandra.io.sstable.Descriptor
Packages that use Descriptor
Package
Description
File transfer
-
Uses of Descriptor in org.apache.cassandra.cache
Fields in org.apache.cassandra.cache declared as DescriptorConstructors in org.apache.cassandra.cache with parameters of type DescriptorModifierConstructorDescriptionKeyCacheKey(TableMetadata tableMetadata, Descriptor desc, ByteBuffer key) -
Uses of Descriptor in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return DescriptorModifier and TypeMethodDescriptionColumnFamilyStore.newSSTableDescriptor(File directory) ColumnFamilyStore.newSSTableDescriptor(File directory, SSTableFormat<?, ?> format) ColumnFamilyStore.newSSTableDescriptor(File directory, Version version) Methods in org.apache.cassandra.db that return types with arguments of type DescriptorModifier and TypeMethodDescriptionDirectories.SSTableLister.list()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.Directories.SSTableLister.sortedList()Returns a sorted version of thelistmethod.Methods in org.apache.cassandra.db with parameters of type DescriptorModifier and TypeMethodDescriptionColumnFamilyStore.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, LifecycleNewTracker lifecycleNewTracker) ColumnFamilyStore.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, SerializationHeader header, LifecycleNewTracker lifecycleNewTracker) ColumnFamilyStore.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SerializationHeader header, LifecycleNewTracker lifecycleNewTracker) static FileDirectories.getBackupsDirectory(Descriptor desc) intDiskBoundaries.getBoundariesFromSSTableDirectory(Descriptor descriptor) Try to figure out location based on sstable directoryDirectories.getDataDirectoryForFile(Descriptor descriptor) static FileDirectories.getSnapshotDirectory(Descriptor desc, String snapshotName) -
Uses of Descriptor in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction with parameters of type DescriptorModifier and TypeMethodDescriptionAbstractCompactionStrategy.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker) abstract SSTableMultiWriterAbstractStrategyHolder.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker) CompactionStrategyHolder.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker) CompactionStrategyManager.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker) PendingRepairHolder.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker) UnifiedCompactionStrategy.createSSTableMultiWriter(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker) Create the sstable writer used for flushing.intAbstractStrategyHolder.DestinationRouter.getIndexForSSTableDirectory(Descriptor descriptor) Method parameters in org.apache.cassandra.db.compaction with type arguments of type DescriptorModifier and TypeMethodDescriptionFuture<?>CompactionManager.submitUserDefined(ColumnFamilyStore cfs, Collection<Descriptor> dataFiles, long gcBefore) -
Uses of Descriptor in org.apache.cassandra.db.compaction.unified
Constructors in org.apache.cassandra.db.compaction.unified with parameters of type DescriptorModifierConstructorDescriptionShardedMultiWriter(ColumnFamilyStore cfs, Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, IntervalSet<CommitLogPosition> commitLogPositions, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker, ShardTracker boundaries) -
Uses of Descriptor in org.apache.cassandra.db.compaction.writers
Methods in org.apache.cassandra.db.compaction.writers with parameters of type DescriptorModifier and TypeMethodDescriptionprotected SSTableWriter.Builder<?,?> CompactionAwareWriter.newWriterBuilder(Descriptor descriptor) It is up to the caller to set the following fields: -SSTableWriter.Builder.setKeyCount(long), -SSTableWriter.Builder.setSerializationHeader(SerializationHeader)and, -SSTableWriter.Builder.setMetadataCollector(MetadataCollector) -
Uses of Descriptor in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable with parameters of type DescriptorModifier and TypeMethodDescriptionstatic 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 DescriptorModifier and TypeMethodDescriptionComponentContext.channel(Descriptor descriptor, Component component, long size) -
Uses of Descriptor in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type DescriptorModifier and TypeMethodDescriptiondefault SSTableFlushObserverIndex.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker) Get flush observer to observe partition/cell events generated by flushing SSTable (memtable flush or compaction).Index.Group.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker, TableMetadata tableMetadata) Get flush observer to observe partition/cell events generated by flushing SSTable (memtable flush or compaction).SingletonIndexGroup.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker, TableMetadata tableMetadata) -
Uses of Descriptor in org.apache.cassandra.index.sai
Methods in org.apache.cassandra.index.sai that return DescriptorMethods in org.apache.cassandra.index.sai with parameters of type DescriptorModifier and TypeMethodDescriptionStorageAttachedIndex.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker) StorageAttachedIndexGroup.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker, TableMetadata tableMetadata) -
Uses of Descriptor in org.apache.cassandra.index.sai.disk.format
Fields in org.apache.cassandra.index.sai.disk.format declared as DescriptorMethods in org.apache.cassandra.index.sai.disk.format with parameters of type DescriptorModifier and TypeMethodDescriptionstatic IndexDescriptorIndexDescriptor.create(Descriptor descriptor, IPartitioner partitioner, ClusteringComparator clusteringComparator) -
Uses of Descriptor in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type DescriptorModifier and TypeMethodDescriptionSASIIndex.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker) protected static PerSSTableIndexWriterSASIIndex.newWriter(AbstractType<?> keyValidator, Descriptor descriptor, 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 DescriptorConstructors in org.apache.cassandra.index.sasi.disk with parameters of type DescriptorModifierConstructorDescriptionPerSSTableIndexWriter(AbstractType<?> keyValidator, Descriptor descriptor, OperationType source, Map<ColumnMetadata, ColumnIndex> supportedIndexes) -
Uses of Descriptor in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable declared as DescriptorModifier and TypeFieldDescriptionfinal DescriptorSSTable.Builder.descriptorfinal DescriptorSSTable.descriptorMethods in org.apache.cassandra.io.sstable that return DescriptorModifier and TypeMethodDescriptionstatic DescriptorParse a sstable filename into a Descriptor.SSTable.Builder.getDescriptor()static DescriptorSSTable.tryDescriptorFromFile(File file) Parse a sstable filename into aDescriptorobject.Methods in org.apache.cassandra.io.sstable that return types with arguments of type DescriptorModifier and TypeMethodDescriptionstatic Pair<Descriptor,Component> Descriptor.fromFileWithComponent(File file) Parse a sstable filename, extracting both theDescriptorandComponentpart.static Pair<Descriptor,Component> Descriptor.fromFileWithComponent(File file, boolean validateDirs) static Pair<Descriptor,Component> Descriptor.fromFileWithComponent(File file, String keyspace, String table) Parse a sstable filename, extracting both theDescriptorandComponentpart.static Pair<Descriptor,Component> SSTable.tryComponentFromFilename(File file) Parse a sstable filename into both aDescriptorandComponentobject.static Pair<Descriptor,Component> SSTable.tryComponentFromFilename(File file, String keyspace, String table) Parse a sstable filename into both aDescriptorandComponentobject.Methods in org.apache.cassandra.io.sstable with parameters of type DescriptorModifier and TypeMethodDescriptionstatic voidSSTable.copy(Descriptor tmpdesc, Descriptor newdesc, Set<Component> components) static SSTableMultiWriterSimpleSSTableMultiWriter.create(Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, TableMetadataRef metadata, IntervalSet<CommitLogPosition> commitLogPositions, int sstableLevel, SerializationHeader header, Collection<Index.Group> indexGroups, LifecycleNewTracker lifecycleNewTracker, SSTable.Owner owner) static SSTableTxnWriterSSTableTxnWriter.create(ColumnFamilyStore cfs, Descriptor descriptor, 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, SerializationHeader header, Collection<Index.Group> indexGroups, SSTable.Owner owner) static voidSSTable.hardlink(Descriptor tmpdesc, Descriptor newdesc, Set<Component> components) booleanComponent.isValidFor(Descriptor descriptor) static voidSSTable.rename(Descriptor tmpdesc, Descriptor newdesc, Set<Component> components) voidSSTableReadsListener.SelectionReason.trace(Descriptor descriptor, AbstractRowIndexEntry entry) voidSSTableReadsListener.SkippingReason.trace(Descriptor descriptor) Constructors in org.apache.cassandra.io.sstable with parameters of type Descriptor -
Uses of Descriptor in org.apache.cassandra.io.sstable.format
Fields in org.apache.cassandra.io.sstable.format declared as DescriptorModifier and TypeFieldDescriptionprotected final DescriptorSortedTableWriter.AbstractIndexWriter.descriptorprotected final DescriptorSSTableReaderLoadingBuilder.descriptorMethods in org.apache.cassandra.io.sstable.format with parameters of type DescriptorModifier and TypeMethodDescriptionSSTableFormat.SSTableReaderFactory.builder(Descriptor descriptor) A simple builder which creates an instnace ofSSTableReaderwith the provided parameters.SSTableFormat.SSTableWriterFactory.builder(Descriptor descriptor) Returns a new builder which can create instance ofSSTableWriterwith the provided parameters.static SequentialWriterDataComponent.buildWriter(Descriptor descriptor, TableMetadata metadata, SequentialWriterOption options, MetadataCollector metadataCollector, OperationType operationType, Config.FlushCompression flushCompression) static voidSSTableReader.createLinks(Descriptor descriptor, Set<Component> components, String snapshotDirectoryPath) static voidSSTableReader.createLinks(Descriptor descriptor, Set<Component> components, String snapshotDirectoryPath, com.google.common.util.concurrent.RateLimiter limiter) voidSSTableFormat.delete(Descriptor descriptor) Deletes the existing components of the sstables represented by the provided descriptor.static voidSortedTableScrubber.deleteOrphanedComponents(Descriptor descriptor, Set<Component> components) voidSSTableFormat.deleteOrphanedComponents(Descriptor descriptor, Set<Component> components) static CompressionMetadataCompressionInfoComponent.load(Descriptor descriptor) static IFilterFilterComponent.load(Descriptor descriptor) Load bloom filter from Filter.db file.static StatsComponentStatsComponent.load(Descriptor descriptor) static StatsComponentStatsComponent.load(Descriptor descriptor, MetadataType... types) static CompressionMetadataCompressionInfoComponent.loadIfExists(Descriptor descriptor) SSTableFormat.SSTableReaderFactory.loadingBuilder(Descriptor descriptor, TableMetadataRef tableMetadataRef, Set<Component> components) A builder which opens/loads all the required resources upon execution ofSSTableReaderLoadingBuilder.build(SSTable.Owner, boolean, boolean)and passed them to the created reader instance.TOCComponent.loadOrCreate(Descriptor descriptor) Loads existing TOC file or creates a new one.TOCComponent.loadTOC(Descriptor descriptor) Reads the list of components from the TOC component.TOCComponent.loadTOC(Descriptor descriptor, boolean skipMissing) Reads the list of components from the TOC component.static CompressionMetadataCompressionInfoComponent.maybeLoad(Descriptor descriptor, Set<Component> components) static IFilterFilterComponent.maybeLoadBloomFilter(Descriptor descriptor, Set<Component> components, TableMetadata metadata, ValidationMetadata validationMetadata) Optionally loads a Bloom filter.static SSTableReaderSSTableReader.moveAndOpenSSTable(ColumnFamilyStore cfs, Descriptor oldDescriptor, Descriptor newDescriptor, Set<Component> components, boolean copyData) Moves the sstable in oldDescriptor to a new place (with generation etc) in newDescriptor.static SSTableReaderSSTableReader.open(SSTable.Owner owner, Descriptor descriptor) static SSTableReaderSSTableReader.open(SSTable.Owner owner, Descriptor descriptor, Set<Component> components, TableMetadataRef metadata) static SSTableReaderSSTableReader.open(SSTable.Owner owner, Descriptor descriptor, Set<Component> components, TableMetadataRef metadata, boolean validate, boolean isOffline) Open an SSTable for readingstatic SSTableReaderSSTableReader.open(SSTable.Owner owner, Descriptor desc, TableMetadataRef metadata) static SSTableReaderSSTableReader.openForBatch(SSTable.Owner owner, Descriptor descriptor, Set<Component> components, TableMetadataRef metadata) Open SSTable reader to be used in batch mode(such as sstableloader).static SSTableReaderSSTableReader.openNoValidation(Descriptor descriptor, Set<Component> components, ColumnFamilyStore cfs) static SSTableReaderSSTableReader.openNoValidation(SSTable.Owner owner, Descriptor descriptor, TableMetadataRef metadata) SSTableFormat.SSTableReaderFactory.readKeyRange(Descriptor descriptor, IPartitioner partitioner) Retrieves a key range for the given sstable at the lowest cost - that is, without opening all sstables files if possible.static voidTOCComponent.rewriteTOC(Descriptor descriptor, Collection<Component> components) Rewrites the TOC component by deleting and recreating it only with provided component names.static voidFilterComponent.save(IFilter filter, Descriptor descriptor, boolean deleteOnFailure) voidStatsComponent.save(Descriptor desc) static voidTOCComponent.updateTOC(Descriptor descriptor, Collection<Component> components) Updates the TOC file by reading existing component entries, merging them with the given components, sorting the combined list in lexicographic order for deterministic output.static voidCompressionInfoComponent.verifyCompressionInfoExistenceIfApplicable(Descriptor descriptor, 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 DescriptorModifier and TypeMethodDescriptionstatic Collection<SSTableReader>SSTableReader.openAll(SSTable.Owner owner, Set<Map.Entry<Descriptor, Set<Component>>> entries, TableMetadataRef metadata) <R,E extends Exception>
RSSTableReader.runWithLock(CheckedFunction<Descriptor, R, E> 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 DescriptorModifierConstructorDescriptionBuilder(Descriptor descriptor) Builder(Descriptor descriptor) Builder(Descriptor descriptor) Builder(Descriptor descriptor) -
Uses of Descriptor in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big with parameters of type DescriptorModifier and TypeMethodDescriptionvoidBigFormat.delete(Descriptor desc) voidBigFormat.deleteOrphanedComponents(Descriptor descriptor, Set<Component> components) Constructors in org.apache.cassandra.io.sstable.format.big with parameters of type Descriptor -
Uses of Descriptor in org.apache.cassandra.io.sstable.format.bti
Methods in org.apache.cassandra.io.sstable.format.bti with parameters of type DescriptorModifier and TypeMethodDescriptionvoidBtiFormat.delete(Descriptor desc) voidBtiFormat.deleteOrphanedComponents(Descriptor descriptor, Set<Component> components) Constructors in org.apache.cassandra.io.sstable.format.bti with parameters of type Descriptor -
Uses of Descriptor in org.apache.cassandra.io.sstable.metadata
Methods in org.apache.cassandra.io.sstable.metadata with parameters of type DescriptorModifier and TypeMethodDescriptionIMetadataSerializer.deserialize(Descriptor descriptor, EnumSet<MetadataType> types) Deserialize specified metadata components from given descriptor.IMetadataSerializer.deserialize(Descriptor descriptor, MetadataType type) Deserialized only metadata component specified from given descriptor.MetadataSerializer.deserialize(Descriptor descriptor, EnumSet<MetadataType> types) MetadataSerializer.deserialize(Descriptor descriptor, MetadataType type) MetadataSerializer.deserialize(Descriptor descriptor, FileDataInput in, EnumSet<MetadataType> selectedTypes) voidIMetadataSerializer.mutate(Descriptor descriptor, String description, 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, String description, 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, Map<MetadataType, MetadataComponent> currentComponents) Replace the sstable metadata file (-Statistics.db) with the given components.voidMetadataSerializer.rewriteSSTableMetadata(Descriptor descriptor, Map<MetadataType, MetadataComponent> currentComponents) -
Uses of Descriptor in org.apache.cassandra.schema
Methods in org.apache.cassandra.schema with parameters of type DescriptorModifier and TypeMethodDescriptionSchema.getTableMetadata(Descriptor descriptor) Schema.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 DescriptorModifier and TypeMethodDescriptionstatic 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 DescriptorModifier and TypeMethodDescriptionstatic IPartitionerFBUtilities.newPartitioner(Descriptor desc) Create a new instance of a partitioner defined in an SSTable Descriptor