Package org.apache.flink.streaming.api.operators

Interface BoundedMultiInput

All Known Implementing Classes:

AbstractExternalTwoInputPythonFunctionOperator, AbstractTwoInputEmbeddedPythonFunctionOperator, BatchCoBroadcastWithKeyedOperator, BatchCoBroadcastWithNonKeyedOperator, BatchMultipleInputStreamOperator, EmbeddedPythonBatchCoBroadcastProcessOperator, EmbeddedPythonBatchKeyedCoBroadcastProcessOperator, EmbeddedPythonCoProcessOperator, EmbeddedPythonKeyedCoProcessOperator, ExternalPythonBatchCoBroadcastProcessOperator, ExternalPythonBatchKeyedCoBroadcastProcessOperator, ExternalPythonCoProcessOperator, ExternalPythonKeyedCoProcessOperator, FinishedOperatorChain, FusionStreamOperatorBase, HashJoinOperator, KeyedTwoInputBroadcastProcessOperator, KeyedTwoInputNonBroadcastProcessOperator, OperatorChain, RegularOperatorChain, SortMergeJoinOperator, TwoInputBroadcastProcessOperator, TwoInputNonBroadcastProcessOperator, UnionStreamOperator

@PublicEvolving
public interface BoundedMultiInput

Interface for multi-input operators that need to be notified about the logical/semantical end of input.

NOTE: Classes should not implement both BoundedOneInput and BoundedMultiInput at the same time!

See Also:

BoundedOneInput

Method Summary

Modifier and Type	Method	Description
void	endInput(int inputId)	It is notified that no more data will arrive from the input identified by the inputId.

Method Detail

endInput

void endInput(int inputId)
       throws Exception

It is notified that no more data will arrive from the input identified by the inputId. The inputId is numbered starting from 1, and `1` indicates the first input.

WARNING: It is not safe to use this method to commit any transactions or other side effects! You can use this method to e.g. flush data buffered for the given input or implement an ordered reading from multiple inputs via InputSelectable.

Throws:

Exception