GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/659
[FLINK-1977] Rework Stream Operators to always be push based
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink event-time
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/659.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #659
----
commit 2e2abbd4afb6f058abb7b5d4a287349cdef5d8f6
Author: Aljoscha Krettek <[email protected]>
Date: 2015-05-04T13:53:36Z
[FLINK-1977] Rework Stream Operators to always be push based
commit 58843949102c0506b30c80cfb36065d303a64cda
Author: Aljoscha Krettek <[email protected]>
Date: 2015-05-06T16:11:52Z
Change StreamOperator to be an Interface
This introduces new AbstractOperator classes for UDF operators and
operators without UDFs.
commit 4e0fadd4c4069817362382dbe8c7287f3b0150ff
Author: Aljoscha Krettek <[email protected]>
Date: 2015-05-07T07:39:54Z
Change StreamOperator to take Output instead of Collector
Output is a richer Interface that extends Collector. Right now it does
not contain additional methods. But this will be extended to support
forwarding of Low Watermarks/Barriers.
commit f0d2c3bb47a63ed50f543732665a8b88872d839d
Author: Aljoscha Krettek <[email protected]>
Date: 2015-05-07T09:06:52Z
Simplify StreamTask and derived classes
commit a4be5138c6262e104d83263d6e4800e416d6fd4a
Author: Aljoscha Krettek <[email protected]>
Date: 2015-05-07T09:19:44Z
Remove unused imports
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
