Repository: kafka
Updated Branches:
  refs/heads/trunk 732fabf94 -> 27e3edc79


MINOR: Fix comments in KStreamKStreamJoinTest

Minor comment fixes.

Author: Elias Levy <fearsome.lucid...@gmail.com>

Reviewers: Guozhang Wang

Closes #1885 from eliaslevy/fix-test-comments


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/27e3edc7
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/27e3edc7
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/27e3edc7

Branch: refs/heads/trunk
Commit: 27e3edc791760dea7ff4d048f87d1585f9e235d7
Parents: 732fabf
Author: Elias Levy <fearsome.lucid...@gmail.com>
Authored: Thu Sep 22 10:33:23 2016 -0700
Committer: Guozhang Wang <wangg...@gmail.com>
Committed: Thu Sep 22 10:33:23 2016 -0700

----------------------------------------------------------------------
 .../internals/KStreamKStreamJoinTest.java       | 40 ++++++++++----------
 1 file changed, 20 insertions(+), 20 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/27e3edc7/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
----------------------------------------------------------------------
diff --git 
a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
index b504b8a..f03a201 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
@@ -93,7 +93,7 @@ public class KStreamKStreamJoinTest {
         // push two items to the primary stream. the other window is empty
         // w1 = {}
         // w2 = {}
-        // --> w1 = { 0:X1, 1:X1 }
+        // --> w1 = { 0:X0, 1:X1 }
         //     w2 = {}
 
         for (int i = 0; i < 2; i++) {
@@ -105,7 +105,7 @@ public class KStreamKStreamJoinTest {
         // push two items to the other stream. this should produce two items.
         // w1 = { 0:X0, 1:X1 }
         // w2 = {}
-        // --> w1 = { 0:X1, 1:X1 }
+        // --> w1 = { 0:X0, 1:X1 }
         //     w2 = { 0:Y0, 1:Y1 }
 
         for (int i = 0; i < 2; i++) {
@@ -117,7 +117,7 @@ public class KStreamKStreamJoinTest {
         // push all four items to the primary stream. this should produce two 
items.
         // w1 = { 0:X0, 1:X1 }
         // w2 = { 0:Y0, 1:Y1 }
-        // --> w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
+        // --> w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
         //     w2 = { 0:Y0, 1:Y1 }
 
         for (int i = 0; i < expectedKeys.length; i++) {
@@ -127,9 +127,9 @@ public class KStreamKStreamJoinTest {
         processor.checkAndClearProcessResult("0:X0+Y0", "1:X1+Y1");
 
         // push all items to the other stream. this should produce six items.
-        // w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
+        // w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
         // w2 = { 0:Y0, 1:Y1 }
-        // --> w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
+        // --> w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
         //     w2 = { 0:Y0, 1:Y1, 0:YY0, 1:YY1, 2:YY2, 3:YY3 }
 
         for (int i = 0; i < expectedKeys.length; i++) {
@@ -139,9 +139,9 @@ public class KStreamKStreamJoinTest {
         processor.checkAndClearProcessResult("0:X0+YY0", "0:X0+YY0", 
"1:X1+YY1", "1:X1+YY1", "2:X2+YY2", "3:X3+YY3");
 
         // push all four items to the primary stream. this should produce six 
items.
-        // w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
+        // w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
         // w2 = { 0:Y0, 1:Y1, 0:YY0, 0:YY0, 1:YY1, 2:YY2, 3:YY3
-        // --> w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 
2:XX2, 3:XX3 }
+        // --> w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 
2:XX2, 3:XX3 }
         //     w2 = { 0:Y0, 1:Y1, 0:YY0, 1:YY1, 2:YY2, 3:YY3 }
 
         for (int i = 0; i < expectedKeys.length; i++) {
@@ -151,9 +151,9 @@ public class KStreamKStreamJoinTest {
         processor.checkAndClearProcessResult("0:XX0+Y0", "0:XX0+YY0", 
"1:XX1+Y1", "1:XX1+YY1", "2:XX2+YY2", "3:XX3+YY3");
 
         // push two items to the other stream. this should produce six item.
-        // w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 2:XX2, 
3:XX3 }
+        // w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 2:XX2, 
3:XX3 }
         // w2 = { 0:Y0, 1:Y1, 0:YY0, 0:YY0, 1:YY1, 2:YY2, 3:YY3
-        // --> w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 
2:XX2, 3:XX3 }
+        // --> w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 
2:XX2, 3:XX3 }
         //     w2 = { 0:Y0, 1:Y1, 0:YY0, 1:YY1, 2:YY2, 3:YY3, 0:YYY0, 1:YYY1 }
 
         for (int i = 0; i < 2; i++) {
@@ -191,7 +191,7 @@ public class KStreamKStreamJoinTest {
         // push two items to the primary stream. the other window is 
empty.this should produce two items
         // w1 = {}
         // w2 = {}
-        // --> w1 = { 0:X1, 1:X1 }
+        // --> w1 = { 0:X0, 1:X1 }
         //     w2 = {}
 
         for (int i = 0; i < 2; i++) {
@@ -203,7 +203,7 @@ public class KStreamKStreamJoinTest {
         // push two items to the other stream. this should produce two items.
         // w1 = { 0:X0, 1:X1 }
         // w2 = {}
-        // --> w1 = { 0:X1, 1:X1 }
+        // --> w1 = { 0:X0, 1:X1 }
         //     w2 = { 0:Y0, 1:Y1 }
 
         for (int i = 0; i < 2; i++) {
@@ -215,7 +215,7 @@ public class KStreamKStreamJoinTest {
         // push all four items to the primary stream. this should produce four 
items.
         // w1 = { 0:X0, 1:X1 }
         // w2 = { 0:Y0, 1:Y1 }
-        // --> w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
+        // --> w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
         //     w2 = { 0:Y0, 1:Y1 }
 
         for (int i = 0; i < expectedKeys.length; i++) {
@@ -225,9 +225,9 @@ public class KStreamKStreamJoinTest {
         processor.checkAndClearProcessResult("0:X0+Y0", "1:X1+Y1", 
"2:X2+null", "3:X3+null");
 
         // push all items to the other stream. this should produce six items.
-        // w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
+        // w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
         // w2 = { 0:Y0, 1:Y1 }
-        // --> w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
+        // --> w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
         //     w2 = { 0:Y0, 1:Y1, 0:YY0, 0:YY0, 1:YY1, 2:YY2, 3:YY3 }
 
         for (int i = 0; i < expectedKeys.length; i++) {
@@ -237,9 +237,9 @@ public class KStreamKStreamJoinTest {
         processor.checkAndClearProcessResult("0:X0+YY0", "0:X0+YY0", 
"1:X1+YY1", "1:X1+YY1", "2:X2+YY2", "3:X3+YY3");
 
         // push all four items to the primary stream. this should produce six 
items.
-        // w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
+        // w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3 }
         // w2 = { 0:Y0, 1:Y1, 0:YY0, 0:YY0, 1:YY1, 2:YY2, 3:YY3
-        // --> w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 
2:XX2, 3:XX3 }
+        // --> w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 
2:XX2, 3:XX3 }
         //     w2 = { 0:Y0, 1:Y1, 0:YY0, 0:YY0, 1:YY1, 2:YY2, 3:YY3 }
 
         for (int i = 0; i < expectedKeys.length; i++) {
@@ -249,9 +249,9 @@ public class KStreamKStreamJoinTest {
         processor.checkAndClearProcessResult("0:XX0+Y0", "0:XX0+YY0", 
"1:XX1+Y1", "1:XX1+YY1", "2:XX2+YY2", "3:XX3+YY3");
 
         // push two items to the other stream. this should produce six item.
-        // w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 2:XX2, 
3:XX3 }
+        // w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 2:XX2, 
3:XX3 }
         // w2 = { 0:Y0, 1:Y1, 0:YY0, 0:YY0, 1:YY1, 2:YY2, 3:YY3
-        // --> w1 = { 0:X1, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 
2:XX2, 3:XX3 }
+        // --> w1 = { 0:X0, 1:X1, 0:X0, 1:X1, 2:X2, 3:X3,  0:XX0, 1:XX1, 
2:XX2, 3:XX3 }
         //     w2 = { 0:Y0, 1:Y1, 0:YY0, 0:YY0, 1:YY1, 2:YY2, 3:YY3, 0:YYY0, 
1:YYY1 }
 
         for (int i = 0; i < 2; i++) {
@@ -292,7 +292,7 @@ public class KStreamKStreamJoinTest {
         // push two items to the primary stream. the other window is empty. 
this should produce no items.
         // w1 = {}
         // w2 = {}
-        // --> w1 = { 0:X1, 1:X1 }
+        // --> w1 = { 0:X0, 1:X1 }
         //     w2 = {}
         setRecordContext(time, topic1);
         for (int i = 0; i < 2; i++) {
@@ -304,7 +304,7 @@ public class KStreamKStreamJoinTest {
         // push two items to the other stream. this should produce two items.
         // w1 = { 0:X0, 1:X1 }
         // w2 = {}
-        // --> w1 = { 0:X1, 1:X1 }
+        // --> w1 = { 0:X0, 1:X1 }
         //     w2 = { 0:Y0, 1:Y1 }
 
         setRecordContext(time, topic2);

Reply via email to