Bulk Operation

FLINK-11875 Change the endinput call of the downstream operator to after the upstream operator closes

FLINK-11875 Drop the non-selectable two-input StreamTask and Processor

FLINK-11875 Change the input selection switching in StreamTwoInputSelectableProcessor#checkFinished to invoking the nextSelection method of the stream operator

FLINK-11875 Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor

FLINK-11875 Make CheckpointBarrierHandler non-blocking

FLINK-11875 Introduce NetworkInput class

FLINK-11875 Replace listeners with CompletableFuture in InputGates

FLINK-11875 Add micro benchmarks for two-input processors

FLINK-11875 Add JobGraph validators for the uses of TwoInputSelectable, BoundedOneInput and BoundedTwoInput

FLINK-11875 Add JobGraph validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput

FLINK-11875 Implement the runtime handling of BoundedOneInput and BoundedMultiInput

FLINK-11875 Implement the runtime handling of the InputSelectable interface

FLINK-11875 Introduce the new interfaces InputSelectable, BoundedOneInput and BoundedMultiInput