Github user wangyangjun commented on the pull request:
https://github.com/apache/flink/pull/1527#issuecomment-199043205
Hi StephanEwen, sorry for replying this late.
This will join two window streams as long as slide size of these two
windows are equal. It can be two
Github user wangyangjun commented on the pull request:
https://github.com/apache/flink/pull/1527#issuecomment-177007794
Hello @aljoscha ,
As I mentioned in last comment, I will reimplement it with [Guava
CacheBuilder](http://docs.guava-libraries.googlecode.com/git/javadoc/com
Github user wangyangjun commented on the pull request:
https://github.com/apache/flink/pull/1527#issuecomment-176912402
Hello, @aljoscha ,
Thanks for your comment and suggestion. I will update the API. During my
benchmark tests of timeJoin, the feature of this implementation is
Github user wangyangjun commented on a diff in the pull request:
https://github.com/apache/flink/pull/1527#discussion_r50318604
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CoGroupJoinITCase.java
---
@@ -234,6 +234,109
Github user wangyangjun commented on a diff in the pull request:
https://github.com/apache/flink/pull/1527#discussion_r50318034
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamJoinOperator.java
---
@@ -0,0 +1,305
Github user wangyangjun commented on a diff in the pull request:
https://github.com/apache/flink/pull/1527#discussion_r50318008
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CoGroupJoinITCase.java
---
@@ -234,6 +234,109
GitHub user wangyangjun opened a pull request:
https://github.com/apache/flink/pull/1527
[FLINK-3109]Join two streams with two different buffer time -- Java iâ¦
Java implementation of jira
[FLINK-3109](https://issues.apache.org/jira/browse/FLINK-3109)
You can merge this pull
