flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1977) Rework Stream Operators to always be push based
Date Wed, 06 May 2015 07:56:59 GMT
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

View raw message