Repository: flink Updated Branches: refs/heads/release-0.10 85b73e0fd -> 712c868eb
Add copy() to Tuple base class. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c257abf7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c257abf7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c257abf7 Branch: refs/heads/release-0.10 Commit: c257abf75773b3643692261018b6794debff6001 Parents: 85b73e0 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 12:48:02 2015 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Fri Oct 23 15:46:11 2015 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/flink/api/java/tuple/Tuple.java | 8 +++++++- .../main/java/org/apache/flink/api/java/tuple/Tuple0.java | 10 ++++++++++ .../main/java/org/apache/flink/api/java/tuple/Tuple1.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple10.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple11.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple12.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple13.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple14.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple15.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple16.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple17.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple18.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple19.java | 2 ++ .../main/java/org/apache/flink/api/java/tuple/Tuple2.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple20.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple21.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple22.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple23.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple24.java | 2 ++ .../java/org/apache/flink/api/java/tuple/Tuple25.java | 2 ++ .../main/java/org/apache/flink/api/java/tuple/Tuple3.java | 2 ++ .../main/java/org/apache/flink/api/java/tuple/Tuple4.java | 2 ++ .../main/java/org/apache/flink/api/java/tuple/Tuple5.java | 2 ++ .../main/java/org/apache/flink/api/java/tuple/Tuple6.java | 2 ++ .../main/java/org/apache/flink/api/java/tuple/Tuple7.java | 2 ++ .../main/java/org/apache/flink/api/java/tuple/Tuple8.java | 2 ++ .../main/java/org/apache/flink/api/java/tuple/Tuple9.java | 2 ++ .../org/apache/flink/api/java/tuple/TupleGenerator.java | 2 ++ 28 files changed, 69 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple.java ---------------------------------------------------------------------- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple.java index 3b07aed..71b1f61 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple.java @@ -81,7 +81,13 @@ public abstract class Tuple implements java.io.Serializable { * @return The number of fields in the tuple. */ public abstract int getArity(); - + + /** + * Shallow tuple copy. + * @return A new Tuple with the same fields as this. + */ + public abstract <T extends Tuple> T copy(); + // -------------------------------------------------------------------------------------------- /** http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple0.java ---------------------------------------------------------------------- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple0.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple0.java index 1caee2a..c3386dc 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple0.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple0.java @@ -50,6 +50,16 @@ public class Tuple0 extends Tuple { throw new IndexOutOfBoundsException(String.valueOf(pos)); } + /** + * Shallow tuple copy. + * @return A new Tuple with the same fields as this. + */ + @Override + @SuppressWarnings("unchecked") + public Tuple0 copy(){ + return new Tuple0(); + } + // ------------------------------------------------------------------------------------------------- // standard utilities // ------------------------------------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple1.java ---------------------------------------------------------------------- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple1.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple1.java index 8e0e3dd..01c5501 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple1.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple1.java @@ -134,6 +134,8 @@ public class Tuple1<T0> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple1<T0> copy(){ return new Tuple1<T0>(this.f0); } http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 7dd0e62..ea24f40 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 @@ -260,6 +260,8 @@ public class Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9> copy(){ return new Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 f1eabe3..b58ae6c 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 @@ -274,6 +274,8 @@ public class Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> extends Tuple * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10> copy(){ return new Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 304ef1e..4e7defb 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 @@ -288,6 +288,8 @@ public class Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> extends T * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11> copy(){ return new Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 a546917..9543912 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 @@ -302,6 +302,8 @@ public class Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> exte * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12> copy(){ return new Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 5b0c8e4..36d508e 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 @@ -316,6 +316,8 @@ public class Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13> copy(){ return new Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 cd9230a..0d45352 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 @@ -330,6 +330,8 @@ public class Tuple15<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14> copy(){ return new Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 4f5c264..5c57ee7 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 @@ -344,6 +344,8 @@ public class Tuple16<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15> copy(){ return new Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 826ad0c..70da5bb 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 @@ -358,6 +358,8 @@ public class Tuple17<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16> copy(){ return new Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 a81bff8..c221ee6 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 @@ -372,6 +372,8 @@ public class Tuple18<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17> copy(){ return new Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 6fed55c..3d4d262 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 @@ -386,6 +386,8 @@ public class Tuple19<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18> copy(){ return new Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 51b3641..4ec930c 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 @@ -156,6 +156,8 @@ public class Tuple2<T0, T1> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple2<T0,T1> copy(){ return new Tuple2<T0,T1>(this.f0, this.f1); http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 c743cb7..8116121 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 @@ -400,6 +400,8 @@ public class Tuple20<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19> copy(){ return new Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 5749a1e..6a1aeab 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 @@ -414,6 +414,8 @@ public class Tuple21<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20> copy(){ return new Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 7a60808..5f7194b 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 @@ -428,6 +428,8 @@ public class Tuple22<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21> copy(){ return new Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 f0002fd..35c71ce 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 @@ -442,6 +442,8 @@ public class Tuple23<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22> copy(){ return new Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 874c090..5c7f91f 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 @@ -456,6 +456,8 @@ public class Tuple24<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23> copy(){ return new Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 1b86c0b..901b838 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 @@ -470,6 +470,8 @@ public class Tuple25<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24> copy(){ return new Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 36824ac..3a46222 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 @@ -162,6 +162,8 @@ public class Tuple3<T0, T1, T2> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple3<T0,T1,T2> copy(){ return new Tuple3<T0,T1,T2>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 4e24b1e..0556ad4 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 @@ -176,6 +176,8 @@ public class Tuple4<T0, T1, T2, T3> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple4<T0,T1,T2,T3> copy(){ return new Tuple4<T0,T1,T2,T3>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 c253e7e..15d3ea9 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 @@ -190,6 +190,8 @@ public class Tuple5<T0, T1, T2, T3, T4> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple5<T0,T1,T2,T3,T4> copy(){ return new Tuple5<T0,T1,T2,T3,T4>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 079db12..1d45a26 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 @@ -204,6 +204,8 @@ public class Tuple6<T0, T1, T2, T3, T4, T5> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple6<T0,T1,T2,T3,T4,T5> copy(){ return new Tuple6<T0,T1,T2,T3,T4,T5>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 b77535c..2008117 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 @@ -218,6 +218,8 @@ public class Tuple7<T0, T1, T2, T3, T4, T5, T6> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple7<T0,T1,T2,T3,T4,T5,T6> copy(){ return new Tuple7<T0,T1,T2,T3,T4,T5,T6>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 12a6e9d..7aaa265 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 @@ -232,6 +232,8 @@ public class Tuple8<T0, T1, T2, T3, T4, T5, T6, T7> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple8<T0,T1,T2,T3,T4,T5,T6,T7> copy(){ return new Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 198360d..86ea998 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 @@ -246,6 +246,8 @@ public class Tuple9<T0, T1, T2, T3, T4, T5, T6, T7, T8> extends Tuple { * Shallow tuple copy. * @return A new Tuple with the same fields as this. */ + @Override + @SuppressWarnings("unchecked") public Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8> copy(){ return new Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>(this.f0, this.f1, http://git-wip-us.apache.org/repos/asf/flink/blob/c257abf7/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 66ee25f..a2d37ce 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 @@ -727,6 +727,8 @@ class TupleGenerator { w.println("\t* Shallow tuple copy."); w.println("\t* @return A new Tuple with the same fields as this."); w.println("\t*/"); + w.println("\t@Override"); + w.println("\t@SuppressWarnings(\"unchecked\")"); w.println("\tpublic " + className + tupleTypes + " copy(){ "); w.print("\t\treturn new " + className + tupleTypes + "(this.f0");
