com.bigdata.bop.solutions

Interface GroupByOp.Annotations

All Superinterfaces:

BOp.Annotations, BufferAnnotations, PipelineOp.Annotations

All Known Subinterfaces:

MemoryGroupByOp.Annotations, PipelinedAggregationOp.Annotations

Enclosing class:

GroupByOp

public static interface GroupByOp.Annotations
extends PipelineOp.Annotations

Field Summary

Fields

Modifier and Type	Field and Description
static String	GROUP_BY_REWRITE This required annotation provides the IGroupByRewriteState, which is a rewrite of the GroupByState that allows for certain optimizations.
static String	GROUP_BY_STATE This required annotation describes the IGroupByState for the aggregation operator, including the SELECT value expressions to be projected, the optional GROUP BY value expressions, and the optional HAVING value expressions.

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

Field Detail

GROUP_BY_STATE

static final String GROUP_BY_STATE

This required annotation describes the IGroupByState for the aggregation operator, including the SELECT value expressions to be projected, the optional GROUP BY value expressions, and the optional HAVING value expressions.

See Also:

IGroupByState

GROUP_BY_REWRITE

static final String GROUP_BY_REWRITE

This required annotation provides the IGroupByRewriteState, which is a rewrite of the GroupByState that allows for certain optimizations. This data is a required annotation because the rewrite includes anonymous variables and the identity of those anonymous variables MUST be stable across each invocation of the operator. This requirement exists both for pipelined aggregation operators running on a single node and for distributed aggregation operators running on a cluster.

See Also:

IGroupByRewriteState