apache

/

flink

branch iconmaster

arrow to build time
clock icon3 hrs, 10 mins, 52 secs

Zhijiang avatarZhijiang

[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.

Reply via email to