[jira] [Created] (FLINK-1763) Remove "cancel" from streaming SinkFunction

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1763) Remove "cancel" from streaming SinkFunction

Shang Yuanchun (Jira)
Stephan Ewen created FLINK-1763:
-----------------------------------

             Summary: Remove "cancel" from streaming SinkFunction
                 Key: FLINK-1763
                 URL: https://issues.apache.org/jira/browse/FLINK-1763
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
    Affects Versions: 0.9
            Reporter: Stephan Ewen
             Fix For: 0.9


Since the streaming sink function is called individually for each record, it does not require a {{cancel()}} function. The system can cancel between calls to that function (which it cannot do for the source function).

Removing this method removes the need to always implement the unnecessary, and usually empty, method.



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