Interface IntermediateResultElementSink

All Known Subinterfaces:

ClosableIntermediateResultElementSink

All Known Implementing Classes:

BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSink, BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin, BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSink, BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin, CollectingIntermediateResultElementSink, CollectingIntermediateResultElementSinkWithTranslation, ConnectorForAdditionalConsumer, PushBasedPlanThreadImplBase, PushBasedPlanThreadImplForBinaryOperator, PushBasedPlanThreadImplForNaryOperator, PushBasedPlanThreadImplForNullaryOperator, PushBasedPlanThreadImplForUnaryOperator, SynchronizedIntermediateResultElementSink

public interface IntermediateResultElementSink

Method Summary

Modifier and Type	Method	Description
default int	send(Iterable<SolutionMapping> it)	Consumes the given iterator, calling send(SolutionMapping) for every SolutionMapping obtained from the iterator, and returns the number of solution mappings obtained from the iterator.
default int	send(Iterator<SolutionMapping> it)	Consumes the given iterator, calling send(SolutionMapping) for every SolutionMapping obtained from the iterator, and returns the number of solution mappings obtained from the iterator.
void	send(SolutionMapping element)

Method Details

send

void send(SolutionMapping element)

send

default int send(Iterable<SolutionMapping> it)

Consumes the given iterator, calling send(SolutionMapping) for every SolutionMapping obtained from the iterator, and returns the number of solution mappings obtained from the iterator.

send

default int send(Iterator<SolutionMapping> it)

Consumes the given iterator, calling send(SolutionMapping) for every SolutionMapping obtained from the iterator, and returns the number of solution mappings obtained from the iterator.