public abstract static class DataLimits.Counter extends StoppingTransformation<BaseRowIterator<?>>
Constructor and Description |
---|
Counter() |
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
applyTo(PartitionIterator partitions) |
RowIterator |
applyTo(RowIterator partition) |
UnfilteredPartitionIterator |
applyTo(UnfilteredPartitionIterator partitions) |
UnfilteredRowIterator |
applyTo(UnfilteredRowIterator partition) |
protected BaseRowIterator<?> |
applyToPartition(BaseRowIterator<?> partition)
Applied to any rows iterator (partition) we encounter in a partitions iterator
|
protected abstract void |
applyToPartition(DecoratedKey partitionKey,
Row staticRow) |
protected void |
attachTo(BasePartitions partitions) |
protected void |
attachTo(BaseRows rows) |
abstract int |
counted()
The number of results counted.
|
abstract int |
countedInCurrentPartition() |
abstract boolean |
isDone() |
abstract boolean |
isDoneForPartition() |
DataLimits.Counter |
onlyCount() |
onClose, onPartitionClose, stop, stopInPartition
apply, apply, apply, apply, applyToDeletion, applyToMarker, applyToPartitionKey, applyToRow, applyToStatic
public DataLimits.Counter onlyCount()
public PartitionIterator applyTo(PartitionIterator partitions)
public UnfilteredPartitionIterator applyTo(UnfilteredPartitionIterator partitions)
public UnfilteredRowIterator applyTo(UnfilteredRowIterator partition)
public RowIterator applyTo(RowIterator partition)
public abstract int counted()
Note that the definition of "results" should be the same that for DataLimits.count()
.
public abstract int countedInCurrentPartition()
public abstract boolean isDone()
public abstract boolean isDoneForPartition()
protected BaseRowIterator<?> applyToPartition(BaseRowIterator<?> partition)
Transformation
applyToPartition
in class Transformation<BaseRowIterator<?>>
protected abstract void applyToPartition(DecoratedKey partitionKey, Row staticRow)
protected void attachTo(BasePartitions partitions)
attachTo
in class StoppingTransformation<BaseRowIterator<?>>
protected void attachTo(BaseRows rows)
attachTo
in class StoppingTransformation<BaseRowIterator<?>>
Copyright © 2017 The Apache Software Foundation