Package org.apache.cassandra.db.compaction.unified

Class ShardedCompactionWriter

java.lang.Object

org.apache.cassandra.utils.concurrent.Transactional.AbstractTransactional

org.apache.cassandra.db.compaction.writers.CompactionAwareWriter

org.apache.cassandra.db.compaction.unified.ShardedCompactionWriter

All Implemented Interfaces:

AutoCloseable, Transactional

public class ShardedCompactionWriter
extends CompactionAwareWriter

A CompactionAwareWriter that splits the output sstable at the partition boundaries of the compaction shards used by UnifiedCompactionStrategy.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.utils.concurrent.Transactional.AbstractTransactional

Transactional.AbstractTransactional.State

Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Transactional

Transactional.AbstractTransactional

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	logger

Fields inherited from class org.apache.cassandra.db.compaction.writers.CompactionAwareWriter

cfs, currentDirectory, directories, estimatedTotalKeys, isTransient, maxAge, minRepairedAt, nonExpiredSSTables, pendingRepair, sstableWriter, txn

Constructor Summary

Constructors

Constructor	Description
ShardedCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, Set<SSTableReader> nonExpiredSSTables, boolean keepOriginals, ShardTracker boundaries)

Method Summary

Modifier and Type	Method	Description
protected void	doPrepare()	Do any preparatory work prior to commit.
protected boolean	shouldSwitchWriterInCurrentLocation(DecoratedKey key)	Returns true if the writer should be switched for reasons other than switching to a new data directory (e.g.
protected long	sstableKeyCount()	Returns the key count with which created sstables should be set up.
protected SSTableWriter	sstableWriter(Directories.DataDirectory directory, DecoratedKey nextKey)

Methods inherited from class org.apache.cassandra.db.compaction.writers.CompactionAwareWriter

append, doAbort, doCommit, doPostCleanup, estimatedKeys, finish, getDirectories, getExpectedWriteSize, getSStableDirectory, getWriteDirectory, maybeSwitchLocation, maybeSwitchWriter, newWriterBuilder, realAppend, setRepairedAt, sstableLevel, switchCompactionWriter

Methods inherited from class org.apache.cassandra.utils.concurrent.Transactional.AbstractTransactional

abort, abort, close, commit, commit, doPreCleanup, prepareToCommit, state

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cassandra.utils.concurrent.Transactional

abort, close, commit, prepareToCommit

Field Details

logger

protected static final org.slf4j.Logger logger

Constructor Details

ShardedCompactionWriter

public ShardedCompactionWriter(ColumnFamilyStore cfs,
 Directories directories,
 LifecycleTransaction txn,
 Set<SSTableReader> nonExpiredSSTables,
 boolean keepOriginals,
 ShardTracker boundaries)

Method Details

shouldSwitchWriterInCurrentLocation

protected boolean shouldSwitchWriterInCurrentLocation(DecoratedKey key)

Description copied from class: CompactionAwareWriter

Returns true if the writer should be switched for reasons other than switching to a new data directory (e.g. because an sstable size limit has been reached).

Specified by:

shouldSwitchWriterInCurrentLocation in class CompactionAwareWriter

sstableWriter

protected SSTableWriter sstableWriter(Directories.DataDirectory directory,
 DecoratedKey nextKey)

Overrides:

sstableWriter in class CompactionAwareWriter

sstableKeyCount

protected long sstableKeyCount()

Description copied from class: CompactionAwareWriter

Returns the key count with which created sstables should be set up.

Specified by:

sstableKeyCount in class CompactionAwareWriter

doPrepare

protected void doPrepare()

Description copied from class: Transactional.AbstractTransactional

Do any preparatory work prior to commit. This method should throw any exceptions that can be encountered during the finalization of the behaviour.

Overrides:

doPrepare in class CompactionAwareWriter