[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14532830#comment-14532830 ]
ASF GitHub Bot commented on FLINK-1977: --------------------------------------- Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/659#issuecomment-99901700 By the way, how should we deal with Sources that might not have new data at the moment but still might emit new data in the future. The interface of reachedEnd() next() is not sufficient for this because the calls would become blocking. And then the Task cannot suspend execution at will anymore. > Rework Stream Operators to always be push based > ----------------------------------------------- > > Key: FLINK-1977 > URL: https://issues.apache.org/jira/browse/FLINK-1977 > Project: Flink > Issue Type: Improvement > Reporter: Aljoscha Krettek > Assignee: Aljoscha Krettek > > This is a result of the discussion on the mailing list. This is an excerpt > from the mailing list that gives the basic idea of the change: > I propose to change all streaming operators to be push based, with a > slightly improved interface: In addition to collect(), which I would > call receiveElement() I would add receivePunctuation() and > receiveBarrier(). The first operator in the chain would also get data > from the outside invokable that reads from the input iterator and > calls receiveElement() for the first operator in a chain. -- This message was sent by Atlassian JIRA (v6.3.4#6332)