[jira] [Created] (FLINK-12587) Add pure-API Watermark class

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12587) Add pure-API Watermark class

Shang Yuanchun (Jira)
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)