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

Class BigTableScrubber

java.lang.Object

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

org.apache.cassandra.io.sstable.format.big.BigTableScrubber

All Implemented Interfaces:

Closeable, AutoCloseable, IScrubber, Closeable

public class BigTableScrubber
extends SortedTableScrubber<BigTableReader>
implements IScrubber

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.io.sstable.format.SortedTableScrubber

SortedTableScrubber.ScrubInfo

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

IScrubber.Options, IScrubber.ScrubResult

Field Summary

Fields inherited from class org.apache.cassandra.io.sstable.format.SortedTableScrubber

badPartitions, cfs, dataFile, destination, emptyPartitions, expectedBloomFilterSize, fileAccessLock, goodPartitions, isCommutative, negativeLocalDeletionInfoMetrics, options, outOfOrder, outputHandler, scrubInfo, sstable, transaction

Constructor Summary

Constructors

Constructor	Description
BigTableScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	scrubInternal(SSTableRewriter writer)
protected void	throwIfCannotContinue(DecoratedKey key, Throwable th)
protected UnfilteredRowIterator	withValidation(UnfilteredRowIterator iter, String filename)

Methods inherited from class org.apache.cassandra.io.sstable.format.SortedTableScrubber

deleteOrphanedComponents, getScrubInfo, keyString, scrub, scrubWithResult, throwIfFatal, tryAppend

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

getScrubInfo, scrub, scrubWithResult

Constructor Details

BigTableScrubber

public BigTableScrubber(ColumnFamilyStore cfs,
 LifecycleTransaction transaction,
 OutputHandler outputHandler,
 IScrubber.Options options)

Method Details

withValidation

protected UnfilteredRowIterator withValidation(UnfilteredRowIterator iter,
 String filename)

Specified by:

withValidation in class SortedTableScrubber<BigTableReader>

scrubInternal

protected void scrubInternal(SSTableRewriter writer)
                      throws IOException

Specified by:

scrubInternal in class SortedTableScrubber<BigTableReader>

Throws:

IOException

throwIfCannotContinue

protected void throwIfCannotContinue(DecoratedKey key,
 Throwable th)

Overrides:

throwIfCannotContinue in class SortedTableScrubber<BigTableReader>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Closeable

Specified by:

close in interface IScrubber