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 sourceSortedKeyValueIterator.
-
-
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 overValues whoseKeys are versions of the current topKey of the sourceSortedKeyValueIterator.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanhasNext()Propertiesnext()voidremove()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 overValues whoseKeys are versions of the current topKey of the sourceSortedKeyValueIterator.- Parameters:
source- TheSortedKeyValueIteratorofKey,Valuepairs from which to read data.group- the element groupelementConverter- the elementConverter to useschema- the schemagroupBy- the groupBy properties
-
-
Method Detail
-
hasNext
public boolean hasNext()
- Specified by:
hasNextin interfaceIterator<Properties>
-
next
public Properties next()
- Specified by:
nextin interfaceIterator<Properties>
-
remove
public void remove()
unsupported- Specified by:
removein interfaceIterator<Properties>
-
-