Class BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSink

java.lang.Object

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

All Implemented Interfaces:

IntermediateResultElementSink

Direct Known Subclasses:

BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin

Enclosing class:

BaseForExecOpBindJoinWithRequestOps<QueryType extends Query,MemberType extends FederationMember>

protected class BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSink
extends Object
implements IntermediateResultElementSink

Field Summary

Fields

Modifier and Type	Field	Description
protected final Iterable<SolutionMapping>	inputSolutionMappings
protected final List<SolutionMapping>	solMapsForOutput

Constructor Summary

Constructors

Constructor	Description
MyIntermediateResultElementSink(Iterable<SolutionMapping> inputSolutionMappings)

Method Summary

Modifier and Type	Method	Description
protected void	_send(SolutionMapping smFromRequest)
void	flush()
List<SolutionMapping>	getSolMapsForOutput()
final boolean	hasObtainedInputAlready()
final void	send(SolutionMapping smFromRequest)

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.IntermediateResultElementSink

send, send

Field Details

inputSolutionMappings

protected final Iterable<SolutionMapping> inputSolutionMappings

solMapsForOutput

protected final List<SolutionMapping> solMapsForOutput

Constructor Details

MyIntermediateResultElementSink

public MyIntermediateResultElementSink(Iterable<SolutionMapping> inputSolutionMappings)

Method Details

send

public final void send(SolutionMapping smFromRequest)

Specified by:

send in interface IntermediateResultElementSink

_send

protected void _send(SolutionMapping smFromRequest)

flush

public void flush()

hasObtainedInputAlready

public final boolean hasObtainedInputAlready()

getSolMapsForOutput

public List<SolutionMapping> getSolMapsForOutput()