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

Packages that use IRunnableBuffer

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.service.jini
com.bigdata.service.jini.benchmark
com.bigdata.service.jini.master
com.bigdata.service.ndx
com.bigdata.service.proxy	This package provides implementations of proxy objects for commonly used classes.

Uses of IRunnableBuffer in com.bigdata.bop.engine

Classes in com.bigdata.bop.engine that implement IRunnableBuffer

class	BlockingBufferWithStats<E> Extended to use the BufferAnnotations to provision the BlockingBuffer and to track the BOpStats as chunks are added to the buffer.
class	OutputStatsBuffer<E> Delegation pattern handles the SinkTransitionMetadata.

Uses of IRunnableBuffer in com.bigdata.relation.accesspath

Subinterfaces of IRunnableBuffer in com.bigdata.relation.accesspath

interface

IBlockingBuffer<E> Interface provides an iterator to drain chunks from an IBuffer.

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

class	BlockingBuffer<E> A buffer that will block when it is full.
class	DelegateBuffer<E> A delegation pattern which does not pass on the DelegateBuffer.close() method.

Uses of IRunnableBuffer in com.bigdata.service.jini

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

<E,V> IRunnableBuffer<E>

JiniFederation.getProxy(IRunnableBuffer<E> buffer) A proxy for an IRunnableBuffer that does not extend Remote and which DOES NOT declare that its methods throw IOException (for RMI).

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

<E,V> IRunnableBuffer<E>

JiniFederation.getProxy(IRunnableBuffer<E> buffer) A proxy for an IRunnableBuffer that does not extend Remote and which DOES NOT declare that its methods throw IOException (for RMI).

Uses of IRunnableBuffer in com.bigdata.service.jini.benchmark

Constructors in com.bigdata.service.jini.benchmark with parameters of type IRunnableBuffer

ThroughputMaster.Task(IScaleOutClientIndex ndx, IRunnableBuffer<KVO<Void>[]> insert, IRunnableBuffer<KVO<Void>[]> remove, Random r, int nops, long firstKey, int incRange, double insertRate)

ThroughputMaster.Task(IScaleOutClientIndex ndx, IRunnableBuffer<KVO<Void>[]> insert, IRunnableBuffer<KVO<Void>[]> remove, Random r, int nops, long firstKey, int incRange, double insertRate)

Uses of IRunnableBuffer in com.bigdata.service.jini.master

Methods in com.bigdata.service.jini.master that return IRunnableBuffer

<T extends IKeyArrayIndexProcedure,O,R,A> IRunnableBuffer<KVO<O>[]>

AggregatorTask.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor) Note: This ignores its arguments (it uses those specified to the ctor instead) and returns the proxy for the pre-existing write buffer.

Uses of IRunnableBuffer in com.bigdata.service.ndx

Methods in com.bigdata.service.ndx that return IRunnableBuffer

<T extends IKeyArrayIndexProcedure,O,R,A> IRunnableBuffer<KVO<O>[]>	ClientIndexView.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor)
<T extends IKeyArrayIndexProcedure,O,R,A> IRunnableBuffer<KVO<O>[]>	IAsynchronousWriteBufferFactory.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor) Asynchronous write API (streaming writes).

Uses of IRunnableBuffer in com.bigdata.service.proxy

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

class

ClientRunnableBuffer<E,V> Serializable class wraps a RemoteRunnableBuffer delegating methods through to the IRunnableBuffer on the remote service while masquerading IOExceptions so that we can implement the IRunnableBuffer API.

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

RemoteRunnableBufferImpl(IRunnableBuffer<E> localBuffer, Future<V> futureProxy)