public class JVMDistinctBindingSetsOp extends PipelineOp
Note: This implementation is a pipelined operator which inspects each chunk
of solutions as they arrive and those solutions which are distinct for each
chunk are passed on. It uses a ConcurrentMap and is thread-safe. It
is significantly faster than the single-threaded hash index routines in the
JVMHashJoinUtility.
| Modifier and Type | Class and Description |
|---|---|
static interface |
JVMDistinctBindingSetsOp.Annotations |
DEFAULT_INITIAL_CAPACITY| Constructor and Description |
|---|
JVMDistinctBindingSetsOp(BOp[] args,
Map<String,Object> annotations)
Required shallow copy constructor.
|
JVMDistinctBindingSetsOp(BOp[] args,
NV... annotations) |
JVMDistinctBindingSetsOp(JVMDistinctBindingSetsOp 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 |
getConcurrencyLevel() |
int |
getInitialCapacity() |
float |
getLoadFactor() |
IVariable<?>[] |
getVariables() |
assertAtOnceJavaHeapOp, 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 JVMDistinctBindingSetsOp(JVMDistinctBindingSetsOp op)
com.bigdata.bop.BOpUtility#deepCopy(FilterNode).public JVMDistinctBindingSetsOp(BOp[] args, Map<String,Object> annotations)
public int getInitialCapacity()
HashMapAnnotations.INITIAL_CAPACITYpublic float getLoadFactor()
HashMapAnnotations.LOAD_FACTORpublic int getConcurrencyLevel()
public IVariable<?>[] getVariables()
DistinctAnnotations.VARIABLESpublic 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.