You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2014/09/17 17:28:43 UTC
git commit: Remove space after comma for TupleXX.toString()
Repository: incubator-flink
Updated Branches:
refs/heads/master 2f6a9559c -> 7adbf53be
Remove space after comma for TupleXX.toString()
It is better to save some bytes when writing the output. Users can always overwrite to `toString()` if they want.
Author: Robert Metzger <rm...@apache.org>
Closes #118 from rmetzger/benchFixes and squashes the following commits:
cb8a251 [Robert Metzger] Remove space after comma for TupleXX.toString()
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/7adbf53b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/7adbf53b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/7adbf53b
Branch: refs/heads/master
Commit: 7adbf53beaa64298a61bac7ee2131f2a25156e64
Parents: 2f6a955
Author: Robert Metzger <rm...@apache.org>
Authored: Wed Sep 17 17:25:19 2014 +0200
Committer: Robert Metzger <rm...@apache.org>
Committed: Wed Sep 17 17:25:19 2014 +0200
----------------------------------------------------------------------
.../apache/flink/api/java/tuple/Tuple10.java | 18 +--
.../apache/flink/api/java/tuple/Tuple11.java | 20 +--
.../apache/flink/api/java/tuple/Tuple12.java | 22 ++--
.../apache/flink/api/java/tuple/Tuple13.java | 24 ++--
.../apache/flink/api/java/tuple/Tuple14.java | 26 ++--
.../apache/flink/api/java/tuple/Tuple15.java | 28 ++---
.../apache/flink/api/java/tuple/Tuple16.java | 30 ++---
.../apache/flink/api/java/tuple/Tuple17.java | 32 ++---
.../apache/flink/api/java/tuple/Tuple18.java | 34 ++---
.../apache/flink/api/java/tuple/Tuple19.java | 36 +++---
.../org/apache/flink/api/java/tuple/Tuple2.java | 2 +-
.../apache/flink/api/java/tuple/Tuple20.java | 38 +++---
.../apache/flink/api/java/tuple/Tuple21.java | 40 +++---
.../apache/flink/api/java/tuple/Tuple22.java | 42 +++----
.../apache/flink/api/java/tuple/Tuple23.java | 44 +++----
.../apache/flink/api/java/tuple/Tuple24.java | 46 +++----
.../apache/flink/api/java/tuple/Tuple25.java | 48 +++----
.../org/apache/flink/api/java/tuple/Tuple3.java | 4 +-
.../org/apache/flink/api/java/tuple/Tuple4.java | 6 +-
.../org/apache/flink/api/java/tuple/Tuple5.java | 8 +-
.../org/apache/flink/api/java/tuple/Tuple6.java | 10 +-
.../org/apache/flink/api/java/tuple/Tuple7.java | 12 +-
.../org/apache/flink/api/java/tuple/Tuple8.java | 14 +--
.../org/apache/flink/api/java/tuple/Tuple9.java | 16 +--
.../flink/api/java/tuple/TupleGenerator.java | 6 +-
.../flink/test/testdata/WordCountData.java | 126 +++++++++----------
.../DependencyConnectedComponentsITCase.java | 4 +-
...nentsWithParametrizableAggregatorITCase.java | 4 +-
...entsWithParametrizableConvergenceITCase.java | 4 +-
.../test/javaApiOperators/CrossITCase.java | 18 +--
.../flink/test/javaApiOperators/JoinITCase.java | 6 +-
31 files changed, 385 insertions(+), 383 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple10.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple10.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple10.java
index 5490128..406b3c2 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple10.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple10.java
@@ -205,15 +205,15 @@ public class Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple11.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple11.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple11.java
index 3b03d18..22fb80c 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple11.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple11.java
@@ -216,16 +216,16 @@ public class Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> extends Tuple
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple12.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple12.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple12.java
index 56ad8c0..e638ef0 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple12.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple12.java
@@ -227,17 +227,17 @@ public class Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> extends T
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple13.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple13.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple13.java
index ee5d33c..8c99aa8 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple13.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple13.java
@@ -238,18 +238,18 @@ public class Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> exte
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple14.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple14.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple14.java
index 43dc6ce..c84046e 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple14.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple14.java
@@ -249,19 +249,19 @@ public class Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple15.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple15.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple15.java
index 9f26542..1ebbe7f 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple15.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple15.java
@@ -260,20 +260,20 @@ public class Tuple15<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple16.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple16.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple16.java
index 2d925a1..fc1bf4a 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple16.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple16.java
@@ -271,21 +271,21 @@ public class Tuple16<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java
index e68b4fd..bad6d63 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java
@@ -282,22 +282,22 @@ public class Tuple17<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple18.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple18.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple18.java
index f7944b9..91008dc 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple18.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple18.java
@@ -293,23 +293,23 @@ public class Tuple18<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
- + ", " + StringUtils.arrayAwareToString(this.f17)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f17)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java
index 062bbf9..a248c0c 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java
@@ -304,24 +304,24 @@ public class Tuple19<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
- + ", " + StringUtils.arrayAwareToString(this.f17)
- + ", " + StringUtils.arrayAwareToString(this.f18)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f17)
+ + "," + StringUtils.arrayAwareToString(this.f18)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple2.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple2.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple2.java
index 4746f50..aabf5e2 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple2.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple2.java
@@ -125,7 +125,7 @@ public class Tuple2<T0, T1> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java
index f75d069..de4e0d0 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java
@@ -315,25 +315,25 @@ public class Tuple20<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
- + ", " + StringUtils.arrayAwareToString(this.f17)
- + ", " + StringUtils.arrayAwareToString(this.f18)
- + ", " + StringUtils.arrayAwareToString(this.f19)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f17)
+ + "," + StringUtils.arrayAwareToString(this.f18)
+ + "," + StringUtils.arrayAwareToString(this.f19)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java
index 5feb0dd..b8af1bd 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java
@@ -326,26 +326,26 @@ public class Tuple21<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
- + ", " + StringUtils.arrayAwareToString(this.f17)
- + ", " + StringUtils.arrayAwareToString(this.f18)
- + ", " + StringUtils.arrayAwareToString(this.f19)
- + ", " + StringUtils.arrayAwareToString(this.f20)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f17)
+ + "," + StringUtils.arrayAwareToString(this.f18)
+ + "," + StringUtils.arrayAwareToString(this.f19)
+ + "," + StringUtils.arrayAwareToString(this.f20)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java
index d8d82d6..62d76e7 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java
@@ -337,27 +337,27 @@ public class Tuple22<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
- + ", " + StringUtils.arrayAwareToString(this.f17)
- + ", " + StringUtils.arrayAwareToString(this.f18)
- + ", " + StringUtils.arrayAwareToString(this.f19)
- + ", " + StringUtils.arrayAwareToString(this.f20)
- + ", " + StringUtils.arrayAwareToString(this.f21)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f17)
+ + "," + StringUtils.arrayAwareToString(this.f18)
+ + "," + StringUtils.arrayAwareToString(this.f19)
+ + "," + StringUtils.arrayAwareToString(this.f20)
+ + "," + StringUtils.arrayAwareToString(this.f21)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java
index bb8379e..c569094 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java
@@ -348,28 +348,28 @@ public class Tuple23<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
- + ", " + StringUtils.arrayAwareToString(this.f17)
- + ", " + StringUtils.arrayAwareToString(this.f18)
- + ", " + StringUtils.arrayAwareToString(this.f19)
- + ", " + StringUtils.arrayAwareToString(this.f20)
- + ", " + StringUtils.arrayAwareToString(this.f21)
- + ", " + StringUtils.arrayAwareToString(this.f22)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f17)
+ + "," + StringUtils.arrayAwareToString(this.f18)
+ + "," + StringUtils.arrayAwareToString(this.f19)
+ + "," + StringUtils.arrayAwareToString(this.f20)
+ + "," + StringUtils.arrayAwareToString(this.f21)
+ + "," + StringUtils.arrayAwareToString(this.f22)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple24.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple24.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple24.java
index 18ce155..84b8c40 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple24.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple24.java
@@ -359,29 +359,29 @@ public class Tuple24<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
- + ", " + StringUtils.arrayAwareToString(this.f17)
- + ", " + StringUtils.arrayAwareToString(this.f18)
- + ", " + StringUtils.arrayAwareToString(this.f19)
- + ", " + StringUtils.arrayAwareToString(this.f20)
- + ", " + StringUtils.arrayAwareToString(this.f21)
- + ", " + StringUtils.arrayAwareToString(this.f22)
- + ", " + StringUtils.arrayAwareToString(this.f23)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f17)
+ + "," + StringUtils.arrayAwareToString(this.f18)
+ + "," + StringUtils.arrayAwareToString(this.f19)
+ + "," + StringUtils.arrayAwareToString(this.f20)
+ + "," + StringUtils.arrayAwareToString(this.f21)
+ + "," + StringUtils.arrayAwareToString(this.f22)
+ + "," + StringUtils.arrayAwareToString(this.f23)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java
index 3a916c5..24f52e7 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java
@@ -370,30 +370,30 @@ public class Tuple25<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
- + ", " + StringUtils.arrayAwareToString(this.f9)
- + ", " + StringUtils.arrayAwareToString(this.f10)
- + ", " + StringUtils.arrayAwareToString(this.f11)
- + ", " + StringUtils.arrayAwareToString(this.f12)
- + ", " + StringUtils.arrayAwareToString(this.f13)
- + ", " + StringUtils.arrayAwareToString(this.f14)
- + ", " + StringUtils.arrayAwareToString(this.f15)
- + ", " + StringUtils.arrayAwareToString(this.f16)
- + ", " + StringUtils.arrayAwareToString(this.f17)
- + ", " + StringUtils.arrayAwareToString(this.f18)
- + ", " + StringUtils.arrayAwareToString(this.f19)
- + ", " + StringUtils.arrayAwareToString(this.f20)
- + ", " + StringUtils.arrayAwareToString(this.f21)
- + ", " + StringUtils.arrayAwareToString(this.f22)
- + ", " + StringUtils.arrayAwareToString(this.f23)
- + ", " + StringUtils.arrayAwareToString(this.f24)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f9)
+ + "," + StringUtils.arrayAwareToString(this.f10)
+ + "," + StringUtils.arrayAwareToString(this.f11)
+ + "," + StringUtils.arrayAwareToString(this.f12)
+ + "," + StringUtils.arrayAwareToString(this.f13)
+ + "," + StringUtils.arrayAwareToString(this.f14)
+ + "," + StringUtils.arrayAwareToString(this.f15)
+ + "," + StringUtils.arrayAwareToString(this.f16)
+ + "," + StringUtils.arrayAwareToString(this.f17)
+ + "," + StringUtils.arrayAwareToString(this.f18)
+ + "," + StringUtils.arrayAwareToString(this.f19)
+ + "," + StringUtils.arrayAwareToString(this.f20)
+ + "," + StringUtils.arrayAwareToString(this.f21)
+ + "," + StringUtils.arrayAwareToString(this.f22)
+ + "," + StringUtils.arrayAwareToString(this.f23)
+ + "," + StringUtils.arrayAwareToString(this.f24)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple3.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple3.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple3.java
index 0682520..ea82e53 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple3.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple3.java
@@ -128,8 +128,8 @@ public class Tuple3<T0, T1, T2> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple4.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple4.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple4.java
index 3eeb098..910929a 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple4.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple4.java
@@ -139,9 +139,9 @@ public class Tuple4<T0, T1, T2, T3> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple5.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple5.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple5.java
index cc7ae29..c3ff743 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple5.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple5.java
@@ -150,10 +150,10 @@ public class Tuple5<T0, T1, T2, T3, T4> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple6.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple6.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple6.java
index db97ce5..2452c57 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple6.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple6.java
@@ -161,11 +161,11 @@ public class Tuple6<T0, T1, T2, T3, T4, T5> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple7.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple7.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple7.java
index c77343a..895c080 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple7.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple7.java
@@ -172,12 +172,12 @@ public class Tuple7<T0, T1, T2, T3, T4, T5, T6> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple8.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple8.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple8.java
index 9f01cc2..3058fd0 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple8.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple8.java
@@ -183,13 +183,13 @@ public class Tuple8<T0, T1, T2, T3, T4, T5, T6, T7> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple9.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple9.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple9.java
index 33dc5ff..9e87645 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple9.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple9.java
@@ -194,14 +194,14 @@ public class Tuple9<T0, T1, T2, T3, T4, T5, T6, T7, T8> extends Tuple {
@Override
public String toString() {
return "(" + StringUtils.arrayAwareToString(this.f0)
- + ", " + StringUtils.arrayAwareToString(this.f1)
- + ", " + StringUtils.arrayAwareToString(this.f2)
- + ", " + StringUtils.arrayAwareToString(this.f3)
- + ", " + StringUtils.arrayAwareToString(this.f4)
- + ", " + StringUtils.arrayAwareToString(this.f5)
- + ", " + StringUtils.arrayAwareToString(this.f6)
- + ", " + StringUtils.arrayAwareToString(this.f7)
- + ", " + StringUtils.arrayAwareToString(this.f8)
+ + "," + StringUtils.arrayAwareToString(this.f1)
+ + "," + StringUtils.arrayAwareToString(this.f2)
+ + "," + StringUtils.arrayAwareToString(this.f3)
+ + "," + StringUtils.arrayAwareToString(this.f4)
+ + "," + StringUtils.arrayAwareToString(this.f5)
+ + "," + StringUtils.arrayAwareToString(this.f6)
+ + "," + StringUtils.arrayAwareToString(this.f7)
+ + "," + StringUtils.arrayAwareToString(this.f8)
+ ")";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java
index f54ecfa..3b6b65b 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java
@@ -673,7 +673,7 @@ class TupleGenerator {
w.println("\tpublic String toString() {");
w.println("\t\treturn \"(\" + StringUtils.arrayAwareToString(this.f0)");
for (int i = 1; i < numFields; i++) {
- w.println("\t\t\t+ \", \" + StringUtils.arrayAwareToString(this.f" + i + ")");
+ w.println("\t\t\t+ \",\" + StringUtils.arrayAwareToString(this.f" + i + ")");
}
w.println("\t\t\t+ \")\";");
w.println("\t}");
@@ -844,7 +844,7 @@ class TupleGenerator {
+ " * with the License. You may obtain a copy of the License at\n"
+ " *\n"
+ " * http://www.apache.org/licenses/LICENSE-2.0\n"
- + " *\n"
+ + " *\n"
+ " * Unless required by applicable law or agreed to in writing, software\n"
+ " * distributed under the License is distributed on an \"AS IS\" BASIS,\n"
+ " * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n"
@@ -852,6 +852,8 @@ class TupleGenerator {
+ " * limitations under the License.\n"
+ " */" +
"\n" +
+ "\n" +
+ "\n" +
"// --------------------------------------------------------------\n" +
"// THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!\n" +
"// GENERATED FROM " + TupleGenerator.class.getName() + ".\n" +
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WordCountData.java
----------------------------------------------------------------------
diff --git a/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WordCountData.java b/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WordCountData.java
index 13bb4d7..e8be6eb 100644
--- a/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WordCountData.java
+++ b/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WordCountData.java
@@ -161,69 +161,69 @@ public class WordCountData {
+ "dient 2\n" + "tiefer 1\n" + "naeh 1\n" + "zieren 1\n";
- public static final String COUNTS_AS_TUPLES = "(machen, 1)\n" + "(zeit, 2)\n" + "(heerscharen, 1)\n" + "(keiner, 2)\n" + "(meine, 3)\n"
- + "(fuehr, 1)\n" + "(triumph, 1)\n" + "(kommst, 1)\n" + "(frei, 1)\n" + "(schaffen, 1)\n" + "(gesinde, 1)\n"
- + "(langbeinigen, 1)\n" + "(schalk, 1)\n" + "(besser, 1)\n" + "(solang, 1)\n" + "(meer, 4)\n" + "(fragst, 1)\n"
- + "(gabriel, 1)\n" + "(selbst, 2)\n" + "(bin, 1)\n" + "(sich, 7)\n" + "(du, 11)\n" + "(sogar, 1)\n" + "(geht, 1)\n"
- + "(immer, 4)\n" + "(mensch, 2)\n" + "(befestigt, 1)\n" + "(lebt, 2)\n" + "(mag, 3)\n" + "(engeln, 2)\n" + "(breiten, 1)\n"
- + "(blitzendes, 1)\n" + "(tags, 1)\n" + "(sie, 2)\n" + "(plagen, 2)\n" + "(allzu, 1)\n" + "(meisten, 1)\n" + "(o, 1)\n"
- + "(pfade, 1)\n" + "(kennst, 1)\n" + "(nichts, 3)\n" + "(gedanken, 1)\n" + "(befriedigt, 1)\n" + "(mich, 6)\n" + "(s, 3)\n"
- + "(es, 8)\n" + "(verneinen, 1)\n" + "(er, 13)\n" + "(gleich, 1)\n" + "(baeumchen, 1)\n" + "(donnergang, 1)\n"
- + "(wunderlich, 1)\n" + "(reise, 1)\n" + "(urquell, 1)\n" + "(doch, 3)\n" + "(aufs, 2)\n" + "(toten, 1)\n" + "(niemals, 1)\n"
- + "(eine, 2)\n" + "(hab, 1)\n" + "(darfst, 1)\n" + "(da, 5)\n" + "(gen, 1)\n" + "(einem, 2)\n" + "(teil, 1)\n" + "(das, 7)\n"
- + "(speise, 1)\n" + "(wenig, 1)\n" + "(sterne, 1)\n" + "(geb, 1)\n" + "(welten, 1)\n" + "(alle, 3)\n" + "(toent, 1)\n"
- + "(gras, 1)\n" + "(felsen, 1)\n" + "(kette, 1)\n" + "(ich, 14)\n" + "(fuer, 2)\n" + "(als, 3)\n" + "(mein, 1)\n"
- + "(schoene, 1)\n" + "(verzeih, 1)\n" + "(schwankender, 1)\n" + "(wie, 9)\n" + "(menschlich, 1)\n" + "(gaertner, 1)\n"
- + "(taetigkeit, 1)\n" + "(bange, 1)\n" + "(liebe, 1)\n" + "(sei, 2)\n" + "(seh, 1)\n" + "(tollheit, 1)\n" + "(am, 6)\n"
- + "(michael, 1)\n" + "(geist, 1)\n" + "(ab, 1)\n" + "(nahst, 1)\n" + "(vollendet, 1)\n" + "(liebt, 1)\n" + "(brausen, 1)\n"
- + "(nase, 1)\n" + "(erlaubt, 1)\n" + "(weiss, 2)\n" + "(schnellem, 1)\n" + "(deinem, 1)\n" + "(gleichem, 1)\n"
- + "(gaerung, 1)\n" + "(dauernden, 1)\n" + "(deines, 1)\n" + "(vorgeschriebne, 1)\n" + "(irdisch, 1)\n" + "(worte, 1)\n"
- + "(verehren, 1)\n" + "(hohen, 2)\n" + "(weise, 2)\n" + "(kuenft, 1)\n" + "(werdende, 1)\n" + "(wette, 2)\n" + "(wuetend, 1)\n"
- + "(erscheinung, 1)\n" + "(gar, 2)\n" + "(verlieren, 1)\n" + "(braucht, 1)\n" + "(weiter, 1)\n" + "(trank, 1)\n"
- + "(tierischer, 1)\n" + "(wohl, 1)\n" + "(verteilen, 1)\n" + "(verhoehnt, 1)\n" + "(schaeumt, 1)\n" + "(himmelslichts, 1)\n"
- + "(unbedingte, 1)\n" + "(herzlich, 1)\n" + "(anblick, 2)\n" + "(nennt, 1)\n" + "(gruent, 1)\n" + "(bluet, 1)\n"
- + "(leichnam, 1)\n" + "(erschlaffen, 1)\n" + "(jammertagen, 1)\n" + "(zieh, 1)\n" + "(ihm, 3)\n" + "(besondre, 1)\n"
- + "(ihn, 5)\n" + "(grossen, 1)\n" + "(vollen, 1)\n" + "(ihr, 7)\n" + "(boten, 1)\n" + "(voller, 1)\n" + "(singt, 1)\n"
- + "(muhme, 1)\n" + "(schon, 1)\n" + "(last, 1)\n" + "(kleine, 1)\n" + "(paradieseshelle, 1)\n" + "(nein, 1)\n" + "(echten, 1)\n"
- + "(unter, 1)\n" + "(bei, 1)\n" + "(herr, 11)\n" + "(gern, 3)\n" + "(sphaerenlauf, 1)\n" + "(stets, 1)\n" + "(ganze, 1)\n"
- + "(braechte, 1)\n" + "(fordert, 1)\n" + "(schoensten, 1)\n" + "(herrlich, 2)\n" + "(gegeben, 1)\n" + "(allein, 2)\n"
- + "(reichen, 1)\n" + "(schauervoller, 1)\n" + "(musst, 1)\n" + "(recht, 1)\n" + "(bleibt, 1)\n" + "(pracht, 1)\n"
- + "(treibt, 1)\n" + "(befangen, 1)\n" + "(was, 2)\n" + "(menschen, 3)\n" + "(jede, 1)\n" + "(hohe, 1)\n" + "(tiefsten, 1)\n"
- + "(bilden, 1)\n" + "(drum, 1)\n" + "(gibt, 2)\n" + "(guter, 1)\n" + "(fuerwahr, 1)\n" + "(im, 3)\n" + "(grund, 1)\n" + "(in, 9)\n"
- + "(hoechste, 1)\n" + "(schliesst, 1)\n" + "(fels, 1)\n" + "(steh, 1)\n" + "(euer, 1)\n" + "(erster, 1)\n" + "(ersten, 3)\n"
- + "(goettersoehne, 1)\n" + "(brechen, 1)\n" + "(tiefen, 1)\n" + "(frucht, 1)\n" + "(kreis, 1)\n" + "(siehst, 1)\n"
- + "(wege, 1)\n" + "(ist, 8)\n" + "(zikaden, 1)\n" + "(frischen, 1)\n" + "(ruh, 1)\n" + "(deine, 2)\n" + "(maus, 1)\n"
- + "(brudersphaeren, 1)\n" + "(nachher, 1)\n" + "(euch, 4)\n" + "(gnaden, 1)\n" + "(anzuklagen, 1)\n" + "(schlange, 1)\n"
- + "(staerke, 2)\n" + "(erde, 4)\n" + "(verlaub, 1)\n" + "(sanfte, 1)\n" + "(holden, 1)\n" + "(sonst, 1)\n" + "(treten, 1)\n"
- + "(sahst, 1)\n" + "(alten, 1)\n" + "(um, 1)\n" + "(wieder, 1)\n" + "(alter, 1)\n" + "(altes, 1)\n" + "(nun, 1)\n" + "(lieb, 1)\n"
- + "(gesellen, 1)\n" + "(erscheinen, 1)\n" + "(wirkt, 2)\n" + "(haettst, 2)\n" + "(nur, 7)\n" + "(tiefbewegte, 1)\n"
- + "(lachen, 2)\n" + "(drange, 1)\n" + "(schlag, 1)\n" + "(schein, 1)\n" + "(muss, 1)\n" + "(verworren, 1)\n" + "(weges, 1)\n"
- + "(allen, 1)\n" + "(gewoehnlich, 1)\n" + "(alles, 1)\n" + "(halb, 1)\n" + "(stuerme, 1)\n" + "(springt, 1)\n" + "(sollt, 1)\n"
- + "(klarheit, 1)\n" + "(so, 6)\n" + "(erfassen, 1)\n" + "(liedchen, 1)\n" + "(prolog, 1)\n" + "(zur, 1)\n" + "(fressen, 1)\n"
- + "(zum, 1)\n" + "(faust, 2)\n" + "(erzengel, 2)\n" + "(jahre, 1)\n" + "(sonn, 1)\n" + "(raphael, 1)\n" + "(land, 2)\n"
- + "(lang, 1)\n" + "(gelange, 1)\n" + "(lust, 2)\n" + "(welt, 1)\n" + "(sehe, 1)\n" + "(ihre, 1)\n" + "(jedes, 1)\n"
- + "(erfreut, 1)\n" + "(seiner, 1)\n" + "(denn, 1)\n" + "(wandeln, 1)\n" + "(wechselt, 1)\n" + "(jeden, 1)\n" + "(dort, 1)\n"
- + "(schlecht, 1)\n" + "(wenigsten, 1)\n" + "(wuerd, 1)\n" + "(schranken, 1)\n" + "(bewusst, 2)\n" + "(seinem, 2)\n"
- + "(gehasst, 1)\n" + "(sein, 1)\n" + "(meinem, 1)\n" + "(meinen, 1)\n" + "(pathos, 1)\n" + "(herrn, 1)\n" + "(lange, 2)\n"
- + "(herab, 1)\n" + "(diesen, 1)\n" + "(ihren, 1)\n" + "(beruehmte, 1)\n" + "(goethe, 1)\n" + "(tag, 3)\n" + "(tier, 1)\n"
- + "(quark, 1)\n" + "(dank, 1)\n" + "(seine, 1)\n" + "(teufel, 2)\n" + "(zweck, 1)\n" + "(wenn, 7)\n" + "(soll, 1)\n"
- + "(wirkung, 1)\n" + "(erlaubnis, 1)\n" + "(lebendig, 1)\n" + "(uns, 1)\n" + "(leicht, 1)\n" + "(gewiss, 1)\n"
- + "(schnell, 1)\n" + "(und, 29)\n" + "(gerne, 1)\n" + "(rechten, 1)\n" + "(umher, 2)\n" + "(vernunft, 1)\n" + "(grase, 1)\n"
- + "(nach, 1)\n" + "(leben, 1)\n" + "(gott, 1)\n" + "(der, 29)\n" + "(des, 5)\n" + "(doktor, 1)\n" + "(beschaemt, 1)\n"
- + "(dreht, 1)\n" + "(habe, 1)\n" + "(sagen, 2)\n" + "(bekennen, 1)\n" + "(dunklen, 1)\n" + "(wettet, 1)\n" + "(den, 9)\n"
- + "(mephistopheles, 9)\n" + "(dem, 4)\n" + "(auch, 4)\n" + "(kann, 2)\n" + "(armen, 1)\n" + "(mir, 9)\n" + "(strebt, 1)\n"
- + "(gut, 2)\n" + "(mit, 11)\n" + "(bald, 2)\n" + "(himmlischen, 1)\n" + "(himmel, 3)\n" + "(noch, 3)\n" + "(kannst, 1)\n"
- + "(deinesgleichen, 1)\n" + "(flammt, 1)\n" + "(ergruenden, 2)\n" + "(nacht, 1)\n" + "(scheint, 1)\n" + "(ferne, 2)\n"
- + "(tragoedie, 1)\n" + "(abgewoehnt, 1)\n" + "(reizt, 1)\n" + "(geistern, 1)\n" + "(nicht, 10)\n" + "(sacht, 1)\n"
- + "(unbegreiflich, 2)\n" + "(schnelle, 1)\n" + "(einmal, 1)\n" + "(werd, 1)\n" + "(werke, 2)\n" + "(begraebt, 1)\n"
- + "(knecht, 1)\n" + "(rings, 1)\n" + "(wird, 1)\n" + "(katze, 1)\n" + "(huete, 1)\n" + "(fortgerissen, 1)\n" + "(gebt, 1)\n"
- + "(huebsch, 1)\n" + "(hast, 1)\n" + "(irrt, 1)\n" + "(befinde, 1)\n" + "(sind, 2)\n" + "(fuehren, 2)\n" + "(fliegt, 1)\n"
- + "(ewig, 3)\n" + "(brust, 2)\n" + "(sonne, 1)\n" + "(sprechen, 1)\n" + "(ein, 3)\n" + "(strasse, 1)\n" + "(von, 8)\n"
- + "(ueberlassen, 1)\n" + "(dir, 4)\n" + "(vom, 3)\n" + "(zu, 11)\n" + "(schwebt, 1)\n" + "(die, 22)\n" + "(vor, 2)\n"
- + "(wangen, 1)\n" + "(wettgesang, 1)\n" + "(donnerschlags, 1)\n" + "(find, 1)\n" + "(dich, 3)\n" + "(umfass, 1)\n"
- + "(verboten, 1)\n" + "(laeg, 1)\n" + "(nie, 1)\n" + "(drei, 2)\n" + "(dauern, 1)\n" + "(toren, 1)\n" + "(dauert, 1)\n"
- + "(verheeren, 1)\n" + "(fliegend, 1)\n" + "(aus, 1)\n" + "(staub, 1)\n" + "(fluessen, 1)\n" + "(haus, 1)\n" + "(auf, 5)\n"
- + "(dient, 2)\n" + "(tiefer, 1)\n" + "(naeh, 1)\n" + "(zieren, 1)\n";
+ public static final String COUNTS_AS_TUPLES = "(machen,1)\n" + "(zeit,2)\n" + "(heerscharen,1)\n" + "(keiner,2)\n" + "(meine,3)\n"
+ + "(fuehr,1)\n" + "(triumph,1)\n" + "(kommst,1)\n" + "(frei,1)\n" + "(schaffen,1)\n" + "(gesinde,1)\n"
+ + "(langbeinigen,1)\n" + "(schalk,1)\n" + "(besser,1)\n" + "(solang,1)\n" + "(meer,4)\n" + "(fragst,1)\n"
+ + "(gabriel,1)\n" + "(selbst,2)\n" + "(bin,1)\n" + "(sich,7)\n" + "(du,11)\n" + "(sogar,1)\n" + "(geht,1)\n"
+ + "(immer,4)\n" + "(mensch,2)\n" + "(befestigt,1)\n" + "(lebt,2)\n" + "(mag,3)\n" + "(engeln,2)\n" + "(breiten,1)\n"
+ + "(blitzendes,1)\n" + "(tags,1)\n" + "(sie,2)\n" + "(plagen,2)\n" + "(allzu,1)\n" + "(meisten,1)\n" + "(o,1)\n"
+ + "(pfade,1)\n" + "(kennst,1)\n" + "(nichts,3)\n" + "(gedanken,1)\n" + "(befriedigt,1)\n" + "(mich,6)\n" + "(s,3)\n"
+ + "(es,8)\n" + "(verneinen,1)\n" + "(er,13)\n" + "(gleich,1)\n" + "(baeumchen,1)\n" + "(donnergang,1)\n"
+ + "(wunderlich,1)\n" + "(reise,1)\n" + "(urquell,1)\n" + "(doch,3)\n" + "(aufs,2)\n" + "(toten,1)\n" + "(niemals,1)\n"
+ + "(eine,2)\n" + "(hab,1)\n" + "(darfst,1)\n" + "(da,5)\n" + "(gen,1)\n" + "(einem,2)\n" + "(teil,1)\n" + "(das,7)\n"
+ + "(speise,1)\n" + "(wenig,1)\n" + "(sterne,1)\n" + "(geb,1)\n" + "(welten,1)\n" + "(alle,3)\n" + "(toent,1)\n"
+ + "(gras,1)\n" + "(felsen,1)\n" + "(kette,1)\n" + "(ich,14)\n" + "(fuer,2)\n" + "(als,3)\n" + "(mein,1)\n"
+ + "(schoene,1)\n" + "(verzeih,1)\n" + "(schwankender,1)\n" + "(wie,9)\n" + "(menschlich,1)\n" + "(gaertner,1)\n"
+ + "(taetigkeit,1)\n" + "(bange,1)\n" + "(liebe,1)\n" + "(sei,2)\n" + "(seh,1)\n" + "(tollheit,1)\n" + "(am,6)\n"
+ + "(michael,1)\n" + "(geist,1)\n" + "(ab,1)\n" + "(nahst,1)\n" + "(vollendet,1)\n" + "(liebt,1)\n" + "(brausen,1)\n"
+ + "(nase,1)\n" + "(erlaubt,1)\n" + "(weiss,2)\n" + "(schnellem,1)\n" + "(deinem,1)\n" + "(gleichem,1)\n"
+ + "(gaerung,1)\n" + "(dauernden,1)\n" + "(deines,1)\n" + "(vorgeschriebne,1)\n" + "(irdisch,1)\n" + "(worte,1)\n"
+ + "(verehren,1)\n" + "(hohen,2)\n" + "(weise,2)\n" + "(kuenft,1)\n" + "(werdende,1)\n" + "(wette,2)\n" + "(wuetend,1)\n"
+ + "(erscheinung,1)\n" + "(gar,2)\n" + "(verlieren,1)\n" + "(braucht,1)\n" + "(weiter,1)\n" + "(trank,1)\n"
+ + "(tierischer,1)\n" + "(wohl,1)\n" + "(verteilen,1)\n" + "(verhoehnt,1)\n" + "(schaeumt,1)\n" + "(himmelslichts,1)\n"
+ + "(unbedingte,1)\n" + "(herzlich,1)\n" + "(anblick,2)\n" + "(nennt,1)\n" + "(gruent,1)\n" + "(bluet,1)\n"
+ + "(leichnam,1)\n" + "(erschlaffen,1)\n" + "(jammertagen,1)\n" + "(zieh,1)\n" + "(ihm,3)\n" + "(besondre,1)\n"
+ + "(ihn,5)\n" + "(grossen,1)\n" + "(vollen,1)\n" + "(ihr,7)\n" + "(boten,1)\n" + "(voller,1)\n" + "(singt,1)\n"
+ + "(muhme,1)\n" + "(schon,1)\n" + "(last,1)\n" + "(kleine,1)\n" + "(paradieseshelle,1)\n" + "(nein,1)\n" + "(echten,1)\n"
+ + "(unter,1)\n" + "(bei,1)\n" + "(herr,11)\n" + "(gern,3)\n" + "(sphaerenlauf,1)\n" + "(stets,1)\n" + "(ganze,1)\n"
+ + "(braechte,1)\n" + "(fordert,1)\n" + "(schoensten,1)\n" + "(herrlich,2)\n" + "(gegeben,1)\n" + "(allein,2)\n"
+ + "(reichen,1)\n" + "(schauervoller,1)\n" + "(musst,1)\n" + "(recht,1)\n" + "(bleibt,1)\n" + "(pracht,1)\n"
+ + "(treibt,1)\n" + "(befangen,1)\n" + "(was,2)\n" + "(menschen,3)\n" + "(jede,1)\n" + "(hohe,1)\n" + "(tiefsten,1)\n"
+ + "(bilden,1)\n" + "(drum,1)\n" + "(gibt,2)\n" + "(guter,1)\n" + "(fuerwahr,1)\n" + "(im,3)\n" + "(grund,1)\n" + "(in,9)\n"
+ + "(hoechste,1)\n" + "(schliesst,1)\n" + "(fels,1)\n" + "(steh,1)\n" + "(euer,1)\n" + "(erster,1)\n" + "(ersten,3)\n"
+ + "(goettersoehne,1)\n" + "(brechen,1)\n" + "(tiefen,1)\n" + "(frucht,1)\n" + "(kreis,1)\n" + "(siehst,1)\n"
+ + "(wege,1)\n" + "(ist,8)\n" + "(zikaden,1)\n" + "(frischen,1)\n" + "(ruh,1)\n" + "(deine,2)\n" + "(maus,1)\n"
+ + "(brudersphaeren,1)\n" + "(nachher,1)\n" + "(euch,4)\n" + "(gnaden,1)\n" + "(anzuklagen,1)\n" + "(schlange,1)\n"
+ + "(staerke,2)\n" + "(erde,4)\n" + "(verlaub,1)\n" + "(sanfte,1)\n" + "(holden,1)\n" + "(sonst,1)\n" + "(treten,1)\n"
+ + "(sahst,1)\n" + "(alten,1)\n" + "(um,1)\n" + "(wieder,1)\n" + "(alter,1)\n" + "(altes,1)\n" + "(nun,1)\n" + "(lieb,1)\n"
+ + "(gesellen,1)\n" + "(erscheinen,1)\n" + "(wirkt,2)\n" + "(haettst,2)\n" + "(nur,7)\n" + "(tiefbewegte,1)\n"
+ + "(lachen,2)\n" + "(drange,1)\n" + "(schlag,1)\n" + "(schein,1)\n" + "(muss,1)\n" + "(verworren,1)\n" + "(weges,1)\n"
+ + "(allen,1)\n" + "(gewoehnlich,1)\n" + "(alles,1)\n" + "(halb,1)\n" + "(stuerme,1)\n" + "(springt,1)\n" + "(sollt,1)\n"
+ + "(klarheit,1)\n" + "(so,6)\n" + "(erfassen,1)\n" + "(liedchen,1)\n" + "(prolog,1)\n" + "(zur,1)\n" + "(fressen,1)\n"
+ + "(zum,1)\n" + "(faust,2)\n" + "(erzengel,2)\n" + "(jahre,1)\n" + "(sonn,1)\n" + "(raphael,1)\n" + "(land,2)\n"
+ + "(lang,1)\n" + "(gelange,1)\n" + "(lust,2)\n" + "(welt,1)\n" + "(sehe,1)\n" + "(ihre,1)\n" + "(jedes,1)\n"
+ + "(erfreut,1)\n" + "(seiner,1)\n" + "(denn,1)\n" + "(wandeln,1)\n" + "(wechselt,1)\n" + "(jeden,1)\n" + "(dort,1)\n"
+ + "(schlecht,1)\n" + "(wenigsten,1)\n" + "(wuerd,1)\n" + "(schranken,1)\n" + "(bewusst,2)\n" + "(seinem,2)\n"
+ + "(gehasst,1)\n" + "(sein,1)\n" + "(meinem,1)\n" + "(meinen,1)\n" + "(pathos,1)\n" + "(herrn,1)\n" + "(lange,2)\n"
+ + "(herab,1)\n" + "(diesen,1)\n" + "(ihren,1)\n" + "(beruehmte,1)\n" + "(goethe,1)\n" + "(tag,3)\n" + "(tier,1)\n"
+ + "(quark,1)\n" + "(dank,1)\n" + "(seine,1)\n" + "(teufel,2)\n" + "(zweck,1)\n" + "(wenn,7)\n" + "(soll,1)\n"
+ + "(wirkung,1)\n" + "(erlaubnis,1)\n" + "(lebendig,1)\n" + "(uns,1)\n" + "(leicht,1)\n" + "(gewiss,1)\n"
+ + "(schnell,1)\n" + "(und,29)\n" + "(gerne,1)\n" + "(rechten,1)\n" + "(umher,2)\n" + "(vernunft,1)\n" + "(grase,1)\n"
+ + "(nach,1)\n" + "(leben,1)\n" + "(gott,1)\n" + "(der,29)\n" + "(des,5)\n" + "(doktor,1)\n" + "(beschaemt,1)\n"
+ + "(dreht,1)\n" + "(habe,1)\n" + "(sagen,2)\n" + "(bekennen,1)\n" + "(dunklen,1)\n" + "(wettet,1)\n" + "(den,9)\n"
+ + "(mephistopheles,9)\n" + "(dem,4)\n" + "(auch,4)\n" + "(kann,2)\n" + "(armen,1)\n" + "(mir,9)\n" + "(strebt,1)\n"
+ + "(gut,2)\n" + "(mit,11)\n" + "(bald,2)\n" + "(himmlischen,1)\n" + "(himmel,3)\n" + "(noch,3)\n" + "(kannst,1)\n"
+ + "(deinesgleichen,1)\n" + "(flammt,1)\n" + "(ergruenden,2)\n" + "(nacht,1)\n" + "(scheint,1)\n" + "(ferne,2)\n"
+ + "(tragoedie,1)\n" + "(abgewoehnt,1)\n" + "(reizt,1)\n" + "(geistern,1)\n" + "(nicht,10)\n" + "(sacht,1)\n"
+ + "(unbegreiflich,2)\n" + "(schnelle,1)\n" + "(einmal,1)\n" + "(werd,1)\n" + "(werke,2)\n" + "(begraebt,1)\n"
+ + "(knecht,1)\n" + "(rings,1)\n" + "(wird,1)\n" + "(katze,1)\n" + "(huete,1)\n" + "(fortgerissen,1)\n" + "(gebt,1)\n"
+ + "(huebsch,1)\n" + "(hast,1)\n" + "(irrt,1)\n" + "(befinde,1)\n" + "(sind,2)\n" + "(fuehren,2)\n" + "(fliegt,1)\n"
+ + "(ewig,3)\n" + "(brust,2)\n" + "(sonne,1)\n" + "(sprechen,1)\n" + "(ein,3)\n" + "(strasse,1)\n" + "(von,8)\n"
+ + "(ueberlassen,1)\n" + "(dir,4)\n" + "(vom,3)\n" + "(zu,11)\n" + "(schwebt,1)\n" + "(die,22)\n" + "(vor,2)\n"
+ + "(wangen,1)\n" + "(wettgesang,1)\n" + "(donnerschlags,1)\n" + "(find,1)\n" + "(dich,3)\n" + "(umfass,1)\n"
+ + "(verboten,1)\n" + "(laeg,1)\n" + "(nie,1)\n" + "(drei,2)\n" + "(dauern,1)\n" + "(toren,1)\n" + "(dauert,1)\n"
+ + "(verheeren,1)\n" + "(fliegend,1)\n" + "(aus,1)\n" + "(staub,1)\n" + "(fluessen,1)\n" + "(haus,1)\n" + "(auf,5)\n"
+ + "(dient,2)\n" + "(tiefer,1)\n" + "(naeh,1)\n" + "(zieren,1)\n";
private WordCountData() {}
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-tests/src/test/java/org/apache/flink/test/iterative/DependencyConnectedComponentsITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/DependencyConnectedComponentsITCase.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/DependencyConnectedComponentsITCase.java
index fdfb321..a62763a 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/iterative/DependencyConnectedComponentsITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/DependencyConnectedComponentsITCase.java
@@ -90,8 +90,8 @@ public class DependencyConnectedComponentsITCase extends JavaProgramTestBase {
resultPath = getTempDirPath("result");
- expectedResult = "(1, 1)\n" + "(2, 1)\n" + "(3, 1)\n" + "(4, 1)\n" +
- "(5, 1)\n" + "(6, 1)\n" + "(7, 7)\n" + "(8, 7)\n" + "(9, 7)\n";
+ expectedResult = "(1,1)\n" + "(2,1)\n" + "(3,1)\n" + "(4,1)\n" +
+ "(5,1)\n" + "(6,1)\n" + "(7,7)\n" + "(8,7)\n" + "(9,7)\n";
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableAggregatorITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableAggregatorITCase.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableAggregatorITCase.java
index e1ae706..8097f28 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableAggregatorITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableAggregatorITCase.java
@@ -83,8 +83,8 @@ public class ConnectedComponentsWithParametrizableAggregatorITCase extends JavaP
resultPath = getTempDirPath("result");
- expectedResult = "(1, 1)\n" + "(2, 1)\n" + "(3, 1)\n" + "(4, 1)\n" +
- "(5, 1)\n" + "(6, 1)\n" + "(7, 7)\n" + "(8, 7)\n" + "(9, 7)\n";
+ expectedResult = "(1,1)\n" + "(2,1)\n" + "(3,1)\n" + "(4,1)\n" +
+ "(5,1)\n" + "(6,1)\n" + "(7,7)\n" + "(8,7)\n" + "(9,7)\n";
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableConvergenceITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableConvergenceITCase.java b/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableConvergenceITCase.java
index 039d64e..6678940 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableConvergenceITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/ConnectedComponentsWithParametrizableConvergenceITCase.java
@@ -86,8 +86,8 @@ public class ConnectedComponentsWithParametrizableConvergenceITCase extends Java
resultPath = getTempDirPath("result");
- expectedResult = "(1, 1)\n" + "(2, 1)\n" + "(3, 1)\n" + "(4, 1)\n" +
- "(5, 2)\n" + "(6, 1)\n" + "(7, 7)\n" + "(8, 7)\n" + "(9, 7)\n";
+ expectedResult = "(1,1)\n" + "(2,1)\n" + "(3,1)\n" + "(4,1)\n" +
+ "(5,2)\n" + "(6,1)\n" + "(7,7)\n" + "(8,7)\n" + "(9,7)\n";
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CrossITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CrossITCase.java b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CrossITCase.java
index 304dda2..7c264b6 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CrossITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CrossITCase.java
@@ -327,15 +327,15 @@ public class CrossITCase extends JavaProgramTestBase {
env.execute();
// return expected result
- return "(1, 1, Hi),(2, 2, 1, Hallo Welt, 2)\n" +
- "(1, 1, Hi),(1, 1, 0, Hallo, 1)\n" +
- "(1, 1, Hi),(2, 3, 2, Hallo Welt wie, 1)\n" +
- "(2, 2, Hello),(2, 2, 1, Hallo Welt, 2)\n" +
- "(2, 2, Hello),(1, 1, 0, Hallo, 1)\n" +
- "(2, 2, Hello),(2, 3, 2, Hallo Welt wie, 1)\n" +
- "(3, 2, Hello world),(2, 2, 1, Hallo Welt, 2)\n" +
- "(3, 2, Hello world),(1, 1, 0, Hallo, 1)\n" +
- "(3, 2, Hello world),(2, 3, 2, Hallo Welt wie, 1)\n";
+ return "(1,1,Hi),(2,2,1,Hallo Welt,2)\n" +
+ "(1,1,Hi),(1,1,0,Hallo,1)\n" +
+ "(1,1,Hi),(2,3,2,Hallo Welt wie,1)\n" +
+ "(2,2,Hello),(2,2,1,Hallo Welt,2)\n" +
+ "(2,2,Hello),(1,1,0,Hallo,1)\n" +
+ "(2,2,Hello),(2,3,2,Hallo Welt wie,1)\n" +
+ "(3,2,Hello world),(2,2,1,Hallo Welt,2)\n" +
+ "(3,2,Hello world),(1,1,0,Hallo,1)\n" +
+ "(3,2,Hello world),(2,3,2,Hallo Welt wie,1)\n";
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/7adbf53b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java
index 45a5458..290b1c2 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java
@@ -162,9 +162,9 @@ public class JoinITCase extends JavaProgramTestBase {
env.execute();
// return expected result
- return "(1, 1, Hi),(2, 2, 1, Hallo Welt, 2)\n" +
- "(2, 2, Hello),(2, 3, 2, Hallo Welt wie, 1)\n" +
- "(3, 2, Hello world),(3, 4, 3, Hallo Welt wie gehts?, 2)\n";
+ return "(1,1,Hi),(2,2,1,Hallo Welt,2)\n" +
+ "(2,2,Hello),(2,3,2,Hallo Welt wie,1)\n" +
+ "(3,2,Hello world),(3,4,3,Hallo Welt wie gehts?,2)\n";
}
case 4: {