You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/04 11:47:38 UTC

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

    [ https://issues.apache.org/jira/browse/FLINK-2160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14572462#comment-14572462 ] 

Gyula Fora commented on FLINK-2160:
-----------------------------------

The context is accessible from the open method before run is called. Why do we need the context in the run?

> 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)