[jira] [Created] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel()

[Shang Yuanchun (Jira)]

Aljoscha Krettek created FLINK-2160:
---------------------------------------

             Summary: Change Streaming Source Interface to run(Context)/cancel()
                 Key: FLINK-2160
                 URL: https://issues.apache.org/jira/browse/FLINK-2160
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
            Reporter: Aljoscha Krettek
            Assignee: Aljoscha Krettek


This will make the source interface more extensible in the future without breaking existing sources (after the change). Right now, the context would have methods for element emission and for retrieving the checkpoint lock for checkpointed sources. In the future this can be extended to allow emission of elements with timestamp and for dealing with watermark emission.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)