zhijiang created FLINK-13765:
--------------------------------
Summary: Introduce the InputSelectionHandler for selecting next
input in StreamTwoInputSelectableProcessor
Key: FLINK-13765
URL: https://issues.apache.org/jira/browse/FLINK-13765
Project: Flink
Issue Type: Sub-task
Components: Runtime / Task
Reporter: zhijiang
Assignee: zhijiang
In StreamTwoInputSelectableProcessor there are three fields \{InputSelectable,
InputSelection, availableInputsMask} to be used together for the function of
selecting next available input index. It would bring two problems:
* From design aspect, these fields should be abstracted into a separate
component and passed into StreamTwoInputSelectableProcessor.
* inputSelector.nextSelection() is called while processing elements in
StreamTwoInputSelectableProcessor, so it is the blocker for integrating task
input/output for both StreamOneInputProcessor/StreamTwoInputSelectableProcessor
later.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
