com.bigdata.bop.join

Interface PipelinedHashIndexAndSolutionSetJoinOp.Annotations

All Superinterfaces:

BOp.Annotations, BufferAnnotations, HashIndexOp.Annotations, HashIndexOpBase.Annotations, HashJoinAnnotations, ILocatableResourceAnnotations, ITimestampAnnotations, JoinAnnotations, NamedSetAnnotations, PipelineOp.Annotations, SubqueryAnnotations

Enclosing class:

PipelinedHashIndexAndSolutionSetJoinOp

public static interface PipelinedHashIndexAndSolutionSetJoinOp.Annotations
extends HashIndexOp.Annotations, SubqueryAnnotations

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_DISTINCT_PROJECTION_BUFFER_THRESHOLD
static int	DEFAULT_INCOMING_BINDINGS_BUFFER_THRESHOLD
static String	DISTINCT_PROJECTION_BUFFER_THRESHOLD The threshold defining when to release the distinctProjectionBuffer.
static String	INCOMING_BINDINGS_BUFFER_THRESHOLD The threshold defining when to release the incomingBindingsBuffer.
static String	PROJECT_IN_VARS The variables that is projected into the inner subgroup.

Fields inherited from interface com.bigdata.bop.join.HashIndexOpBase.Annotations

BINDING_SETS_SOURCE, HASH_JOIN_UTILITY_FACTORY, NAMED_SET_SOURCE_REF

Fields inherited from interface com.bigdata.bop.join.HashJoinAnnotations

ASK_VAR, DEFAULT_NO_JOIN_VARS_LIMIT, JOIN_VARS, OUTPUT_DISTINCT_JVs

Fields inherited from interface com.bigdata.bop.join.JoinAnnotations

CONSTRAINTS, DEFAULT_LIMIT, JOIN_TYPE, LIMIT, SELECT

Fields inherited from interface com.bigdata.bop.PipelineOp.Annotations

ALT_SINK_REF, DEFAULT_LAST_PASS, DEFAULT_MAX_MEMORY, DEFAULT_MAX_MESSAGES_PER_TASK, DEFAULT_MAX_PARALLEL, DEFAULT_PIPELINE_QUEUE_CAPACITY, DEFAULT_PIPELINED, DEFAULT_REORDER_SOLUTIONS, DEFAULT_SHARED_STATE, LAST_PASS, MAX_MEMORY, MAX_MESSAGES_PER_TASK, MAX_PARALLEL, PIPELINE_QUEUE_CAPACITY, PIPELINED, REORDER_SOLUTIONS, SHARED_STATE, SINK_REF

Fields inherited from interface com.bigdata.bop.BOp.Annotations

BOP_ID, CONTROLLER, DEFAULT_CONTROLLER, DEFAULT_EVALUATION_CONTEXT, DEFAULT_TIMEOUT, EVALUATION_CONTEXT, NAMESPACE, TIMEOUT

Fields inherited from interface com.bigdata.bop.BufferAnnotations

CHUNK_CAPACITY, CHUNK_OF_CHUNKS_CAPACITY, CHUNK_TIMEOUT, chunkTimeoutUnit, DEFAULT_CHUNK_CAPACITY, DEFAULT_CHUNK_OF_CHUNKS_CAPACITY, DEFAULT_CHUNK_TIMEOUT

Fields inherited from interface com.bigdata.bop.controller.NamedSetAnnotations

NAMED_SET_REF

Fields inherited from interface com.bigdata.bop.ILocatableResourceAnnotations

RELATION_NAME

Fields inherited from interface com.bigdata.bop.ITimestampAnnotations

TIMESTAMP

Fields inherited from interface com.bigdata.bop.controller.SubqueryAnnotations

SUBQUERY

Field Detail

PROJECT_IN_VARS

static final String PROJECT_IN_VARS

The variables that is projected into the inner subgroup. Typically, this is identical to the join variables. There are, however, exceptions where we need to project in a superset. For instance, for the query select * where { ?a :knows ?b . OPTIONAL { ?b :knows ?c . ?c :knows ?d . filter(?a != :paul) # Note: filter applies to *outer* variable } } we have joinVars={?b} and projectInVars={?a, ?b}, because variables from outside are visible in the inner filter.

DISTINCT_PROJECTION_BUFFER_THRESHOLD

static final String DISTINCT_PROJECTION_BUFFER_THRESHOLD

The threshold defining when to release the distinctProjectionBuffer. Note that releasing this buffer means releasing the distinctProjectionBuffer at the same time.

DEFAULT_DISTINCT_PROJECTION_BUFFER_THRESHOLD

static final int DEFAULT_DISTINCT_PROJECTION_BUFFER_THRESHOLD

See Also:

Constant Field Values

INCOMING_BINDINGS_BUFFER_THRESHOLD

static final String INCOMING_BINDINGS_BUFFER_THRESHOLD

The threshold defining when to release the incomingBindingsBuffer. Note that releasing this buffer means releasing the distinctProjectionBuffer at the same time.

DEFAULT_INCOMING_BINDINGS_BUFFER_THRESHOLD

static final int DEFAULT_INCOMING_BINDINGS_BUFFER_THRESHOLD

See Also:

Constant Field Values