com.bigdata.bop

Interface BufferAnnotations

All Known Subinterfaces:

AbstractAccessPathOp.Annotations, AbstractAddRemoveStatementsOp.Annotations, AbstractSubqueryOp.Annotations, AccessPathJoinAnnotations, ArbitraryLengthPathOp.Annotations, ChunkedMaterializationOp.Annotations, ChunkedResolutionOp.Annotations, CommitOp.Annotations, ConditionalRoutingOp.Annotations, CopyOp.Annotations, DataSetJoin.Annotations, DistinctTermScanOp.Annotations, DropOp.Annotations, FastRangeCountOp.Annotations, FederatedQueryEngine.Annotations, GroupByOp.Annotations, HashIndexOp.Annotations, HashIndexOpBase.Annotations, HashJoinOp.Annotations, HTreeDistinctBindingSetsOp.Annotations, HTreeHashJoinAnnotations, HTreeHashJoinOp.Annotations, HTreeMergeJoin.Annotations, HTreeNamedSubqueryOp.Annotations, InlineMaterializeOp.Annotations, InsertOp.Annotations, IPredicate.Annotations, IsInlineBOp.Annotations, JoinAnnotations, JoinGraph.Annotations, JVMDistinctBindingSetsOp.Annotations, JVMHashJoinAnnotations, JVMHashJoinOp.Annotations, JVMMergeJoin.Annotations, JVMNamedSubqueryOp.Annotations, MemoryGroupByOp.Annotations, MockTermResolverOp.Annotations, NestedLoopJoinOp.Annotations, ParseOp.Annotations, PipelinedAggregationOp.Annotations, PipelineDelayOp.Annotations, PipelinedHashIndexAndSolutionSetJoinOp.Annotations, PipelineJoin.Annotations, PipelineOp.Annotations, Predicate.Annotations, ProjectionOp.Annotations, QueryEngine.Annotations, ServiceCallJoin.Annotations, SliceOp.Annotations, SolutionSetHashJoinOp.Annotations, SortOp.Annotations, SPOPredicate.Annotations, SPOStarJoin.Annotations, SubqueryJoinAnnotations, SubqueryOp.Annotations, VariableUnificationOp.Annotations, ZeroLengthPathOp.Annotations

public interface BufferAnnotations

Annotations for BlockingBuffer as used by various kinds of operators.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHUNK_CAPACITY Sets the capacity of the IBindingSet[]s used to accumulate a chunk of IBindingSets (default 100).
static String	CHUNK_OF_CHUNKS_CAPACITY The maximum #of chunks that can be buffered before an the producer would block (default 5).
static String	CHUNK_TIMEOUT The timeout in milliseconds that the BlockingBuffer will wait for another chunk to combine with the current chunk before returning the current chunk (default 10).
static TimeUnit	chunkTimeoutUnit The TimeUnits in which the CHUNK_TIMEOUT is measured.
static int	DEFAULT_CHUNK_CAPACITY Default for CHUNK_CAPACITY
static int	DEFAULT_CHUNK_OF_CHUNKS_CAPACITY Default for CHUNK_OF_CHUNKS_CAPACITY
static int	DEFAULT_CHUNK_TIMEOUT The default for CHUNK_TIMEOUT.

Field Detail

CHUNK_OF_CHUNKS_CAPACITY

static final String CHUNK_OF_CHUNKS_CAPACITY

The maximum #of chunks that can be buffered before an the producer would block (default 5). Note that partial chunks may be combined into full chunks whose nominal capacity is specified by CHUNK_CAPACITY.

DEFAULT_CHUNK_OF_CHUNKS_CAPACITY

static final int DEFAULT_CHUNK_OF_CHUNKS_CAPACITY

Default for CHUNK_OF_CHUNKS_CAPACITY

See Also:

Constant Field Values

CHUNK_CAPACITY

static final String CHUNK_CAPACITY

Sets the capacity of the IBindingSet[]s used to accumulate a chunk of IBindingSets (default 100). Partial chunks may be automatically combined into full chunks.

See Also:

CHUNK_OF_CHUNKS_CAPACITY

DEFAULT_CHUNK_CAPACITY

static final int DEFAULT_CHUNK_CAPACITY

Default for CHUNK_CAPACITY

See Also:

Constant Field Values

CHUNK_TIMEOUT

static final String CHUNK_TIMEOUT

The timeout in milliseconds that the BlockingBuffer will wait for another chunk to combine with the current chunk before returning the current chunk (default 10). This may be ZERO (0) to disable the chunk combiner.

DEFAULT_CHUNK_TIMEOUT

static final int DEFAULT_CHUNK_TIMEOUT

The default for CHUNK_TIMEOUT.

See Also:

Constant Field Values

chunkTimeoutUnit

static final TimeUnit chunkTimeoutUnit

The TimeUnits in which the CHUNK_TIMEOUT is measured.