Package org.apache.cassandra.io.sstable.format

Class SortedTableScrubber<R extends SSTableReaderWithFilter>

java.lang.Object

org.apache.cassandra.io.sstable.format.SortedTableScrubber<R>

All Implemented Interfaces:

Closeable, AutoCloseable, IScrubber, Closeable

Direct Known Subclasses:

BigTableScrubber, BtiTableScrubber

@NotThreadSafe
public abstract class SortedTableScrubber<R extends SSTableReaderWithFilter>
extends Object
implements IScrubber

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SortedTableScrubber.ScrubInfo

Nested classes/interfaces inherited from interface org.apache.cassandra.io.sstable.IScrubber

IScrubber.Options, IScrubber.ScrubResult

Field Summary

Fields

Modifier and Type	Field	Description
protected int	badPartitions
protected final ColumnFamilyStore	cfs
protected final RandomAccessReader	dataFile
protected final File	destination
protected int	emptyPartitions
protected final long	expectedBloomFilterSize
protected final ReadWriteLock	fileAccessLock
protected int	goodPartitions
protected final boolean	isCommutative
protected final org.apache.cassandra.io.sstable.format.SortedTableScrubber.NegativeLocalDeletionInfoMetrics	negativeLocalDeletionInfoMetrics
protected final IScrubber.Options	options
protected final SortedSet<Partition>	outOfOrder
protected final OutputHandler	outputHandler
protected final SortedTableScrubber.ScrubInfo	scrubInfo
protected final R	sstable
protected final LifecycleTransaction	transaction

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SortedTableScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)

Method Summary

Modifier and Type	Method	Description
static void	deleteOrphanedComponents(Descriptor descriptor, Set<Component> components)
CompactionInfo.Holder	getScrubInfo()
protected String	keyString(DecoratedKey key)
void	scrub()
protected abstract void	scrubInternal(SSTableRewriter writer)
IScrubber.ScrubResult	scrubWithResult()
protected void	throwIfCannotContinue(DecoratedKey key, Throwable th)
protected static void	throwIfFatal(Throwable th)
protected boolean	tryAppend(DecoratedKey prevKey, DecoratedKey key, SSTableRewriter writer)
protected abstract UnfilteredRowIterator	withValidation(UnfilteredRowIterator iter, String filename)

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.io.sstable.IScrubber

close

Field Details

cfs

protected final ColumnFamilyStore cfs

transaction

protected final LifecycleTransaction transaction

destination

protected final File destination

options

protected final IScrubber.Options options

sstable

protected final R extends SSTableReaderWithFilter sstable

outputHandler

protected final OutputHandler outputHandler

isCommutative

protected final boolean isCommutative

expectedBloomFilterSize

protected final long expectedBloomFilterSize

fileAccessLock

protected final ReadWriteLock fileAccessLock

dataFile

protected final RandomAccessReader dataFile

scrubInfo

protected final SortedTableScrubber.ScrubInfo scrubInfo

negativeLocalDeletionInfoMetrics

protected final org.apache.cassandra.io.sstable.format.SortedTableScrubber.NegativeLocalDeletionInfoMetrics negativeLocalDeletionInfoMetrics

outOfOrder

protected final SortedSet<Partition> outOfOrder

goodPartitions

protected int goodPartitions

badPartitions

protected int badPartitions

emptyPartitions

protected int emptyPartitions

Constructor Details

SortedTableScrubber

protected SortedTableScrubber(ColumnFamilyStore cfs,
 LifecycleTransaction transaction,
 OutputHandler outputHandler,
 IScrubber.Options options)

Method Details

deleteOrphanedComponents

public static void deleteOrphanedComponents(Descriptor descriptor,
 Set<Component> components)

scrub

public void scrub()

Specified by:

scrub in interface IScrubber

scrubInternal

protected abstract void scrubInternal(SSTableRewriter writer)
                               throws IOException

Throws:

IOException

withValidation

protected abstract UnfilteredRowIterator withValidation(UnfilteredRowIterator iter,
 String filename)

scrubWithResult

public IScrubber.ScrubResult scrubWithResult()

Specified by:

scrubWithResult in interface IScrubber

getScrubInfo

public CompactionInfo.Holder getScrubInfo()

Specified by:

getScrubInfo in interface IScrubber

keyString

protected String keyString(DecoratedKey key)

tryAppend

protected boolean tryAppend(DecoratedKey prevKey,
 DecoratedKey key,
 SSTableRewriter writer)

throwIfFatal

protected static void throwIfFatal(Throwable th)

throwIfCannotContinue

protected void throwIfCannotContinue(DecoratedKey key,
 Throwable th)