[ https://issues.apache.org/jira/browse/FLINK-16316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-16316: ----------------------------------- Labels: pull-request-available (was: ) > Provide new base class for StreamOperators > ------------------------------------------ > > Key: FLINK-16316 > URL: https://issues.apache.org/jira/browse/FLINK-16316 > Project: Flink > Issue Type: Sub-task > Components: API / DataStream > Affects Versions: 1.10.0 > Reporter: Piotr Nowojski > Assignee: Piotr Nowojski > Priority: Major > Labels: pull-request-available > Fix For: 1.11.0 > > > Current {{AbstractStreamOperator}} has at least couple of issues: > # it's using deprecated {{SetupableStreamOperator}} interface, instead of > relaying on {{StreamOperatorFactory}}. > # it depends on {{OneInputStreamOperator}} and {{TwoInputStreamOperator}} > interfaces, by providing indirectly implementation of methods like > {{processLatencyMarker}}, {{processLatencyMarker1}} and > {{processLatencyMarker2}} > Both of those things makes {{AbstractStreamOperator}} an unsuitable base > implementation for {{MultipleInputStreamOperator}}. We should provide a new > base class (or hierarchy of base classes), without those two limitations. > CC [~aljoscha] -- This message was sent by Atlassian Jira (v8.3.4#803005)