Uses of Enum Class
org.apache.cassandra.db.compaction.OperationType
Packages that use OperationType
Package
Description
-
Uses of OperationType in org.apache.cassandra.db
Methods in org.apache.cassandra.db with parameters of type OperationTypeModifier and TypeMethodDescriptionlongColumnFamilyStore.getExpectedCompactedFileSize(Iterable<SSTableReader> sstables, OperationType operation) Calculate expected file size of SSTable after compaction.voidColumnFamilyStore.markObsolete(Collection<SSTableReader> sstables, OperationType compactionType) <V> VColumnFamilyStore.runWithCompactionsDisabled(Callable<V> callable, com.google.common.base.Predicate<SSTableReader> sstablesPredicate, OperationType operationType, boolean interruptValidation, boolean interruptViews, boolean interruptIndexes) Runs callable with compactions paused and compactions including sstables matching sstablePredicate stopped<V> VColumnFamilyStore.runWithCompactionsDisabled(Callable<V> callable, OperationType operationType, boolean interruptValidation, boolean interruptViews) <T> TColumnFamilyStore.withAllSSTables(OperationType operationType, com.google.common.base.Function<LifecycleTransaction, T> op) -
Uses of OperationType in org.apache.cassandra.db.compaction
Fields in org.apache.cassandra.db.compaction declared as OperationTypeMethods in org.apache.cassandra.db.compaction that return OperationTypeModifier and TypeMethodDescriptionstatic OperationTypeOperationType.fromFileName(String fileName) CompactionInfo.getTaskType()static OperationTypeReturns the enum constant of this class with the specified name.static OperationType[]OperationType.values()Returns an array containing the constants of this enum class, in the order they are declared.Methods in org.apache.cassandra.db.compaction with parameters of type OperationTypeModifier and TypeMethodDescriptionActiveCompactions.getCompactionsForSSTable(SSTableReader sstable, OperationType compactionType) Iterates over the active compactions and tries to find CompactionInfos with the given compactionType for the given sstable Number of entries in compactions should be small (< 10) but avoid calling in any time-sensitive contextCompactionStrategyManager.getMaximalTasks(long gcBefore, boolean splitOutput, OperationType operationType) AbstractCompactionTask.setCompactionType(OperationType compactionType) CompactionManager.submitMaximal(ColumnFamilyStore cfStore, long gcBefore, boolean splitOutput, OperationType operationType) static CompactionInfoCompactionInfo.withoutSSTables(TableMetadata metadata, OperationType tasktype, long completed, long total, CompactionInfo.Unit unit, TimeUUID compactionId) Special compaction info where we always need to cancel the compaction - for example ViewBuilderTask where we don't know the sstables at constructionstatic CompactionInfoCompactionInfo.withoutSSTables(TableMetadata metadata, OperationType tasktype, long completed, long total, CompactionInfo.Unit unit, TimeUUID compactionId, String targetDirectory) Special compaction info where we always need to cancel the compaction - for example AutoSavingCache where we don't know the sstables at constructionConstructors in org.apache.cassandra.db.compaction with parameters of type OperationTypeModifierConstructorDescriptionCompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, CompactionInfo.Unit unit, TimeUUID compactionId, Collection<? extends SSTableReader> sstables, String targetDirectory) CompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, TimeUUID compactionId, Collection<? extends SSTableReader> sstables) CompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, TimeUUID compactionId, Collection<SSTableReader> sstables, String targetDirectory) CompactionIterator(OperationType type, List<ISSTableScanner> scanners, AbstractCompactionController controller, long nowInSec, TimeUUID compactionId) CompactionIterator(OperationType type, List<ISSTableScanner> scanners, AbstractCompactionController controller, long nowInSec, TimeUUID compactionId, ActiveCompactionsTracker activeCompactions, TopPartitionTracker.Collector topPartitionCollector) -
Uses of OperationType in org.apache.cassandra.db.lifecycle
Methods in org.apache.cassandra.db.lifecycle that return OperationTypeModifier and TypeMethodDescriptionLifecycleNewTracker.opType()LifecycleTransaction.opType()WrappedLifecycleTransaction.opType()Methods in org.apache.cassandra.db.lifecycle with parameters of type OperationTypeModifier and TypeMethodDescriptionTracker.dropSSTables(com.google.common.base.Predicate<SSTableReader> remove, OperationType operationType, Throwable accumulate) removes all sstables that are not busy compacting.static LifecycleTransactionLifecycleTransaction.offline(OperationType operationType) construct an empty Transaction with no existing readersstatic LifecycleTransactionLifecycleTransaction.offline(OperationType operationType, Collection<SSTableReader> readers) construct a Transaction for use in an offline operationstatic LifecycleTransactionLifecycleTransaction.offline(OperationType operationType, SSTableReader reader) construct a Transaction for use in an offline operationTracker.tryModify(Iterable<? extends SSTableReader> sstables, OperationType operationType) Tracker.tryModify(SSTableReader sstable, OperationType operationType) -
Uses of OperationType in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform with parameters of type OperationTypeModifier and TypeMethodDescriptionstatic UnfilteredPartitionIteratorDuplicateRowChecker.duringCompaction(UnfilteredPartitionIterator iterator, OperationType type) -
Uses of OperationType in org.apache.cassandra.index.sai.disk
Methods in org.apache.cassandra.index.sai.disk with parameters of type OperationTypeModifier and TypeMethodDescriptionstatic RowMappingRowMapping.create(OperationType opType) Create row mapping for FLUSH operation only. -
Uses of OperationType in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type OperationTypeModifier and TypeMethodDescriptionprotected static PerSSTableIndexWriterSASIIndex.newWriter(AbstractType<?> keyValidator, Descriptor descriptor, Map<ColumnMetadata, ColumnIndex> indexes, OperationType opType) -
Uses of OperationType in org.apache.cassandra.index.sasi.disk
Constructors in org.apache.cassandra.index.sasi.disk with parameters of type OperationTypeModifierConstructorDescriptionPerSSTableIndexWriter(AbstractType<?> keyValidator, Descriptor descriptor, OperationType source, Map<ColumnMetadata, ColumnIndex> supportedIndexes) -
Uses of OperationType in org.apache.cassandra.io.sstable.format
Methods in org.apache.cassandra.io.sstable.format with parameters of type OperationTypeModifier and TypeMethodDescriptionstatic SequentialWriterDataComponent.buildWriter(Descriptor descriptor, TableMetadata metadata, SequentialWriterOption options, MetadataCollector metadataCollector, OperationType operationType, Config.FlushCompression flushCompression) -
Uses of OperationType in org.apache.cassandra.notifications
Fields in org.apache.cassandra.notifications declared as OperationTypeModifier and TypeFieldDescriptionfinal OperationTypeSSTableListChangedNotification.compactionTypeConstructors in org.apache.cassandra.notifications with parameters of type OperationTypeModifierConstructorDescriptionSSTableListChangedNotification(Collection<SSTableReader> added, Collection<SSTableReader> removed, OperationType compactionType)