Add copy() to Tuple base class.

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple.java

@@ -81,7 +81,13 @@ public <T> T getFieldNotNull(int pos){
  * @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();
+
  // --------------------------------------------------------------------------------------------
 
  /**

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple0.java

@@ -50,6 +50,16 @@ public <T> void setField(T value, int pos) {
  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
  // -------------------------------------------------------------------------------------------------

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple1.java

@@ -134,6 +134,8 @@ public int hashCode() {
  * 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);
  }

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple10.java

@@ -260,6 +260,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple11.java

@@ -274,6 +274,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple12.java

@@ -288,6 +288,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple13.java

@@ -302,6 +302,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple14.java

@@ -316,6 +316,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple15.java

@@ -330,6 +330,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple16.java

@@ -344,6 +344,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java

@@ -358,6 +358,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple18.java

@@ -372,6 +372,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java

@@ -386,6 +386,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple2.java

@@ -156,6 +156,8 @@ public int hashCode() {
  * 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);

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java

@@ -400,6 +400,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java

@@ -414,6 +414,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java

@@ -428,6 +428,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java

@@ -442,6 +442,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple24.java

@@ -456,6 +456,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java

@@ -470,6 +470,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple3.java

@@ -162,6 +162,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple4.java

@@ -176,6 +176,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple5.java

@@ -190,6 +190,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple6.java

@@ -204,6 +204,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple7.java

@@ -218,6 +218,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple8.java

@@ -232,6 +232,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple9.java

@@ -246,6 +246,8 @@ public int hashCode() {
  * 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,

flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java

@@ -727,6 +727,8 @@ private static void writeTupleClass(PrintWriter w, int numFields) {
  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");