Package uk.gov.gchq.gaffer.accumulostore.key.impl

Class AggregatorIterator

java.lang.Object

org.apache.accumulo.core.iterators.WrappingIterator

org.apache.accumulo.core.iterators.Combiner

uk.gov.gchq.gaffer.accumulostore.key.impl.AggregatorIterator

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 AggregatorIterator
extends org.apache.accumulo.core.iterators.Combiner

The aggregator iterator is used to combine Values where the Key is the same (Except for the Timestamp column). The instructions provided in the schema define how the aggregation takes place and therefore what the resulting Value will be.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.accumulo.core.iterators.Combiner

org.apache.accumulo.core.iterators.Combiner.ValueIterator

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

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

Constructor Summary

Constructors

Constructor	Description
AggregatorIterator()

Method Summary

Modifier and Type	Method	Description
org.apache.accumulo.core.iterators.OptionDescriber.IteratorOptions	describeOptions()
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)
org.apache.accumulo.core.data.Value	reduce(org.apache.accumulo.core.data.Key key, Iterator<org.apache.accumulo.core.data.Value> iter)
boolean	validateOptions(Map<String,String> options)

Methods inherited from class org.apache.accumulo.core.iterators.Combiner

deepCopy, getTopKey, getTopValue, hasTop, next, seek, setColumns, setCombineAllColumns, setReduceOnFullCompactionOnly

Methods inherited from class java.lang.Object

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

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

enableYielding

Constructor Detail

AggregatorIterator

public AggregatorIterator()

Method Detail

reduce

public org.apache.accumulo.core.data.Value reduce(org.apache.accumulo.core.data.Key key,
                                                  Iterator<org.apache.accumulo.core.data.Value> iter)

Specified by:

reduce in class org.apache.accumulo.core.iterators.Combiner

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 org.apache.accumulo.core.iterators.Combiner

Throws:

IOException

validateOptions

public boolean validateOptions(Map<String,String> options)

Specified by:

validateOptions in interface org.apache.accumulo.core.iterators.OptionDescriber

Overrides:

validateOptions in class org.apache.accumulo.core.iterators.Combiner

describeOptions

public org.apache.accumulo.core.iterators.OptionDescriber.IteratorOptions describeOptions()

Specified by:

describeOptions in interface org.apache.accumulo.core.iterators.OptionDescriber

Overrides:

describeOptions in class org.apache.accumulo.core.iterators.Combiner