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)