public class MemoryGroupByOp extends GroupByOp
| Modifier and Type | Class and Description |
|---|---|
static interface |
MemoryGroupByOp.Annotations |
DEFAULT_INITIAL_CAPACITY| Constructor and Description |
|---|
MemoryGroupByOp(BOp[] args,
Map<String,Object> annotations)
Required shallow copy constructor.
|
MemoryGroupByOp(MemoryGroupByOp op)
Constructor required for
com.bigdata.bop.BOpUtility#deepCopy(FilterNode). |
| Modifier and Type | Method and Description |
|---|---|
FutureTask<Void> |
eval(BOpContext<IBindingSet> context)
Return a
FutureTask which computes the operator against the
evaluation context. |
int |
getInitialCapacity() |
float |
getLoadFactor() |
boolean |
isPipelinedAggregationOp()
Return
true iff this operator supports pipelined aggregation |
getGroupByRewrite, getGroupByStateassertAtOnceJavaHeapOp, assertMaxParallelOne, getChunkCapacity, getChunkOfChunksCapacity, getChunkTimeout, getMaxMemory, getMaxParallel, isAtOnceEvaluation, isBlockedEvaluation, isLastPassRequested, isPipelinedEvaluation, isReorderSolutions, isSharedState, newStats__replaceArg, _clearProperty, _set, _setProperty, annotations, annotationsCopy, annotationsEqual, annotationsRef, argIterator, args, argsCopy, arity, clearAnnotations, clearProperty, deepCopy, deepCopy, get, getProperty, setArg, setProperty, setUnboundProperty, toArray, toArrayannotationsEqual, annotationsToString, annotationsToString, annotationValueToString, checkArgs, clone, equals, getEvaluationContext, getId, getProperty, getRequiredProperty, hashCode, indent, isController, mutation, shortenName, toShortString, toString, toStringpublic MemoryGroupByOp(MemoryGroupByOp op)
com.bigdata.bop.BOpUtility#deepCopy(FilterNode).public final boolean isPipelinedAggregationOp()
true iff this operator supports pipelined aggregation
Note: Pipelined aggregation is only possible when (a) DISTINCT is not
used in the IAggregates; and (b) IAggregates are not
nested within other IAggregates. An implementation which returns
true for this method MUST NOT be used for aggregation
operations which would violate either of these constraints.
Returns false. This is a generalized aggregation operator
and may be used to evaluate any aggregation request.
isPipelinedAggregationOp in class GroupByOppublic int getInitialCapacity()
HashMapAnnotations.INITIAL_CAPACITYpublic float getLoadFactor()
HashMapAnnotations.LOAD_FACTORpublic FutureTask<Void> eval(BOpContext<IBindingSet> context)
PipelineOpFutureTask which computes the operator against the
evaluation context. The caller is responsible for executing the
FutureTask (this gives them the ability to hook the completion of
the computation).eval in class PipelineOpcontext - The evaluation context.FutureTask which will compute the operator's
evaluation.Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.