Package uk.gov.gchq.gaffer.sparkaccumulo.operation.rfilereaderrdd

Class RFileReaderIterator

java.lang.Object

uk.gov.gchq.gaffer.sparkaccumulo.operation.rfilereaderrdd.RFileReaderIterator

All Implemented Interfaces:

Iterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>>

public class RFileReaderIterator
extends Object
implements Iterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>>

A RFileReaderIterator is a Iterator formed by merging iterators over a set of RFiles.

Constructor Summary

Constructors

Constructor	Description
RFileReaderIterator(org.apache.spark.Partition partition, org.apache.spark.TaskContext taskContext, org.apache.hadoop.conf.Configuration configuration, Set<String> auths)

Method Summary

Modifier and Type	Method	Description
boolean	hasNext()
Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

RFileReaderIterator

public RFileReaderIterator(org.apache.spark.Partition partition,
                           org.apache.spark.TaskContext taskContext,
                           org.apache.hadoop.conf.Configuration configuration,
                           Set<String> auths)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>>

next

public Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> next()

Specified by:

next in interface Iterator<Map.Entry<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>>