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

Class BtiTableScrubber

java.lang.Object

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

org.apache.cassandra.io.sstable.format.bti.BtiTableScrubber

All Implemented Interfaces:

Closeable, AutoCloseable, IScrubber, Closeable

public class BtiTableScrubber
extends SortedTableScrubber<BtiTableReader>
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
BtiTableScrubber(ColumnFamilyStore cfs, LifecycleTransaction transaction, OutputHandler outputHandler, IScrubber.Options options)

Method Summary

Modifier and Type	Method	Description
void	close()
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

BtiTableScrubber

public BtiTableScrubber(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<BtiTableReader>

scrubInternal

public void scrubInternal(SSTableRewriter writer)

Specified by:

scrubInternal in class SortedTableScrubber<BtiTableReader>

throwIfCannotContinue

protected void throwIfCannotContinue(DecoratedKey key,
 Throwable th)

Overrides:

throwIfCannotContinue in class SortedTableScrubber<BtiTableReader>

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