Uses of Interface
org.apache.cassandra.io.sstable.SSTableMultiWriter
Packages that use SSTableMultiWriter
Package
Description
File transfer
-
Uses of SSTableMultiWriter in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return SSTableMultiWriterModifier 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) -
Uses of SSTableMultiWriter in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction that return SSTableMultiWriterModifier 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. -
Uses of SSTableMultiWriter in org.apache.cassandra.db.compaction.unified
Classes in org.apache.cassandra.db.compaction.unified that implement SSTableMultiWriterModifier and TypeClassDescriptionclassASSTableMultiWriterthat splits the output sstable at the partition boundaries of the compaction shards used byUnifiedCompactionStrategy.Methods in org.apache.cassandra.db.compaction.unified that return SSTableMultiWriter -
Uses of SSTableMultiWriter in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable that return SSTableMultiWriterModifier and TypeMethodDescriptionFlushing.FlushRunnable.call()static SSTableMultiWriterFlushing.createFlushWriter(ColumnFamilyStore cfs, Memtable.FlushablePartitionSet<?> flushSet, LifecycleTransaction txn, Descriptor descriptor, long partitionCount) Constructors in org.apache.cassandra.db.memtable with parameters of type SSTableMultiWriterModifierConstructorDescriptionFlushRunnable(Memtable.FlushablePartitionSet<?> flushSet, SSTableMultiWriter writer, TableMetrics metrics, boolean logCompletion) -
Uses of SSTableMultiWriter in org.apache.cassandra.db.streaming
Methods in org.apache.cassandra.db.streaming that return SSTableMultiWriterModifier and TypeMethodDescriptionprotected SSTableMultiWriterCassandraStreamReader.createWriter(ColumnFamilyStore cfs, long totalSize, long repairedAt, TimeUUID pendingRepair, SSTableFormat<?, ?> format) CassandraIncomingFile.getSSTable()CassandraCompressedStreamReader.read(DataInputPlus inputPlus) CassandraEntireSSTableStreamReader.read(DataInputPlus in) CassandraStreamReader.read(DataInputPlus inputPlus) IStreamReader.read(DataInputPlus inputPlus) Methods in org.apache.cassandra.db.streaming with parameters of type SSTableMultiWriterModifier and TypeMethodDescriptionprotected CassandraStreamReader.StreamDeserializerCassandraStreamReader.getDeserializer(TableMetadata metadata, TrackedDataInputPlus in, Version inputVersion, StreamSession session, SSTableMultiWriter writer) protected voidCassandraStreamReader.writePartition(CassandraStreamReader.StreamDeserializer deserializer, SSTableMultiWriter writer) Constructors in org.apache.cassandra.db.streaming with parameters of type SSTableMultiWriterModifierConstructorDescriptionStreamDeserializer(TableMetadata metadata, DataInputPlus in, Version version, SerializationHeader header, StreamSession session, SSTableMultiWriter writer) -
Uses of SSTableMultiWriter in org.apache.cassandra.io.sstable
Classes in org.apache.cassandra.io.sstable that implement SSTableMultiWriterModifier and TypeClassDescriptionclassclassclassMethods in org.apache.cassandra.io.sstable that return SSTableMultiWriterModifier and TypeMethodDescriptionstatic 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) RangeAwareSSTableWriter.setOpenResult(boolean openResult) SimpleSSTableMultiWriter.setOpenResult(boolean openResult) SSTableMultiWriter.setOpenResult(boolean openResult) SSTableZeroCopyWriter.setOpenResult(boolean openResult) Methods in org.apache.cassandra.io.sstable with parameters of type SSTableMultiWriterModifier and TypeMethodDescriptionstatic voidSSTableMultiWriter.abortOrDie(SSTableMultiWriter writer) Constructors in org.apache.cassandra.io.sstable with parameters of type SSTableMultiWriterModifierConstructorDescriptionSSTableTxnWriter(LifecycleTransaction txn, SSTableMultiWriter writer)