[
https://issues.apache.org/jira/browse/FLINK-2160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14573128#comment-14573128
]
ASF GitHub Bot commented on FLINK-2160:
---------------------------------------
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/785
[FLINK-2160] Change Streaming Source Interface to run(Context)/cancel()
The context can be used to emit elemens and retrieve the checkpointing
lock object.
In the future, the context can be extended to provide support for
emission with timestamps and dealing with the watermark system.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink source-context
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/785.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #785
----
commit 80a7127e4da5567900fe9fe4942b54d71ad1068e
Author: Aljoscha Krettek <[email protected]>
Date: 2015-06-04T09:29:17Z
[FLINK-2160] Change Streaming Source Interface to run(Context)/cancel()
The context can be used to emit elemens and retrieve the checkpointing
lock object.
In the future, the context can be extended to provide support for
emission with timestamps and dealing with the watermark system.
----
> 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)
