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

Class CoreKeyGroupByAggregatorIterator

java.lang.Object

org.apache.accumulo.core.iterators.WrappingIterator

uk.gov.gchq.gaffer.accumulostore.key.core.impl.CoreKeyGroupByCombiner

uk.gov.gchq.gaffer.accumulostore.key.core.impl.CoreKeyGroupByAggregatorIterator

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 CoreKeyGroupByAggregatorIterator
extends CoreKeyGroupByCombiner

Nested Class Summary

Nested classes/interfaces inherited from class uk.gov.gchq.gaffer.accumulostore.key.core.impl.CoreKeyGroupByCombiner

CoreKeyGroupByCombiner.KeyValueIterator

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

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

Constructor Summary

Constructors

Constructor	Description
CoreKeyGroupByAggregatorIterator()

Method Summary

Modifier and Type	Method	Description
org.apache.accumulo.core.iterators.OptionDescriber.IteratorOptions	describeOptions()
Properties	reduce(String group, org.apache.accumulo.core.data.Key key, Iterator<Properties> iter, Set<String> groupBy, ElementAggregator viewAggregator)	Reduces an iterator of Properties into a single Properties object.

Methods inherited from class uk.gov.gchq.gaffer.accumulostore.key.core.impl.CoreKeyGroupByCombiner

deepCopy, getTopKey, getTopValue, hasTop, init, next, seek, validateOptions

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

CoreKeyGroupByAggregatorIterator

public CoreKeyGroupByAggregatorIterator()

Method Detail

reduce

public Properties reduce(String group,
                         org.apache.accumulo.core.data.Key key,
                         Iterator<Properties> iter,
                         Set<String> groupBy,
                         ElementAggregator viewAggregator)

Description copied from class: CoreKeyGroupByCombiner

Reduces an iterator of Properties into a single Properties object.

Specified by:

reduce in class CoreKeyGroupByCombiner

Parameters:

group - the schema group taken from the key

key - The most recent version of the Key being reduced.

iter - An iterator over all Properties for different versions of the key.

groupBy - the groupBy properties

viewAggregator - an optional view aggregator

Returns:

The combined Properties.

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 CoreKeyGroupByCombiner