Aljoscha Krettek created FLINK-12587:
----------------------------------------
Summary: Add pure-API Watermark class
Key: FLINK-12587
URL:
https://issues.apache.org/jira/browse/FLINK-12587 Project: Flink
Issue Type: Improvement
Components: API / DataStream
Reporter: Aljoscha Krettek
Assignee: Aljoscha Krettek
Currently, {{Watermark}} extends {{StreamElement}}, which comes with a lot of transitive dependencies to classes and modules that are runtime code and shouldn't be in an API package. In the future, we want to more clearly separate API packages from runtime packages. The first instance of this is trying to put {{TableSources}} into {{flink-table-common}}, which will require our source-like interfaces to be clean of runtime dependencies. This means that we have to put {{SourceFunction}} into {{flink-core}}, which has {{Watermark}} in its interface, which we therefore have to untangle from runtime classes.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)