[ https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhijiang updated FLINK-13765: ----------------------------- Summary: Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor (was: Introduce the TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor) > Introduce TwoInputSelectionHandler for selecting 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 > Priority: Minor > Labels: pull-request-available > Time Spent: 10m > Remaining Estimate: 0h > > 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 (v8.3.2#803003)