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

Class BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin

java.lang.Object

BaseForExecOpBindJoinWithRequestOps<QueryType,MemberType>.MyIntermediateResultElementSink

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin

All Implemented Interfaces:

IntermediateResultElementSink

Enclosing class:

BaseForExecOpBindJoinWithRequestOps<QueryType extends Query,MemberType extends FederationMember>

protected class BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin
extends BaseForExecOpBindJoinWithRequestOps<QueryType,MemberType>.MyIntermediateResultElementSink

Field Summary

Fields

Modifier and Type	Field	Description
protected final Set<SolutionMapping>	inputSolutionMappingsWithJoinPartners

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

inputSolutionMappings, outputSink

Constructor Summary

Constructors

Constructor	Description
MyIntermediateResultElementSinkOuterJoin(IntermediateResultElementSink outputSink, Iterable<SolutionMapping> inputSolutionMappings)

Method Summary

Modifier and Type	Method	Description
void	_send(SolutionMapping smFromRequest)
void	flush()	Sends to the output sink all input solution mappings that did not have a join partner.

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

hasObtainedInputAlready, send

Methods inherited from class java.lang.Object

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

Field Details

inputSolutionMappingsWithJoinPartners

protected final Set<SolutionMapping> inputSolutionMappingsWithJoinPartners

Constructor Details

MyIntermediateResultElementSinkOuterJoin

public MyIntermediateResultElementSinkOuterJoin(IntermediateResultElementSink outputSink,
 Iterable<SolutionMapping> inputSolutionMappings)

Method Details

_send

public void _send(SolutionMapping smFromRequest)

Overrides:

_send in class BaseForExecOpBindJoinWithRequestOps<QueryType extends Query,MemberType extends FederationMember>.MyIntermediateResultElementSink

flush

public void flush()

Sends to the output sink all input solution mappings that did not have a join partner.

Overrides:

flush in class BaseForExecOpBindJoinWithRequestOps<QueryType extends Query,MemberType extends FederationMember>.MyIntermediateResultElementSink