Package org.apache.cassandra.db.repair
Class CassandraValidationIterator
- java.lang.Object
-
- org.apache.cassandra.db.partitions.AbstractUnfilteredPartitionIterator
-
- org.apache.cassandra.repair.ValidationPartitionIterator
-
- org.apache.cassandra.db.repair.CassandraValidationIterator
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,java.util.Iterator<UnfilteredRowIterator>
,BasePartitionIterator<UnfilteredRowIterator>
,UnfilteredPartitionIterator
,CloseableIterator<UnfilteredRowIterator>
public class CassandraValidationIterator extends ValidationPartitionIterator
-
-
Constructor Summary
Constructors Constructor Description CassandraValidationIterator(ColumnFamilyStore cfs, java.util.Collection<Range<Token>> ranges, java.util.UUID parentId, java.util.UUID sessionID, boolean isIncremental, int nowInSec)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
long
estimatedPartitions()
static int
getDefaultGcBefore(ColumnFamilyStore cfs, int nowInSec)
long
getEstimatedBytes()
java.util.Map<Range<Token>,java.lang.Long>
getRangePartitionCounts()
boolean
hasNext()
TableMetadata
metadata()
UnfilteredRowIterator
next()
-
Methods inherited from class org.apache.cassandra.db.partitions.AbstractUnfilteredPartitionIterator
remove
-
-
-
-
Constructor Detail
-
CassandraValidationIterator
public CassandraValidationIterator(ColumnFamilyStore cfs, java.util.Collection<Range<Token>> ranges, java.util.UUID parentId, java.util.UUID sessionID, boolean isIncremental, int nowInSec) throws java.io.IOException
- Throws:
java.io.IOException
-
-
Method Detail
-
getDefaultGcBefore
public static int getDefaultGcBefore(ColumnFamilyStore cfs, int nowInSec)
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceBasePartitionIterator<UnfilteredRowIterator>
- Specified by:
close
in interfaceCloseableIterator<UnfilteredRowIterator>
- Overrides:
close
in classAbstractUnfilteredPartitionIterator
-
metadata
public TableMetadata metadata()
-
hasNext
public boolean hasNext()
-
next
public UnfilteredRowIterator next()
-
getEstimatedBytes
public long getEstimatedBytes()
- Specified by:
getEstimatedBytes
in classValidationPartitionIterator
-
estimatedPartitions
public long estimatedPartitions()
- Specified by:
estimatedPartitions
in classValidationPartitionIterator
-
getRangePartitionCounts
public java.util.Map<Range<Token>,java.lang.Long> getRangePartitionCounts()
- Specified by:
getRangePartitionCounts
in classValidationPartitionIterator
-
-