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

Class SortedTableVerifier<R extends SSTableReaderWithFilter>

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, IVerifier

Direct Known Subclasses:

BigTableVerifier, BtiTableVerifier

public abstract class SortedTableVerifier<R extends SSTableReaderWithFilter>
extends Object
implements IVerifier

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SortedTableVerifier.RangeOwnHelper	Use the fact that check(...) is called with sorted tokens - we keep a pointer in to the normalized ranges and only bump the pointer if the key given is out of range.
protected static class	SortedTableVerifier.VerifyController
protected static class	SortedTableVerifier.VerifyInfo

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

IVerifier.Options

Field Summary

Fields

Modifier and Type	Field	Description
protected final ColumnFamilyStore	cfs
protected final RandomAccessReader	dataFile
protected final ReadWriteLock	fileAccessLock
protected int	goodRows
protected final boolean	isOffline
protected final IVerifier.Options	options
protected final OutputHandler	outputHandler
protected final R	sstable
protected final Function<String,? extends Collection<Range<Token>>>	tokenLookup	Given a keyspace, return the set of local and pending token ranges.
protected final SortedTableVerifier.VerifyInfo	verifyInfo

Constructor Summary

Constructors

Constructor	Description
SortedTableVerifier(ColumnFamilyStore cfs, R sstable, OutputHandler outputHandler, boolean isOffline, IVerifier.Options options)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	deserializeBloomFilter(SSTableReader sstable)
CompactionInfo.Holder	getVerifyInfo()
protected void	markAndThrow(Throwable cause)
protected void	markAndThrow(Throwable cause, boolean mutateRepaired)
void	verify()
protected void	verifyBloomFilter()
protected boolean	verifyDigest()
protected void	verifyIndex()
protected int	verifyOwnedRanges()
protected abstract void	verifyPartition(DecoratedKey key, UnfilteredRowIterator iterator)
protected void	verifySSTable()
protected void	verifySSTableMetadata()
protected void	verifySSTableVersion()

Methods inherited from class java.lang.Object

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

Field Details

cfs

protected final ColumnFamilyStore cfs

sstable

protected final R extends SSTableReaderWithFilter sstable

fileAccessLock

protected final ReadWriteLock fileAccessLock

dataFile

protected final RandomAccessReader dataFile

verifyInfo

protected final SortedTableVerifier.VerifyInfo verifyInfo

options

protected final IVerifier.Options options

isOffline

protected final boolean isOffline

tokenLookup

protected final Function<String,? extends Collection<Range<Token>>> tokenLookup

Given a keyspace, return the set of local and pending token ranges. By default StorageService.getLocalAndPendingRanges(String) is expected, but for the standalone verifier case we can't use that, so this is here to allow the CLI to provide the token ranges.

goodRows

protected int goodRows

outputHandler

protected final OutputHandler outputHandler

Constructor Details

SortedTableVerifier

public SortedTableVerifier(ColumnFamilyStore cfs,
 R sstable,
 OutputHandler outputHandler,
 boolean isOffline,
 IVerifier.Options options)

Method Details

deserializeBloomFilter

protected void deserializeBloomFilter(SSTableReader sstable)
                               throws IOException

Throws:

IOException

getVerifyInfo

public CompactionInfo.Holder getVerifyInfo()

Specified by:

getVerifyInfo in interface IVerifier

markAndThrow

protected void markAndThrow(Throwable cause)

markAndThrow

protected void markAndThrow(Throwable cause,
 boolean mutateRepaired)

verify

public void verify()

Specified by:

verify in interface IVerifier

verifyBloomFilter

protected void verifyBloomFilter()

verifySSTableMetadata

protected void verifySSTableMetadata()

verifySSTableVersion

protected void verifySSTableVersion()

verifyOwnedRanges

protected int verifyOwnedRanges()

verifyDigest

protected boolean verifyDigest()

verifySSTable

protected void verifySSTable()

verifyPartition

protected abstract void verifyPartition(DecoratedKey key,
 UnfilteredRowIterator iterator)

verifyIndex

protected void verifyIndex()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface IVerifier