Package uk.gov.gchq.gaffer.accumulostore.retriever

Class AccumuloSetRetriever<OP extends InputOutput<Iterable<? extends EntityId>,Iterable<? extends Element>> & GraphFilters>

java.lang.Object

uk.gov.gchq.gaffer.accumulostore.retriever.AccumuloRetriever<OP,Element>

uk.gov.gchq.gaffer.accumulostore.retriever.AccumuloSetRetriever<OP>

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Element>

Direct Known Subclasses:

AccumuloIDBetweenSetsRetriever, AccumuloIDWithinSetRetriever

public abstract class AccumuloSetRetriever<OP extends InputOutput<Iterable<? extends EntityId>,Iterable<? extends Element>> & GraphFilters>
extends AccumuloRetriever<OP,Element>

Constructor Summary

Constructors

Constructor	Description
AccumuloSetRetriever(AccumuloStore store, OP operation, User user)
AccumuloSetRetriever(AccumuloStore store, OP operation, User user, boolean readEntriesIntoMemory)
AccumuloSetRetriever(AccumuloStore store, OP operation, User user, boolean readEntriesIntoMemory, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
AccumuloSetRetriever(AccumuloStore store, OP operation, User user, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)

Method Summary

Modifier and Type	Method	Description
Iterator<Element>	iterator()	Only 1 iterator can be open at a time.
void	setReadEntriesIntoMemory(boolean readEntriesIntoMemory)

Methods inherited from class uk.gov.gchq.gaffer.accumulostore.retriever.AccumuloRetriever

close, doPostFilter, doTransformation

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

AccumuloSetRetriever

public AccumuloSetRetriever(AccumuloStore store,
                            OP operation,
                            User user)
                     throws StoreException

Throws:

StoreException

AccumuloSetRetriever

public AccumuloSetRetriever(AccumuloStore store,
                            OP operation,
                            User user,
                            boolean readEntriesIntoMemory)
                     throws StoreException

Throws:

StoreException

AccumuloSetRetriever

public AccumuloSetRetriever(AccumuloStore store,
                            OP operation,
                            User user,
                            org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
                     throws StoreException

Throws:

StoreException

AccumuloSetRetriever

public AccumuloSetRetriever(AccumuloStore store,
                            OP operation,
                            User user,
                            boolean readEntriesIntoMemory,
                            org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
                     throws StoreException

Throws:

StoreException

Method Detail

setReadEntriesIntoMemory

public void setReadEntriesIntoMemory(boolean readEntriesIntoMemory)

iterator

public Iterator<Element> iterator()

Only 1 iterator can be open at a time.

Returns:

a closeable iterator of items.