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

Packages that use IBuffer

com.bigdata.bop.engine
com.bigdata.bop.fed.shards
com.bigdata.bop.join
com.bigdata.rdf.load	Support for concurrent loading of RDF data across one or more clients from a variety of input sources.
com.bigdata.rdf.rio	This package provides an integration with the openrdf RIO parser that supports fast data loads.
com.bigdata.rdf.rules
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.proxy	This package provides implementations of proxy objects for commonly used classes.

Uses of IBuffer in com.bigdata.bop.engine

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

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 IBuffer in com.bigdata.bop.fed.shards

Classes in com.bigdata.bop.fed.shards that implement IBuffer

class

MapBindingSetsOverShardsBuffer<E extends IBindingSet,F> A stream of IBindingSet are mapped across the shards which will have the data for the IPredicate.asBound(IBindingSet) IPredicate.

Methods in com.bigdata.bop.fed.shards that return IBuffer

protected IBuffer<IBindingSet[]>	MapBindingSetsOverShardsBuffer.getBuffer(PartitionLocator locator) Return the buffer used to absorb binding sets which target the specified index partition.
protected abstract IBuffer<IBindingSet[]>	MapBindingSetsOverShardsBuffer.newBuffer(PartitionLocator locator) Return a buffer onto which binding sets will be written which are destined for the specified shard.

Methods in com.bigdata.bop.fed.shards that return types with arguments of type IBuffer

Map<PartitionLocator,IBuffer<IBindingSet[]>>

MapBindingSetsOverShardsBuffer.getSinks() An immutable view of the sinks.

Uses of IBuffer in com.bigdata.bop.join

Methods in com.bigdata.bop.join with parameters of type IBuffer

long	IHashJoinUtility.filterSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats, IBuffer<IBindingSet> sink) Filter solutions, writing only the DISTINCT solutions onto the sink.
long	JVMHashJoinUtility.filterSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats, IBuffer<IBindingSet> sink)
long	HTreeHashJoinUtility.filterSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats, IBuffer<IBindingSet> sink)
void	IHashJoinUtility.hashJoin(ICloseableIterator<IBindingSet> leftItr, IBuffer<IBindingSet> outputBuffer) Do a hash join between a stream of source solutions (left) and a hash index (right).
void	JVMHashJoinUtility.hashJoin(ICloseableIterator<IBindingSet> leftItr, IBuffer<IBindingSet> outputBuffer)
void	HTreeHashJoinUtility.hashJoin(ICloseableIterator<IBindingSet> leftItr, IBuffer<IBindingSet> outputBuffer)
void	IHashJoinUtility.hashJoin2(ICloseableIterator<IBindingSet> leftItr, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints) Variant hash join method allows the caller to impose different constraints or additional constraints.
void	JVMHashJoinUtility.hashJoin2(ICloseableIterator<IBindingSet> leftItr, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints) Variant hash join method allows the caller to impose different constraints or additional constraints.
void	HTreeHashJoinUtility.hashJoin2(ICloseableIterator<IBindingSet> leftItr, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints)
void	IHashJoinUtility.mergeJoin(IHashJoinUtility[] others, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints, boolean optional) Perform an N-way merge join.
void	JVMHashJoinUtility.mergeJoin(IHashJoinUtility[] others, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints, boolean optional)
void	HTreeHashJoinUtility.mergeJoin(IHashJoinUtility[] others, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints, boolean optional) Perform an N-way merge join.
void	IHashJoinUtility.outputJoinSet(IBuffer<IBindingSet> out) Output the solutions which joined.
void	JVMHashJoinUtility.outputJoinSet(IBuffer<IBindingSet> outputBuffer)
void	HTreeHashJoinUtility.outputJoinSet(IBuffer<IBindingSet> out)
void	IHashJoinUtility.outputOptionals(IBuffer<IBindingSet> outputBuffer) Identify and output the optional solutions.
void	JVMHashJoinUtility.outputOptionals(IBuffer<IBindingSet> outputBuffer)
void	HTreeHashJoinUtility.outputOptionals(IBuffer<IBindingSet> outputBuffer)
void	IHashJoinUtility.outputSolutions(IBuffer<IBindingSet> out) Output the solutions buffered in the hash index.
void	JVMHashJoinUtility.outputSolutions(IBuffer<IBindingSet> out)
void	HTreeHashJoinUtility.outputSolutions(IBuffer<IBindingSet> out)

Uses of IBuffer in com.bigdata.rdf.load

Classes in com.bigdata.rdf.load that implement IBuffer

class

VerifyStatementBuffer Statements inserted into the buffer are verified against the database.

Uses of IBuffer in com.bigdata.rdf.rio

Subinterfaces of IBuffer in com.bigdata.rdf.rio

interface

IStatementBuffer<F extends Statement> Abstraction for a buffer that loads Statements into an AbstractTripleStore.

Classes in com.bigdata.rdf.rio that implement IBuffer

class	AbstractStatementBuffer<F extends Statement,G extends BigdataStatement> Class for efficiently converting Statements into BigdataStatements, including resolving term identifiers (or adding entries to the lexicon for unknown terms) as required.
static class	AbstractStatementBuffer.StatementBuffer2<F extends Statement,G extends BigdataStatement> Loads Statements into an RDF database.
protected class	AsynchronousStatementBufferFactory.AsynchronousStatementBufferImpl Inner class provides the statement buffer.
class	StatementBuffer<S extends Statement> A write buffer for absorbing the output of the RIO parser or other Statement source and writing that output onto an AbstractTripleStore using the batch API.

Uses of IBuffer in com.bigdata.rdf.rules

Classes in com.bigdata.rdf.rules that implement IBuffer

static class

RDFJoinNexus.InsertSPOAndJustificationBuffer<E> Buffer writes on IMutableRelation#insert(IChunkedIterator) when it is flushed.

Methods in com.bigdata.rdf.rules that return IBuffer

IBuffer<ISolution[]>

RDFJoinNexus.newInsertBuffer(IMutableRelation relation) Overridden to handle justifications when using truth maintenance.

Constructors in com.bigdata.rdf.rules with parameters of type IBuffer

AbstractRuleDistinctTermScan.DistinctTermScan(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer, IVariable<IV> h, SPOKeyOrder keyOrder)

AbstractRuleFastClosure_3_5_6_7_9.FastClosureRuleTask(String database, String focusStore, IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer, IConstant<IV> rdfsSubPropertyOf, IConstant<IV> propertyId)
(?x, {P}, ?y) -> (?x, propertyId, ?y) Note: Both the database and the (optional) focusStore relation names MUST be declared for these rules.

Uses of IBuffer in com.bigdata.relation.accesspath

Classes in com.bigdata.relation.accesspath with type parameters of type IBuffer

class

ThreadLocalBufferFactory<T extends IBuffer<E>,E> A factory pattern for per-thread objects whose life cycle is tied to some container.

Subinterfaces of IBuffer in com.bigdata.relation.accesspath

interface	IBlockingBuffer<E> Interface provides an iterator to drain chunks from an IBuffer.
interface	IRunnableBuffer<E> An IBuffer that may be closed.

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

class	AbstractArrayBuffer<E> A thread-safe buffer backed by a fixed capacity array.
class	AbstractElementBuffer<R> Base class for IBuffer of IRelation elements whose target is a mutation (insert, delete, or update) of some IMutableRelation.
static class	AbstractElementBuffer.DeleteBuffer<R> Buffer writes on IMutableRelation.delete(IChunkedOrderedIterator) when it is flushed.
static class	AbstractElementBuffer.InsertBuffer<R> Buffer writes on IMutableRelation.insert(IChunkedOrderedIterator) when it is flushed.
class	AbstractUnsynchronizedArrayBuffer<E> An abstract implementation of an unsynchronized buffer backed by a fixed capacity array.
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.
class	UnsynchronizedArrayBuffer<E> An unsynchronized buffer backed by a fixed capacity array that migrates references onto the caller's buffer (which is normally thread-safe) using IBuffer#add(int).
class	UnsynchronizedUnboundedChunkBuffer<E> An unsynchronized buffer backed by a fixed capacity array that migrates references onto an internal Queue, which may be drained by an UnsynchronizedUnboundedChunkBuffer.iterator().
class	UnsyncLocalOutputBuffer<E extends IBindingSet> Wraps the base class to update the caller's BOpStats.

Constructors in com.bigdata.relation.accesspath with parameters of type IBuffer

FlushBufferTask(IBuffer<ISolution[]> buffer)

UnsynchronizedArrayBuffer(IBuffer<E[]> target, Class<? extends E> cls, int capacity)

UnsynchronizedArrayBuffer(IBuffer<E[]> target, int capacity, Class<? extends E> cls, IElementFilter<E> filter)

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

Classes in com.bigdata.relation.rule.eval that implement IBuffer

class	AbstractSolutionBuffer<R> Base class for IBuffer whose target is a mutation (insert, delete, or update) of some IMutableRelation.
static class	AbstractSolutionBuffer.DeleteSolutionBuffer<E> Buffer writes on IMutableRelation.delete(IChunkedOrderedIterator) when it is flushed.
static class	AbstractSolutionBuffer.InsertSolutionBuffer<E> Buffer writes on IMutableRelation#insert(IChunkedIterator) when it is flushed.

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

IBuffer<ISolution[]>	IJoinNexus.newDeleteBuffer(IMutableRelation relation) Return a thread-safe buffer onto which chunks of computed ISolutions will be written.
IBuffer<ISolution[]>	AbstractJoinNexus.newDeleteBuffer(IMutableRelation relation) Return a thread-safe buffer onto which chunks of computed ISolutions will be written.
IBuffer<ISolution[]>	IJoinNexus.newInsertBuffer(IMutableRelation relation) Return a thread-safe buffer onto which chunks of computed ISolutions will be written.
IBuffer<ISolution[]>	AbstractJoinNexus.newInsertBuffer(IMutableRelation relation) Return a thread-safe buffer onto which chunks of computed ISolutions will be written.
IBuffer<ISolution>	IJoinNexus.newUnsynchronizedBuffer(IBuffer<ISolution[]> targetBuffer, int chunkCapacity) Return a buffer suitable for a single-threaded writer that flushes onto the specified targetBuffer.
IBuffer<ISolution>	AbstractJoinNexus.newUnsynchronizedBuffer(IBuffer<ISolution[]> targetBuffer, int chunkCapacity)

Methods in com.bigdata.relation.rule.eval that return types with arguments of type IBuffer

protected Map<String,IBuffer<ISolution[]>>

AbstractStepTask.getMutationBuffers(IJoinNexus joinNexus, Map<String,IRelation> relations) Create the appropriate buffers to absorb writes by the rules in the program that target an IMutableRelation.

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

IStepTask	RunRuleAndFlushBufferTaskFactory.newTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer) Deprecated.
IStepTask	IRuleTaskFactory.newTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer) The object will be used to evaluate the rule for the IRule.
IStepTask	DefaultRuleTaskFactory.newTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer)
IBuffer<ISolution>	IJoinNexus.newUnsynchronizedBuffer(IBuffer<ISolution[]> targetBuffer, int chunkCapacity) Return a buffer suitable for a single-threaded writer that flushes onto the specified targetBuffer.
IBuffer<ISolution>	AbstractJoinNexus.newUnsynchronizedBuffer(IBuffer<ISolution[]> targetBuffer, int chunkCapacity)

Method parameters in com.bigdata.relation.rule.eval with type arguments of type IBuffer

protected void	MutationTask.flushBuffers(IJoinNexus joinNexus, Map<String,IBuffer<ISolution[]>> buffers) Flush the buffer(s) and aggregate the mutation count from each buffer.
protected long	MutationTask.getMutationCountFromBuffers(RuleStats totals, Map<String,IBuffer<ISolution[]>> buffers) This just reads off and aggregates the mutationCount from each buffer as reported by flush().
protected List<Callable<RuleStats>>	MutationTask.newMutationTasks(IStep step, IJoinNexus joinNexus, Map<String,IBuffer<ISolution[]>> buffers) Builds a set of tasks for the program.

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

RunRuleAndFlushBufferTask(IStepTask stepTask, IBuffer<ISolution[]> buffer)

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

Classes in com.bigdata.relation.rule.eval.pipeline with type parameters of type IBuffer

class

JoinTask.ThreadLocalFactory<T extends IBuffer<E>,E> A factory pattern for per-thread objects whose life cycle is tied to some container.

Fields in com.bigdata.relation.rule.eval.pipeline declared as IBuffer

protected IBuffer<ISolution[]>

JoinMasterTask.solutionBuffer From the ctor.

Methods in com.bigdata.relation.rule.eval.pipeline that return IBuffer

IBuffer<ISolution[]>	DistributedJoinMasterTask.getSolutionBuffer()
IBuffer<ISolution[]>	JoinMasterTask.getSolutionBuffer() Returns the buffer specified to the ctor (overridden for distributed joins).
protected abstract IBuffer<ISolution[]>	JoinTask.getSolutionBuffer() The buffer on which the last predicate in the evaluation order will write its ISolutions.
protected IBuffer<ISolution[]>	DistributedJoinTask.getSolutionBuffer()
IBuffer<ISolution[]>	IJoinMaster.getSolutionBuffer() A proxy for the buffer on which the last DistributedJoinTask must write its query solutions.
protected IBuffer<ISolution[]>	LocalJoinTask.getSolutionBuffer()

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

DistributedJoinMasterTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer)

JoinMasterTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> solutionBuffer)

LocalJoinMasterTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer)

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

Uses of IBuffer in com.bigdata.service

Methods in com.bigdata.service that return IBuffer

abstract <E> IBuffer<E>

AbstractDistributedFederation.getProxy(IBuffer<E> buffer) Return a proxy object for an IBuffer suitable for use in an RMI environment.

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

abstract <E> IBuffer<E>

AbstractDistributedFederation.getProxy(IBuffer<E> buffer) Return a proxy object for an IBuffer suitable for use in an RMI environment.

Uses of IBuffer in com.bigdata.service.jini

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

<E> IBuffer<E>

JiniFederation.getProxy(IBuffer<E> buffer) A proxy for an IBuffer 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 IBuffer

<E> IBuffer<E>

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

Uses of IBuffer in com.bigdata.service.proxy

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

class	ClientBuffer<E> Serializable class wraps a RemoteBuffer delegating methods through to the IBuffer on the remote service while masquerading IOExceptions so that we can implement the IBuffer API.
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 IBuffer

RemoteBufferImpl(IBuffer<E> buffer)