Uses of Interface
com.bigdata.relation.accesspath.IAsynchronousIterator

Packages that use IAsynchronousIterator

com.bigdata.bop.engine
com.bigdata.relation.accesspath	This package includes an abstraction layer for efficient access paths, including chunked iterators, blocking buffers, and an abstraction corresponding to the natural order of an index.
com.bigdata.relation.rule.eval	This package supports rule evaluation.
com.bigdata.relation.rule.eval.pipeline	This package implements a pipeline join.
com.bigdata.service	This package provides implementations of bigdata services (metadata service, data service, transaction manager service.
com.bigdata.service.jini
com.bigdata.service.ndx.pipeline
com.bigdata.service.proxy	This package provides implementations of proxy objects for commonly used classes.

Uses of IAsynchronousIterator in com.bigdata.bop.engine

Methods in com.bigdata.bop.engine that return IAsynchronousIterator

IAsynchronousIterator<E>

OutputStatsBuffer.iterator()

Uses of IAsynchronousIterator in com.bigdata.relation.accesspath

Classes in com.bigdata.relation.accesspath that implement IAsynchronousIterator

protected class	BlockingBuffer.BlockingIterator An inner class that reads from the buffer.
class	EmptyAsynchronousIterator<E> An empty IAsynchronousIterator.
class	ThickAsynchronousIterator<E> An IAsynchronousIterator that may be serialized and sent to a remote JVM for consumption.
class	WrappedAsynchronousIterator<E,F> An IAsynchronousIterator that wraps an IChunkedIterator or a ICloseableIterator.

Methods in com.bigdata.relation.accesspath that return IAsynchronousIterator

IAsynchronousIterator<E>	BlockingBuffer.iterator() The iterator is NOT thread-safe and does NOT support remove().
IAsynchronousIterator<E>	IBlockingBuffer.iterator() Return an iterator reading from the buffer.
IAsynchronousIterator<E>	DelegateBuffer.iterator()

Uses of IAsynchronousIterator in com.bigdata.relation.rule.eval

Methods in com.bigdata.relation.rule.eval that return IAsynchronousIterator

protected IAsynchronousIterator<ISolution[]>

ProgramTask.executeQuery(IStep step) Execute the IStep as a query.

Uses of IAsynchronousIterator in com.bigdata.relation.rule.eval.pipeline

Methods in com.bigdata.relation.rule.eval.pipeline with parameters of type IAsynchronousIterator

boolean

DistributedJoinTask.addSource(IAsynchronousIterator<IBindingSet[]> source) Adds a source from which this DistributedJoinTask will read IBindingSet chunks.

Constructors in com.bigdata.relation.rule.eval.pipeline with parameters of type IAsynchronousIterator

DistributedJoinTask(IRule rule, IJoinNexus joinNexus, int[] order, int orderIndex, int partitionId, AbstractScaleOutFederation<?> fed, IJoinMaster master, UUID masterUUID, IAsynchronousIterator<IBindingSet[]> src, IKeyOrder[] keyOrders, DataService dataService, IVariable[][] requiredVars)

JoinTaskFactoryTask(String scaleOutIndexName, IRule rule, IJoinNexusFactory joinNexusFactory, int[] order, int orderIndex, int partitionId, IJoinMaster masterProxy, UUID masterUUID, IAsynchronousIterator<IBindingSet[]> sourceItrProxy, IKeyOrder[] keyOrders, IVariable[][] requiredVars)

LocalJoinTask(IRule rule, IJoinNexus joinNexus, int[] order, int orderIndex, IJoinMaster masterProxy, UUID masterUUID, IAsynchronousIterator<IBindingSet[]> source, IBuffer<ISolution[]> solutionBuffer, IVariable[][] requiredVars)

Uses of IAsynchronousIterator in com.bigdata.service

Methods in com.bigdata.service that return IAsynchronousIterator

abstract <E> IAsynchronousIterator<E>

AbstractDistributedFederation.getProxy(IAsynchronousIterator<E> src, IStreamSerializer<E> serializer, int capacity) Return a proxy object for an IAsynchronousIterator suiteable for use in an RMI environment.

Methods in com.bigdata.service with parameters of type IAsynchronousIterator

abstract <E> IAsynchronousIterator<E>

AbstractDistributedFederation.getProxy(IAsynchronousIterator<E> src, IStreamSerializer<E> serializer, int capacity) Return a proxy object for an IAsynchronousIterator suiteable for use in an RMI environment.

Uses of IAsynchronousIterator in com.bigdata.service.jini

Methods in com.bigdata.service.jini that return IAsynchronousIterator

<E> IAsynchronousIterator<E>

JiniFederation.getProxy(IAsynchronousIterator<E> sourceIterator, IStreamSerializer<E> serializer, int capacity) Export and return a proxy object.

Methods in com.bigdata.service.jini with parameters of type IAsynchronousIterator

<E> IAsynchronousIterator<E>

JiniFederation.getProxy(IAsynchronousIterator<E> sourceIterator, IStreamSerializer<E> serializer, int capacity) Export and return a proxy object.

Uses of IAsynchronousIterator in com.bigdata.service.ndx.pipeline

Fields in com.bigdata.service.ndx.pipeline declared as IAsynchronousIterator

protected IAsynchronousIterator<E[]>	AbstractMasterTask.src The iterator draining the AbstractMasterTask.buffer.
protected IAsynchronousIterator<E[]>	AbstractSubtask.src The iterator draining the AbstractSubtask.buffer.

Uses of IAsynchronousIterator in com.bigdata.service.proxy

Classes in com.bigdata.service.proxy that implement IAsynchronousIterator

class

ClientAsynchronousIterator<E> Wraps an RemoteAsynchronousIterator so that it looks like an IAsynchronousIterator again.

Constructors in com.bigdata.service.proxy with parameters of type IAsynchronousIterator

RemoteAsynchronousIteratorImpl(IAsynchronousIterator<E> itr)
Ctor variant does not support RemoteAsynchronousIteratorImpl.nextElement().

RemoteAsynchronousIteratorImpl(IAsynchronousIterator<E> itr, IStreamSerializer<E> serializer)
Ctor variant optionally supports RemoteAsynchronousIteratorImpl.nextElement().

RemoteChunkedIterator(IAsynchronousIterator<E[]> sourceIterator, IStreamSerializer<E[]> serializer, IKeyOrder<E> keyOrder)