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

Packages that use IAsynchronousIterator

Package	Description
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.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

Modifier and Type	Method and Description
IAsynchronousIterator<IBindingSet[]>	MockRunningQuery.iterator()
IAsynchronousIterator<E>	OutputStatsBuffer.iterator()

Methods in com.bigdata.bop.engine with parameters of type IAsynchronousIterator

Modifier and Type	Method and Description
static void	AbstractQueryEngineTestCase.assertSameSolutions(IBindingSet[] expected, IAsynchronousIterator<IBindingSet[]> itr) Deprecated. by #assertSameSolutions(Future, IBindingSet[], IAsynchronousIterator)

Uses of IAsynchronousIterator in com.bigdata.relation.accesspath

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

Modifier and Type	Class and Description
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

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

Methods in com.bigdata.relation.accesspath with parameters of type IAsynchronousIterator

Modifier and Type	Method and Description
protected void	TestThickAsynchronousIterator.assertSameIterator(String[] expected, IAsynchronousIterator<String> actual)
protected void	TestThickAsynchronousIterator.doRoundTripTest(String[] expected, IAsynchronousIterator<String> itr)

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

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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Constructor and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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.ndx.pipeline

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

Modifier and Type	Field and Description
protected IAsynchronousIterator<E[]>	AbstractSubtask.src The iterator draining the AbstractSubtask.buffer.
protected IAsynchronousIterator<E[]>	AbstractMasterTask.src The iterator draining the AbstractMasterTask.buffer.

Uses of IAsynchronousIterator in com.bigdata.service.proxy

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

Modifier and Type	Class and Description
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

Constructor and Description
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)