com.bigdata.bop.join

Interface PipelinedHashJoinUtility

All Known Implementing Classes:

HTreePipelinedHashJoinUtility, JVMPipelinedHashJoinUtility

public interface PipelinedHashJoinUtility

Special interface for pipelines hash join implementations, offering a method that combines acceptance and outputting of solutions.

Version:

$Id$

Author:

Michael Schmidt

Method Summary

Methods

Modifier and Type

Method and Description

long

acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out, ICloseableIterator<IBindingSet[]> itr, NamedSolutionSetStats stats, IConstraint[] joinConstraints, PipelineOp subquery, IBindingSet[] bsFromBindingsSetSource, IVariable<?>[] projectInVars, IVariable<?> askVar, boolean isLastInvocation, int distinctProjectionBufferThreshold, int incomingBindingsBufferThreshold, BOpContext<IBindingSet> context) AcceptAndOutputSolutions is a special method for building the hash index of the JVMPipelinedHashIndex, which accepts and immediately forwards relevant solutions (non-blocking index).

Method Detail

acceptAndOutputSolutions

long acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out,
                            ICloseableIterator<IBindingSet[]> itr,
                            NamedSolutionSetStats stats,
                            IConstraint[] joinConstraints,
                            PipelineOp subquery,
                            IBindingSet[] bsFromBindingsSetSource,
                            IVariable<?>[] projectInVars,
                            IVariable<?> askVar,
                            boolean isLastInvocation,
                            int distinctProjectionBufferThreshold,
                            int incomingBindingsBufferThreshold,
                            BOpContext<IBindingSet> context)

AcceptAndOutputSolutions is a special method for building the hash index of the JVMPipelinedHashIndex, which accepts and immediately forwards relevant solutions (non-blocking index).