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

Class CoreKeyGroupByCombiner.KeyValueIterator

java.lang.Object

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

All Implemented Interfaces:

Iterator<Properties>

Enclosing class:

CoreKeyGroupByCombiner

public static class CoreKeyGroupByCombiner.KeyValueIterator
extends Object
implements Iterator<Properties>

A Java Iterator that iterates over the properties for a given row Key and column family from a source SortedKeyValueIterator.

Constructor Summary

Constructors

Constructor	Description
KeyValueIterator(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> source, String group, AccumuloElementConverter elementConverter, Schema schema, Set<String> groupBy)	Constructs an iterator over Values whose Keys are versions of the current topKey of the source SortedKeyValueIterator.

Method Summary

Modifier and Type	Method	Description
boolean	hasNext()
Properties	next()
void	remove()	unsupported

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

KeyValueIterator

public KeyValueIterator(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> source,
                        String group,
                        AccumuloElementConverter elementConverter,
                        Schema schema,
                        Set<String> groupBy)

Constructs an iterator over Values whose Keys are versions of the current topKey of the source SortedKeyValueIterator.

Parameters:

source - The SortedKeyValueIterator of Key, Value pairs from which to read data.

group - the element group

elementConverter - the elementConverter to use

schema - the schema

groupBy - the groupBy properties

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Properties>

next

public Properties next()

Specified by:

next in interface Iterator<Properties>

remove

public void remove()

unsupported

Specified by:

remove in interface Iterator<Properties>