[FLINK-16316] Provide new base class for StreamOperators

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.11.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Piotr Nowojski
• Reporter: Piotr Nowojski
• Created: 27/Feb/20 14:56
• Updated: 25/Mar/20 14:07
• Resolved: 25/Mar/20 14:07

Description

Current AbstractStreamOperator has at least couple of issues:

1. it's using deprecated SetupableStreamOperator interface, instead of relaying on StreamOperatorFactory.
2. 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

Issue Links

• links to: GitHub Pull Request #11403