[jira] [Created] (FLINK-1977) Rework Stream Operators to always be push based

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

Aljoscha Krettek created FLINK-1977:
---------------------------------------

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