[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890140#comment-15890140
]
ASF GitHub Bot commented on FLINK-4460:
---------------------------------------
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 <aljoscha.kret...@gmail.com>
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 <aljoscha.kret...@gmail.com>
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 <aljoscha.kret...@gmail.com>
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 <aljoscha.kret...@gmail.com>
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.
----
> Side Outputs in Flink
> ---------------------
>
> Key: FLINK-4460
> URL: https://issues.apache.org/jira/browse/FLINK-4460
> Project: Flink
> Issue Type: New Feature
> Components: Core, DataStream API
> Affects Versions: 1.2.0, 1.1.3
> Reporter: Chen Qin
> Assignee: Chen Qin
> Labels: latearrivingevents, sideoutput
>
> https://docs.google.com/document/d/1vg1gpR8JL4dM07Yu4NyerQhhVvBlde5qdqnuJv4LcV4/edit?usp=sharing
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
