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)
