org.locationtech.geowave.datastore.accumulo.iterators

Class WholeRowAggregationIterator

java.lang.Object

org.apache.accumulo.core.iterators.user.RowEncodingIterator

org.apache.accumulo.core.iterators.user.WholeRowIterator

org.locationtech.geowave.datastore.accumulo.iterators.WholeRowQueryFilterIterator

org.locationtech.geowave.datastore.accumulo.iterators.WholeRowAggregationIterator

All Implemented Interfaces:

org.apache.accumulo.core.iterators.OptionDescriber, org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>, org.apache.accumulo.core.iterators.YieldingKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

public class WholeRowAggregationIterator
extends WholeRowQueryFilterIterator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	WholeRowAggregationIterator.WholeRowAggregationParent

Nested classes/interfaces inherited from interface org.apache.accumulo.core.iterators.OptionDescriber

org.apache.accumulo.core.iterators.OptionDescriber.IteratorOptions

Field Summary

Fields inherited from class org.locationtech.geowave.datastore.accumulo.iterators.WholeRowQueryFilterIterator

queryFilterIterator

Fields inherited from class org.apache.accumulo.core.iterators.user.RowEncodingIterator

MAX_BUFFER_SIZE_OPT, sourceIter

Constructor Summary

Constructors

Constructor and Description
WholeRowAggregationIterator()

Method Summary

Modifier and Type	Method and Description
org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>	deepCopy(org.apache.accumulo.core.iterators.IteratorEnvironment env)
protected boolean	filter(org.apache.hadoop.io.Text currentRow, List<org.apache.accumulo.core.data.Key> keys, List<org.apache.accumulo.core.data.Value> values)
org.apache.accumulo.core.data.Key	getTopKey()
org.apache.accumulo.core.data.Value	getTopValue()
boolean	hasTop()
void	init(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> source, Map<String,String> options, org.apache.accumulo.core.iterators.IteratorEnvironment env)
void	next()
void	seek(org.apache.accumulo.core.data.Range range, Collection<org.apache.accumulo.core.data.ByteSequence> columnFamilies, boolean inclusive)

Methods inherited from class org.apache.accumulo.core.iterators.user.WholeRowIterator

decodeRow, encodeRow, rowDecoder, rowEncoder

Methods inherited from class org.apache.accumulo.core.iterators.user.RowEncodingIterator

describeOptions, validateOptions

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.accumulo.core.iterators.YieldingKeyValueIterator

enableYielding

Constructor Detail

WholeRowAggregationIterator

public WholeRowAggregationIterator()

Method Detail

filter

protected boolean filter(org.apache.hadoop.io.Text currentRow,
                         List<org.apache.accumulo.core.data.Key> keys,
                         List<org.apache.accumulo.core.data.Value> values)

Overrides:

filter in class WholeRowQueryFilterIterator

init

public void init(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> source,
                 Map<String,String> options,
                 org.apache.accumulo.core.iterators.IteratorEnvironment env)
          throws IOException

Specified by:

init in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Overrides:

init in class WholeRowQueryFilterIterator

Throws:

IOException

deepCopy

public org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> deepCopy(org.apache.accumulo.core.iterators.IteratorEnvironment env)

Specified by:

deepCopy in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Overrides:

deepCopy in class org.apache.accumulo.core.iterators.user.RowEncodingIterator

getTopKey

public org.apache.accumulo.core.data.Key getTopKey()

Specified by:

getTopKey in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Overrides:

getTopKey in class org.apache.accumulo.core.iterators.user.RowEncodingIterator

getTopValue

public org.apache.accumulo.core.data.Value getTopValue()

Specified by:

getTopValue in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Overrides:

getTopValue in class org.apache.accumulo.core.iterators.user.RowEncodingIterator

hasTop

public boolean hasTop()

Specified by:

hasTop in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Overrides:

hasTop in class org.apache.accumulo.core.iterators.user.RowEncodingIterator

next

public void next()
          throws IOException

Specified by:

next in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Overrides:

next in class org.apache.accumulo.core.iterators.user.RowEncodingIterator

Throws:

IOException

seek

public void seek(org.apache.accumulo.core.data.Range range,
                 Collection<org.apache.accumulo.core.data.ByteSequence> columnFamilies,
                 boolean inclusive)
          throws IOException

Specified by:

seek in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Overrides:

seek in class org.apache.accumulo.core.iterators.user.RowEncodingIterator

Throws:

IOException