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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	_send(SolutionMapping smFromRequest)
void	flush()
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

Field Details

outputSink

protected final IntermediateResultElementSink outputSink

inputSolutionMappings

protected final Iterable<SolutionMapping> inputSolutionMappings

Constructor Details

MyIntermediateResultElementSink

public MyIntermediateResultElementSink(IntermediateResultElementSink outputSink,
 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()