Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5342#discussion_r163506497
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperatorTest.java
---
@@ -0,0 +1,590 @@
+/*
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5342#discussion_r163500703
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,328 @@
+/*
+ *
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5342#discussion_r163499894
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,328 @@
+/*
+ *
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5342#discussion_r163500913
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,328 @@
+/*
+ *
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5342#discussion_r163500884
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,328 @@
+/*
+ *
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5342#discussion_r163506043
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,328 @@
+/*
+ *
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5342#discussion_r163499952
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,328 @@
+/*
+ *
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5342#discussion_r163500641
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,328 @@
+/*
+ *
GitHub user florianschmidt1994 opened a pull request:
https://github.com/apache/flink/pull/5342
[FLINK-8470] Timebounded stream join
## What is the purpose of the change
Add a time-bounded inner join implementation of two streams as a
TwoInputStreamOperator, as discussed in
