Package se.liu.ida.hefquin.engine.queryplan.executable.impl.ops

Class ExecOpHashRJoin

java.lang.Object

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BinaryExecutableOpBase

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.ExecOpHashJoin

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.ExecOpHashRJoin

All Implemented Interfaces:

StatsProvider, BinaryExecutableOp, ExecutableOperator

public class ExecOpHashRJoin
extends ExecOpHashJoin

A right outer join version of the hash join algorithm implemented in ExecOpHashJoin. The only difference is that, when consuming the second input, for every solution mapping that does not have any join partners in the hash index (that was created when consuming the first input), the solution mapping is not simply discarded (as required by the inner join semantics implemented by the base algorithm) but it is sent to the output as is (to comply with the right join semantics).

Attention: if this algorithm is used to implement the OPTIONAL operator, the OPTIONAL part must be used as the first input.

Field Summary

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.ExecOpHashJoin

child1InputComplete, child2InputComplete, index, statsOfIndex

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BinaryExecutableOpBase

timeAtCurrentLeftProcStart, timeAtCurrentRightProcStart

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps

collectExceptions

Constructor Summary

Constructors

Constructor	Description
ExecOpHashRJoin(ExpectedVariables inputVars1, ExpectedVariables inputVars2, boolean collectExceptions)

Method Summary

Modifier and Type	Method	Description
protected void	_processSolMapFromChild2(SolutionMapping smR, IntermediateResultElementSink sink, ExecutionContext execCxt)

Methods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.ExecOpHashJoin

_processBlockFromChild1, _processBlockFromChild2, _wrapUpForChild1, _wrapUpForChild2, preferredInputBlockSizeFromChild1, preferredInputBlockSizeFromChild2, requiresCompleteChild1InputFirst

Methods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BinaryExecutableOpBase

createStats, getStats, processBlockFromChild1, processBlockFromChild2, resetStats, wrapUpForChild1, wrapUpForChild2

Methods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps

getExceptionsCaughtDuringExecution, recordExceptionCaughtDuringExecution

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface se.liu.ida.hefquin.engine.queryplan.executable.ExecutableOperator

getExceptionsCaughtDuringExecution

Constructor Details

ExecOpHashRJoin

public ExecOpHashRJoin(ExpectedVariables inputVars1,
 ExpectedVariables inputVars2,
 boolean collectExceptions)

Method Details

_processSolMapFromChild2

protected void _processSolMapFromChild2(SolutionMapping smR,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)

Overrides:

_processSolMapFromChild2 in class ExecOpHashJoin