flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel()
Date Thu, 04 Jun 2015 10:01:37 GMT

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

Aljoscha Krettek commented on FLINK-2160:

No problemo :)

> 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

View raw message