GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4702
[FLINK-7635][DataStream API][Scala API] Support sideOutput in
ProcessWindowFunciton
## What is the purpose of the change
Add support for sideOutput in ProcessWindowFunciton
## Verifying this change
This change added tests and can be verified as follows:
- Added integration tests for DataStream API in
`flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SideOutputITCase.java`
- Added integration tests for Scala API in
`flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/SideOutputITCase.scala`
## Does this pull request potentially affect one of the following parts:
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (yes)
## Documentation
- Does this pull request introduce a new feature? (yes)
- If yes, how is the feature documented? (I will add document for this
feature and [FLINK-7660](https://issues.apache.org/jira/browse/FLINK-7660)
together when implementing FLINK-7660)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bowenli86/flink FLINK-7635
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4702.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 #4702
----
commit 6386983239bd3024b395c865ec4fd33e232ca5a3
Author: Bowen Li <[email protected]>
Date: 2017-08-30T16:35:03Z
FLINK-7422 Upgrade Kinesis Client Library (KCL) and AWS SDK in
flink-connector-kinesis
commit 381cd4156b84673a1d32d2db3f7b2d748d90d980
Author: Bowen Li <[email protected]>
Date: 2017-09-07T06:33:37Z
Merge remote-tracking branch 'upstream/master'
commit dcf40bd821187b848d924f7f4df6805b1b924c16
Author: Bowen Li <[email protected]>
Date: 2017-09-15T18:00:03Z
Merge remote-tracking branch 'upstream/master'
commit 169ea0a3bee1ba315d39fa49c16e9bd7c71d1338
Author: Bowen Li <[email protected]>
Date: 2017-09-18T06:25:26Z
Merge remote-tracking branch 'upstream/master'
commit 659e91c18ade8eb65d355b5b85ae2d402a61ff5e
Author: Bowen Li <[email protected]>
Date: 2017-09-18T23:50:48Z
Merge remote-tracking branch 'upstream/master'
commit 990c4648a1427ca7c3c27453fe2a40cd5cac3734
Author: Bowen Li <[email protected]>
Date: 2017-09-19T17:18:54Z
Merge remote-tracking branch 'upstream/master'
commit fb88d61579cbc602b21f96ffca5c189aa846bec1
Author: Bowen Li <[email protected]>
Date: 2017-09-20T05:56:14Z
Merge branch 'master' of github.com:bowenli86/flink
commit 3538421e6e8d194fe838f662480f44b57a41e5e2
Author: Bowen Li <[email protected]>
Date: 2017-09-20T06:35:34Z
add full path of WindowWordCount to doc to remove warning from IDE
commit e08f099465f495401efad1a4d8f54a19735df76c
Author: Bowen Li <[email protected]>
Date: 2017-09-20T18:08:06Z
format code and doc
commit 83fca0651f8d342aea83291bfe4d45bc8df646d2
Author: Bowen Li <[email protected]>
Date: 2017-09-21T19:13:17Z
update window doc
commit a90e18102e8f85d305cd5f2f077db202f471023b
Author: Bowen Li <[email protected]>
Date: 2017-09-22T00:56:03Z
FLINK-7635 Support sideOutput in ProcessWindowFunciton
commit 76e22afa3030db9dd555608168f7cf408696d1a7
Author: Bowen Li <[email protected]>
Date: 2017-09-22T01:07:02Z
add output to InternalProcessApplyWindowContext
commit 3da7ce9c439fb58c898f34acc87e11621df68947
Author: Bowen Li <[email protected]>
Date: 2017-09-22T01:57:03Z
add scala API
----
---
