GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3438
[FLINK-4460] Allow ProcessFunction on non-keyed streams
This is in preparation for side outputs, which will only work on
`ProcessFunction`. We still want side outputs on non-keyed streams so we have
to make `ProcessFunction` available there.
See this ML thread for reference:
https://lists.apache.org/thread.html/f3fe7d68986877994ad6b66173f40e72fc454420720a74ea5a834cc2@%3Cdev.flink.apache.org%3E
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink jira-4460-process-for-everyone
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3438.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 #3438
----
commit 38f33f2399598b521a7e34e8dea1d236f5672042
Author: Aljoscha Krettek <[email protected]>
Date: 2017-03-01T09:57:12Z
[FLINK-4460] Make ProcessFunction abstract, add default onTime() method
This is in preparation of allowing ProcessFunction on DataStream because
we will use it to allow side outputs from the ProcessFunction Context.
commit f0dd2c0d81a847cfa4f3d241ce874db6807caee2
Author: Aljoscha Krettek <[email protected]>
Date: 2017-03-01T10:41:02Z
[FLINK-4660] Allow ProcessFunction on DataStream
Introduce new ProcessOperator for this. Rename the pre-existing
ProcessOperator to KeyedProcessOperator.
commit 29ca9b4b794522b35d84d9f19edc5b0bb9f64912
Author: Aljoscha Krettek <[email protected]>
Date: 2017-03-01T10:33:03Z
[FLINK-4460] Make CoProcessFunction abstract, add default onTime() method
This is in preparation of allowing CoProcessFunction on a non-keyed
connected stream. we will use it to allow side outputs from the
ProcessFunction Context.
commit a26accf8feebaf9d3566055c0d1eb3006986bfd6
Author: Aljoscha Krettek <[email protected]>
Date: 2017-03-01T11:02:34Z
[FLINK-4660] Allow CoProcessFunction on non-keyed ConnectedStreams
Introduce new CoProcessOperator for this. Rename the pre-existing
CoProcessOperator to KeyedCoProcessOperator.
----
---
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.
---
