You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2014/06/25 17:48:30 UTC
[4/4] git commit: Fix generic type warnings in generated tuples
Fix generic type warnings in generated tuples
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/49cd35a7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/49cd35a7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/49cd35a7
Branch: refs/heads/master
Commit: 49cd35a7632f32fd70eeefffc129ac764c1df262
Parents: 35438ec
Author: Stephan Ewen <se...@apache.org>
Authored: Wed Jun 25 16:55:20 2014 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Wed Jun 25 16:55:20 2014 +0200
----------------------------------------------------------------------
.../api/java/operators/CrossOperator.java | 220 +++++++++----------
.../eu/stratosphere/api/java/tuple/Tuple1.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple10.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple11.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple12.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple13.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple14.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple15.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple16.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple17.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple18.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple19.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple2.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple20.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple21.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple22.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple23.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple24.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple25.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple3.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple4.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple5.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple6.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple7.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple8.java | 1 +
.../eu/stratosphere/api/java/tuple/Tuple9.java | 1 +
.../api/java/tuple/TupleGenerator.java | 1 +
27 files changed, 136 insertions(+), 110 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/operators/CrossOperator.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/operators/CrossOperator.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/operators/CrossOperator.java
index 3566224..b497407 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/operators/CrossOperator.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/operators/CrossOperator.java
@@ -469,12 +469,12 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
// GENERATED FROM eu.stratosphere.api.java.tuple.TupleGenerator.
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -483,7 +483,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple1<T0>> tType = new TupleTypeInfo<Tuple1<T0>>(fTypes);
@@ -491,13 +491,13 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -506,7 +506,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple2<T0, T1>> tType = new TupleTypeInfo<Tuple2<T0, T1>>(fTypes);
@@ -514,14 +514,14 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -530,7 +530,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple3<T0, T1, T2>> tType = new TupleTypeInfo<Tuple3<T0, T1, T2>>(fTypes);
@@ -538,15 +538,15 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
* @param type3 The class of field '3' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -555,7 +555,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple4<T0, T1, T2, T3>> tType = new TupleTypeInfo<Tuple4<T0, T1, T2, T3>>(fTypes);
@@ -563,16 +563,16 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
* @param type3 The class of field '3' of the result tuples.
* @param type4 The class of field '4' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -581,7 +581,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple5<T0, T1, T2, T3, T4>> tType = new TupleTypeInfo<Tuple5<T0, T1, T2, T3, T4>>(fTypes);
@@ -589,9 +589,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -599,7 +599,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type4 The class of field '4' of the result tuples.
* @param type5 The class of field '5' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -608,7 +608,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple6<T0, T1, T2, T3, T4, T5>> tType = new TupleTypeInfo<Tuple6<T0, T1, T2, T3, T4, T5>>(fTypes);
@@ -616,9 +616,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -627,7 +627,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type5 The class of field '5' of the result tuples.
* @param type6 The class of field '6' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -636,7 +636,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple7<T0, T1, T2, T3, T4, T5, T6>> tType = new TupleTypeInfo<Tuple7<T0, T1, T2, T3, T4, T5, T6>>(fTypes);
@@ -644,9 +644,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -656,7 +656,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type6 The class of field '6' of the result tuples.
* @param type7 The class of field '7' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -665,7 +665,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple8<T0, T1, T2, T3, T4, T5, T6, T7>> tType = new TupleTypeInfo<Tuple8<T0, T1, T2, T3, T4, T5, T6, T7>>(fTypes);
@@ -673,9 +673,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -686,7 +686,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type7 The class of field '7' of the result tuples.
* @param type8 The class of field '8' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -695,7 +695,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple9<T0, T1, T2, T3, T4, T5, T6, T7, T8>> tType = new TupleTypeInfo<Tuple9<T0, T1, T2, T3, T4, T5, T6, T7, T8>>(fTypes);
@@ -703,9 +703,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -717,7 +717,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type8 The class of field '8' of the result tuples.
* @param type9 The class of field '9' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -726,7 +726,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9>> tType = new TupleTypeInfo<Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9>>(fTypes);
@@ -734,9 +734,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -749,7 +749,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type9 The class of field '9' of the result tuples.
* @param type10 The class of field '10' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -758,7 +758,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>> tType = new TupleTypeInfo<Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>>(fTypes);
@@ -766,9 +766,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -782,7 +782,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type10 The class of field '10' of the result tuples.
* @param type11 The class of field '11' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -791,7 +791,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>> tType = new TupleTypeInfo<Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>>(fTypes);
@@ -799,9 +799,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -816,7 +816,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type11 The class of field '11' of the result tuples.
* @param type12 The class of field '12' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -825,7 +825,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>> tType = new TupleTypeInfo<Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>>(fTypes);
@@ -833,9 +833,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -851,7 +851,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type12 The class of field '12' of the result tuples.
* @param type13 The class of field '13' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -860,7 +860,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>> tType = new TupleTypeInfo<Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>>(fTypes);
@@ -868,9 +868,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -887,7 +887,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type13 The class of field '13' of the result tuples.
* @param type14 The class of field '14' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -896,7 +896,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple15<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>> tType = new TupleTypeInfo<Tuple15<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>>(fTypes);
@@ -904,9 +904,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -924,7 +924,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type14 The class of field '14' of the result tuples.
* @param type15 The class of field '15' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -933,7 +933,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple16<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>> tType = new TupleTypeInfo<Tuple16<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>>(fTypes);
@@ -941,9 +941,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -962,7 +962,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type15 The class of field '15' of the result tuples.
* @param type16 The class of field '16' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -971,7 +971,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple17<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>> tType = new TupleTypeInfo<Tuple17<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>>(fTypes);
@@ -979,9 +979,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -1001,7 +1001,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type16 The class of field '16' of the result tuples.
* @param type17 The class of field '17' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -1010,7 +1010,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple18<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17>> tType = new TupleTypeInfo<Tuple18<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17>>(fTypes);
@@ -1018,9 +1018,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -1041,7 +1041,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type17 The class of field '17' of the result tuples.
* @param type18 The class of field '18' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -1050,7 +1050,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple19<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18>> tType = new TupleTypeInfo<Tuple19<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18>>(fTypes);
@@ -1058,9 +1058,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -1082,7 +1082,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type18 The class of field '18' of the result tuples.
* @param type19 The class of field '19' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -1091,7 +1091,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple20<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19>> tType = new TupleTypeInfo<Tuple20<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19>>(fTypes);
@@ -1099,9 +1099,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -1124,7 +1124,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type19 The class of field '19' of the result tuples.
* @param type20 The class of field '20' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -1133,7 +1133,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple21<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20>> tType = new TupleTypeInfo<Tuple21<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20>>(fTypes);
@@ -1141,9 +1141,9 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
}
/**
- * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
- * Requires the classes of the fields of the resulting tuples.
- *
+ * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields.
+ * Requires the classes of the fields of the resulting tuples.
+ *
* @param type0 The class of field '0' of the result tuples.
* @param type1 The class of field '1' of the result tuples.
* @param type2 The class of field '2' of the result tuples.
@@ -1167,7 +1167,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
* @param type20 The class of field '20' of the result tuples.
* @param type21 The class of field '21' of the result tuples.
* @return The projected data set.
- *
+ *
* @see Tuple
* @see DataSet
*/
@@ -1176,7 +1176,7 @@ public class CrossOperator<I1, I2, OUT> extends TwoInputUdfOperator<I1, I2, OUT,
if(types.length != this.fieldIndexes.length) {
throw new IllegalArgumentException("Numbers of projected fields and types do not match.");
}
-
+
TypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, types);
TupleTypeInfo<Tuple22<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21>> tType = new TupleTypeInfo<Tuple22<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21>>(fTypes);
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple1.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple1.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple1.java
index 66be617..7f5b7a2 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple1.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple1.java
@@ -114,6 +114,7 @@ public class Tuple1<T0> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple1)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple1 tuple = (Tuple1) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
return true;
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple10.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple10.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple10.java
index 3a8ffd9..5c06654 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple10.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple10.java
@@ -222,6 +222,7 @@ public class Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple10)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple10 tuple = (Tuple10) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple11.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple11.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple11.java
index 9cafa32..6413d82 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple11.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple11.java
@@ -234,6 +234,7 @@ public class Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> extends Tuple
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple11)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple11 tuple = (Tuple11) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple12.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple12.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple12.java
index 81204a9..0f6d366 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple12.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple12.java
@@ -246,6 +246,7 @@ public class Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> extends T
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple12)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple12 tuple = (Tuple12) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple13.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple13.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple13.java
index 5a4b02a..127dde8 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple13.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple13.java
@@ -258,6 +258,7 @@ public class Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> exte
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple13)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple13 tuple = (Tuple13) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple14.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple14.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple14.java
index 205e0b4..d3042ef 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple14.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple14.java
@@ -270,6 +270,7 @@ public class Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple14)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple14 tuple = (Tuple14) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple15.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple15.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple15.java
index 6ffaa4e..4e6205c 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple15.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple15.java
@@ -282,6 +282,7 @@ public class Tuple15<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple15)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple15 tuple = (Tuple15) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple16.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple16.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple16.java
index ed4b67d..de57619 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple16.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple16.java
@@ -294,6 +294,7 @@ public class Tuple16<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple16)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple16 tuple = (Tuple16) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple17.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple17.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple17.java
index 68760f5..6fd2554 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple17.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple17.java
@@ -306,6 +306,7 @@ public class Tuple17<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple17)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple17 tuple = (Tuple17) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple18.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple18.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple18.java
index 33ac5d9..f45e406 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple18.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple18.java
@@ -318,6 +318,7 @@ public class Tuple18<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple18)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple18 tuple = (Tuple18) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple19.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple19.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple19.java
index 4419ca3..2a867e3 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple19.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple19.java
@@ -330,6 +330,7 @@ public class Tuple19<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple19)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple19 tuple = (Tuple19) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple2.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple2.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple2.java
index d175511..d3be5cc 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple2.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple2.java
@@ -126,6 +126,7 @@ public class Tuple2<T0, T1> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple2)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple2 tuple = (Tuple2) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple20.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple20.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple20.java
index ce6c03e..a8cd9ee 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple20.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple20.java
@@ -342,6 +342,7 @@ public class Tuple20<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple20)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple20 tuple = (Tuple20) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple21.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple21.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple21.java
index 7995ced..6d0e7bb 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple21.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple21.java
@@ -354,6 +354,7 @@ public class Tuple21<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple21)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple21 tuple = (Tuple21) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple22.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple22.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple22.java
index 060f158..43d0d3f 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple22.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple22.java
@@ -366,6 +366,7 @@ public class Tuple22<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple22)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple22 tuple = (Tuple22) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple23.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple23.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple23.java
index 1910024..a71dcf6 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple23.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple23.java
@@ -378,6 +378,7 @@ public class Tuple23<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple23)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple23 tuple = (Tuple23) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple24.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple24.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple24.java
index 8ed9438..92b5467 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple24.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple24.java
@@ -390,6 +390,7 @@ public class Tuple24<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple24)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple24 tuple = (Tuple24) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple25.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple25.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple25.java
index cf0fcdd..013188d 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple25.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple25.java
@@ -402,6 +402,7 @@ public class Tuple25<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13,
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple25)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple25 tuple = (Tuple25) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple3.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple3.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple3.java
index aa6aff9..293b74c 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple3.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple3.java
@@ -138,6 +138,7 @@ public class Tuple3<T0, T1, T2> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple3)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple3 tuple = (Tuple3) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple4.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple4.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple4.java
index 3c165b0..7007896 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple4.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple4.java
@@ -150,6 +150,7 @@ public class Tuple4<T0, T1, T2, T3> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple4)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple4 tuple = (Tuple4) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple5.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple5.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple5.java
index 17d3ec7..fda4ab1 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple5.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple5.java
@@ -162,6 +162,7 @@ public class Tuple5<T0, T1, T2, T3, T4> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple5)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple5 tuple = (Tuple5) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple6.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple6.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple6.java
index 0f519aa..1cf0ad1 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple6.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple6.java
@@ -174,6 +174,7 @@ public class Tuple6<T0, T1, T2, T3, T4, T5> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple6)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple6 tuple = (Tuple6) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple7.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple7.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple7.java
index 1572083..ef08ca9 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple7.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple7.java
@@ -186,6 +186,7 @@ public class Tuple7<T0, T1, T2, T3, T4, T5, T6> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple7)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple7 tuple = (Tuple7) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple8.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple8.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple8.java
index b4fe194..76dc3d9 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple8.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple8.java
@@ -198,6 +198,7 @@ public class Tuple8<T0, T1, T2, T3, T4, T5, T6, T7> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple8)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple8 tuple = (Tuple8) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple9.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple9.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple9.java
index 0a1ce0b..23ab671 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple9.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/Tuple9.java
@@ -210,6 +210,7 @@ public class Tuple9<T0, T1, T2, T3, T4, T5, T6, T7, T8> extends Tuple {
public boolean equals(Object o) {
if(this == o) { return true; }
if (!(o instanceof Tuple9)) { return false; }
+ @SuppressWarnings("rawtypes")
Tuple9 tuple = (Tuple9) o;
if (f0 != null ? !f0.equals(tuple.f0) : tuple.f0 != null) { return false; }
if (f1 != null ? !f1.equals(tuple.f1) : tuple.f1 != null) { return false; }
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/49cd35a7/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/TupleGenerator.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/TupleGenerator.java b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/TupleGenerator.java
index 08e5cd3..c73e4cd 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/TupleGenerator.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/tuple/TupleGenerator.java
@@ -674,6 +674,7 @@ class TupleGenerator {
w.println("\tpublic boolean equals(Object o) {");
w.println("\t\tif(this == o) { return true; }");
w.println("\t\tif (!(o instanceof " + className + ")) { return false; }");
+ w.println("\t\t@SuppressWarnings(\"rawtypes\")");
w.println("\t\t" + className + " tuple = (" + className + ") o;");
for (int i = 0; i < numFields; i++) {
String field = "f" + i;