|
apache
/
flink
|
|
master
|
3 hrs, 10 mins, 52 secs
|
Zhijiang
|
|
[FLINK-13765][task] Introduce the TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor
In StreamTwoInputSelectableProcessor there are three fields {InputSelectable, InputSelection, availableInputsMask} to be used together for the function of selecting next available input index.
From design aspect, these fields can be abstracted into a separate component called TwoInputSelectionHandler, which is passed into the constructor of StreamTwoInputSelectableProcessor as a final field. So the internal implementation details of TwoInputSelectionHandler is hidden from processor view which only needs to interact with exposed methods from selection handler.
Another tiny benefit is that we make the StreamTwoInputSelectableProcessor a bit because two methods are removed from it.
|
|