flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [24/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core
Date Tue, 02 Feb 2016 17:23:24 GMT
http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/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
deleted file mode 100644
index 15d3ea9..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple5.java
+++ /dev/null
@@ -1,214 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple;
-
-import org.apache.flink.util.StringUtils;
-
-/**
- * A tuple with 5 fields. Tuples are strongly typed; each field may be of a separate type.
- * The fields of the tuple can be accessed directly as public fields (f0, f1, ...) or via their position
- * through the {@link #getField(int)} method. The tuple field positions start at zero.
- * <p>
- * Tuples are mutable types, meaning that their fields can be re-assigned. This allows functions that work
- * with Tuples to reuse objects in order to reduce pressure on the garbage collector.
- *
- * @see Tuple
- *
- * @param <T0> The type of field 0
- * @param <T1> The type of field 1
- * @param <T2> The type of field 2
- * @param <T3> The type of field 3
- * @param <T4> The type of field 4
- */
-public class Tuple5<T0, T1, T2, T3, T4> extends Tuple {
-
-	private static final long serialVersionUID = 1L;
-
-	/** Field 0 of the tuple. */
-	public T0 f0;
-	/** Field 1 of the tuple. */
-	public T1 f1;
-	/** Field 2 of the tuple. */
-	public T2 f2;
-	/** Field 3 of the tuple. */
-	public T3 f3;
-	/** Field 4 of the tuple. */
-	public T4 f4;
-
-	/**
-	 * Creates a new tuple where all fields are null.
-	 */
-	public Tuple5() {}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 */
-	public Tuple5(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-	}
-
-	@Override
-	public int getArity() { return 5; }
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> T getField(int pos) {
-		switch(pos) {
-			case 0: return (T) this.f0;
-			case 1: return (T) this.f1;
-			case 2: return (T) this.f2;
-			case 3: return (T) this.f3;
-			case 4: return (T) this.f4;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> void setField(T value, int pos) {
-		switch(pos) {
-			case 0:
-				this.f0 = (T0) value;
-				break;
-			case 1:
-				this.f1 = (T1) value;
-				break;
-			case 2:
-				this.f2 = (T2) value;
-				break;
-			case 3:
-				this.f3 = (T3) value;
-				break;
-			case 4:
-				this.f4 = (T4) value;
-				break;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	/**
-	 * Sets new values to all fields of the tuple.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 */
-	public void setFields(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-	}
-
-
-	// -------------------------------------------------------------------------------------------------
-	// standard utilities
-	// -------------------------------------------------------------------------------------------------
-
-	/**
-	 * Creates a string representation of the tuple in the form
-	 * (f0, f1, f2, f3, f4),
-	 * where the individual fields are the value returned by calling {@link Object#toString} on that field.
-	 * @return The string representation of the tuple.
-	 */
-	@Override
-	public String toString() {
-		return "(" + StringUtils.arrayAwareToString(this.f0)
-			+ "," + StringUtils.arrayAwareToString(this.f1)
-			+ "," + StringUtils.arrayAwareToString(this.f2)
-			+ "," + StringUtils.arrayAwareToString(this.f3)
-			+ "," + StringUtils.arrayAwareToString(this.f4)
-			+ ")";
-	}
-
-	/**
-	 * Deep equality for tuples by calling equals() on the tuple members
-	 * @param o the object checked for equality
-	 * @return true if this is equal to o.
-	 */
-	@Override
-	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; }
-		if (f2 != null ? !f2.equals(tuple.f2) : tuple.f2 != null) { return false; }
-		if (f3 != null ? !f3.equals(tuple.f3) : tuple.f3 != null) { return false; }
-		if (f4 != null ? !f4.equals(tuple.f4) : tuple.f4 != null) { return false; }
-		return true;
-	}
-
-	@Override
-	public int hashCode() {
-		int result = f0 != null ? f0.hashCode() : 0;
-		result = 31 * result + (f1 != null ? f1.hashCode() : 0);
-		result = 31 * result + (f2 != null ? f2.hashCode() : 0);
-		result = 31 * result + (f3 != null ? f3.hashCode() : 0);
-		result = 31 * result + (f4 != null ? f4.hashCode() : 0);
-		return result;
-	}
-
-	/**
-	* 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,
-			this.f2,
-			this.f3,
-			this.f4);
-	}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 * This is more convenient than using the constructor, because the compiler can
-	 * infer the generic type arguments implicitly. For example:
-	 * {@code Tuple3.of(n, x, s)}
-	 * instead of
-	 * {@code new Tuple3<Integer, Double, String>(n, x, s)}
-	 */
-	public static <T0,T1,T2,T3,T4> Tuple5<T0,T1,T2,T3,T4> of(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4) {
-		return new Tuple5<T0,T1,T2,T3,T4>(value0, value1, value2, value3, value4);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/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
deleted file mode 100644
index 1d45a26..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple6.java
+++ /dev/null
@@ -1,229 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple;
-
-import org.apache.flink.util.StringUtils;
-
-/**
- * A tuple with 6 fields. Tuples are strongly typed; each field may be of a separate type.
- * The fields of the tuple can be accessed directly as public fields (f0, f1, ...) or via their position
- * through the {@link #getField(int)} method. The tuple field positions start at zero.
- * <p>
- * Tuples are mutable types, meaning that their fields can be re-assigned. This allows functions that work
- * with Tuples to reuse objects in order to reduce pressure on the garbage collector.
- *
- * @see Tuple
- *
- * @param <T0> The type of field 0
- * @param <T1> The type of field 1
- * @param <T2> The type of field 2
- * @param <T3> The type of field 3
- * @param <T4> The type of field 4
- * @param <T5> The type of field 5
- */
-public class Tuple6<T0, T1, T2, T3, T4, T5> extends Tuple {
-
-	private static final long serialVersionUID = 1L;
-
-	/** Field 0 of the tuple. */
-	public T0 f0;
-	/** Field 1 of the tuple. */
-	public T1 f1;
-	/** Field 2 of the tuple. */
-	public T2 f2;
-	/** Field 3 of the tuple. */
-	public T3 f3;
-	/** Field 4 of the tuple. */
-	public T4 f4;
-	/** Field 5 of the tuple. */
-	public T5 f5;
-
-	/**
-	 * Creates a new tuple where all fields are null.
-	 */
-	public Tuple6() {}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 * @param value5 The value for field 5
-	 */
-	public Tuple6(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-		this.f5 = value5;
-	}
-
-	@Override
-	public int getArity() { return 6; }
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> T getField(int pos) {
-		switch(pos) {
-			case 0: return (T) this.f0;
-			case 1: return (T) this.f1;
-			case 2: return (T) this.f2;
-			case 3: return (T) this.f3;
-			case 4: return (T) this.f4;
-			case 5: return (T) this.f5;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> void setField(T value, int pos) {
-		switch(pos) {
-			case 0:
-				this.f0 = (T0) value;
-				break;
-			case 1:
-				this.f1 = (T1) value;
-				break;
-			case 2:
-				this.f2 = (T2) value;
-				break;
-			case 3:
-				this.f3 = (T3) value;
-				break;
-			case 4:
-				this.f4 = (T4) value;
-				break;
-			case 5:
-				this.f5 = (T5) value;
-				break;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	/**
-	 * Sets new values to all fields of the tuple.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 * @param value5 The value for field 5
-	 */
-	public void setFields(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-		this.f5 = value5;
-	}
-
-
-	// -------------------------------------------------------------------------------------------------
-	// standard utilities
-	// -------------------------------------------------------------------------------------------------
-
-	/**
-	 * Creates a string representation of the tuple in the form
-	 * (f0, f1, f2, f3, f4, f5),
-	 * where the individual fields are the value returned by calling {@link Object#toString} on that field.
-	 * @return The string representation of the tuple.
-	 */
-	@Override
-	public String toString() {
-		return "(" + StringUtils.arrayAwareToString(this.f0)
-			+ "," + StringUtils.arrayAwareToString(this.f1)
-			+ "," + StringUtils.arrayAwareToString(this.f2)
-			+ "," + StringUtils.arrayAwareToString(this.f3)
-			+ "," + StringUtils.arrayAwareToString(this.f4)
-			+ "," + StringUtils.arrayAwareToString(this.f5)
-			+ ")";
-	}
-
-	/**
-	 * Deep equality for tuples by calling equals() on the tuple members
-	 * @param o the object checked for equality
-	 * @return true if this is equal to o.
-	 */
-	@Override
-	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; }
-		if (f2 != null ? !f2.equals(tuple.f2) : tuple.f2 != null) { return false; }
-		if (f3 != null ? !f3.equals(tuple.f3) : tuple.f3 != null) { return false; }
-		if (f4 != null ? !f4.equals(tuple.f4) : tuple.f4 != null) { return false; }
-		if (f5 != null ? !f5.equals(tuple.f5) : tuple.f5 != null) { return false; }
-		return true;
-	}
-
-	@Override
-	public int hashCode() {
-		int result = f0 != null ? f0.hashCode() : 0;
-		result = 31 * result + (f1 != null ? f1.hashCode() : 0);
-		result = 31 * result + (f2 != null ? f2.hashCode() : 0);
-		result = 31 * result + (f3 != null ? f3.hashCode() : 0);
-		result = 31 * result + (f4 != null ? f4.hashCode() : 0);
-		result = 31 * result + (f5 != null ? f5.hashCode() : 0);
-		return result;
-	}
-
-	/**
-	* 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,
-			this.f2,
-			this.f3,
-			this.f4,
-			this.f5);
-	}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 * This is more convenient than using the constructor, because the compiler can
-	 * infer the generic type arguments implicitly. For example:
-	 * {@code Tuple3.of(n, x, s)}
-	 * instead of
-	 * {@code new Tuple3<Integer, Double, String>(n, x, s)}
-	 */
-	public static <T0,T1,T2,T3,T4,T5> Tuple6<T0,T1,T2,T3,T4,T5> of(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5) {
-		return new Tuple6<T0,T1,T2,T3,T4,T5>(value0, value1, value2, value3, value4, value5);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/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
deleted file mode 100644
index 2008117..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple7.java
+++ /dev/null
@@ -1,244 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple;
-
-import org.apache.flink.util.StringUtils;
-
-/**
- * A tuple with 7 fields. Tuples are strongly typed; each field may be of a separate type.
- * The fields of the tuple can be accessed directly as public fields (f0, f1, ...) or via their position
- * through the {@link #getField(int)} method. The tuple field positions start at zero.
- * <p>
- * Tuples are mutable types, meaning that their fields can be re-assigned. This allows functions that work
- * with Tuples to reuse objects in order to reduce pressure on the garbage collector.
- *
- * @see Tuple
- *
- * @param <T0> The type of field 0
- * @param <T1> The type of field 1
- * @param <T2> The type of field 2
- * @param <T3> The type of field 3
- * @param <T4> The type of field 4
- * @param <T5> The type of field 5
- * @param <T6> The type of field 6
- */
-public class Tuple7<T0, T1, T2, T3, T4, T5, T6> extends Tuple {
-
-	private static final long serialVersionUID = 1L;
-
-	/** Field 0 of the tuple. */
-	public T0 f0;
-	/** Field 1 of the tuple. */
-	public T1 f1;
-	/** Field 2 of the tuple. */
-	public T2 f2;
-	/** Field 3 of the tuple. */
-	public T3 f3;
-	/** Field 4 of the tuple. */
-	public T4 f4;
-	/** Field 5 of the tuple. */
-	public T5 f5;
-	/** Field 6 of the tuple. */
-	public T6 f6;
-
-	/**
-	 * Creates a new tuple where all fields are null.
-	 */
-	public Tuple7() {}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 * @param value5 The value for field 5
-	 * @param value6 The value for field 6
-	 */
-	public Tuple7(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-		this.f5 = value5;
-		this.f6 = value6;
-	}
-
-	@Override
-	public int getArity() { return 7; }
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> T getField(int pos) {
-		switch(pos) {
-			case 0: return (T) this.f0;
-			case 1: return (T) this.f1;
-			case 2: return (T) this.f2;
-			case 3: return (T) this.f3;
-			case 4: return (T) this.f4;
-			case 5: return (T) this.f5;
-			case 6: return (T) this.f6;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> void setField(T value, int pos) {
-		switch(pos) {
-			case 0:
-				this.f0 = (T0) value;
-				break;
-			case 1:
-				this.f1 = (T1) value;
-				break;
-			case 2:
-				this.f2 = (T2) value;
-				break;
-			case 3:
-				this.f3 = (T3) value;
-				break;
-			case 4:
-				this.f4 = (T4) value;
-				break;
-			case 5:
-				this.f5 = (T5) value;
-				break;
-			case 6:
-				this.f6 = (T6) value;
-				break;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	/**
-	 * Sets new values to all fields of the tuple.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 * @param value5 The value for field 5
-	 * @param value6 The value for field 6
-	 */
-	public void setFields(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-		this.f5 = value5;
-		this.f6 = value6;
-	}
-
-
-	// -------------------------------------------------------------------------------------------------
-	// standard utilities
-	// -------------------------------------------------------------------------------------------------
-
-	/**
-	 * Creates a string representation of the tuple in the form
-	 * (f0, f1, f2, f3, f4, f5, f6),
-	 * where the individual fields are the value returned by calling {@link Object#toString} on that field.
-	 * @return The string representation of the tuple.
-	 */
-	@Override
-	public String toString() {
-		return "(" + StringUtils.arrayAwareToString(this.f0)
-			+ "," + StringUtils.arrayAwareToString(this.f1)
-			+ "," + StringUtils.arrayAwareToString(this.f2)
-			+ "," + StringUtils.arrayAwareToString(this.f3)
-			+ "," + StringUtils.arrayAwareToString(this.f4)
-			+ "," + StringUtils.arrayAwareToString(this.f5)
-			+ "," + StringUtils.arrayAwareToString(this.f6)
-			+ ")";
-	}
-
-	/**
-	 * Deep equality for tuples by calling equals() on the tuple members
-	 * @param o the object checked for equality
-	 * @return true if this is equal to o.
-	 */
-	@Override
-	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; }
-		if (f2 != null ? !f2.equals(tuple.f2) : tuple.f2 != null) { return false; }
-		if (f3 != null ? !f3.equals(tuple.f3) : tuple.f3 != null) { return false; }
-		if (f4 != null ? !f4.equals(tuple.f4) : tuple.f4 != null) { return false; }
-		if (f5 != null ? !f5.equals(tuple.f5) : tuple.f5 != null) { return false; }
-		if (f6 != null ? !f6.equals(tuple.f6) : tuple.f6 != null) { return false; }
-		return true;
-	}
-
-	@Override
-	public int hashCode() {
-		int result = f0 != null ? f0.hashCode() : 0;
-		result = 31 * result + (f1 != null ? f1.hashCode() : 0);
-		result = 31 * result + (f2 != null ? f2.hashCode() : 0);
-		result = 31 * result + (f3 != null ? f3.hashCode() : 0);
-		result = 31 * result + (f4 != null ? f4.hashCode() : 0);
-		result = 31 * result + (f5 != null ? f5.hashCode() : 0);
-		result = 31 * result + (f6 != null ? f6.hashCode() : 0);
-		return result;
-	}
-
-	/**
-	* 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,
-			this.f2,
-			this.f3,
-			this.f4,
-			this.f5,
-			this.f6);
-	}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 * This is more convenient than using the constructor, because the compiler can
-	 * infer the generic type arguments implicitly. For example:
-	 * {@code Tuple3.of(n, x, s)}
-	 * instead of
-	 * {@code new Tuple3<Integer, Double, String>(n, x, s)}
-	 */
-	public static <T0,T1,T2,T3,T4,T5,T6> Tuple7<T0,T1,T2,T3,T4,T5,T6> of(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6) {
-		return new Tuple7<T0,T1,T2,T3,T4,T5,T6>(value0, value1, value2, value3, value4, value5, value6);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/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
deleted file mode 100644
index 7aaa265..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple8.java
+++ /dev/null
@@ -1,259 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple;
-
-import org.apache.flink.util.StringUtils;
-
-/**
- * A tuple with 8 fields. Tuples are strongly typed; each field may be of a separate type.
- * The fields of the tuple can be accessed directly as public fields (f0, f1, ...) or via their position
- * through the {@link #getField(int)} method. The tuple field positions start at zero.
- * <p>
- * Tuples are mutable types, meaning that their fields can be re-assigned. This allows functions that work
- * with Tuples to reuse objects in order to reduce pressure on the garbage collector.
- *
- * @see Tuple
- *
- * @param <T0> The type of field 0
- * @param <T1> The type of field 1
- * @param <T2> The type of field 2
- * @param <T3> The type of field 3
- * @param <T4> The type of field 4
- * @param <T5> The type of field 5
- * @param <T6> The type of field 6
- * @param <T7> The type of field 7
- */
-public class Tuple8<T0, T1, T2, T3, T4, T5, T6, T7> extends Tuple {
-
-	private static final long serialVersionUID = 1L;
-
-	/** Field 0 of the tuple. */
-	public T0 f0;
-	/** Field 1 of the tuple. */
-	public T1 f1;
-	/** Field 2 of the tuple. */
-	public T2 f2;
-	/** Field 3 of the tuple. */
-	public T3 f3;
-	/** Field 4 of the tuple. */
-	public T4 f4;
-	/** Field 5 of the tuple. */
-	public T5 f5;
-	/** Field 6 of the tuple. */
-	public T6 f6;
-	/** Field 7 of the tuple. */
-	public T7 f7;
-
-	/**
-	 * Creates a new tuple where all fields are null.
-	 */
-	public Tuple8() {}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 * @param value5 The value for field 5
-	 * @param value6 The value for field 6
-	 * @param value7 The value for field 7
-	 */
-	public Tuple8(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-		this.f5 = value5;
-		this.f6 = value6;
-		this.f7 = value7;
-	}
-
-	@Override
-	public int getArity() { return 8; }
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> T getField(int pos) {
-		switch(pos) {
-			case 0: return (T) this.f0;
-			case 1: return (T) this.f1;
-			case 2: return (T) this.f2;
-			case 3: return (T) this.f3;
-			case 4: return (T) this.f4;
-			case 5: return (T) this.f5;
-			case 6: return (T) this.f6;
-			case 7: return (T) this.f7;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> void setField(T value, int pos) {
-		switch(pos) {
-			case 0:
-				this.f0 = (T0) value;
-				break;
-			case 1:
-				this.f1 = (T1) value;
-				break;
-			case 2:
-				this.f2 = (T2) value;
-				break;
-			case 3:
-				this.f3 = (T3) value;
-				break;
-			case 4:
-				this.f4 = (T4) value;
-				break;
-			case 5:
-				this.f5 = (T5) value;
-				break;
-			case 6:
-				this.f6 = (T6) value;
-				break;
-			case 7:
-				this.f7 = (T7) value;
-				break;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	/**
-	 * Sets new values to all fields of the tuple.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 * @param value5 The value for field 5
-	 * @param value6 The value for field 6
-	 * @param value7 The value for field 7
-	 */
-	public void setFields(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-		this.f5 = value5;
-		this.f6 = value6;
-		this.f7 = value7;
-	}
-
-
-	// -------------------------------------------------------------------------------------------------
-	// standard utilities
-	// -------------------------------------------------------------------------------------------------
-
-	/**
-	 * Creates a string representation of the tuple in the form
-	 * (f0, f1, f2, f3, f4, f5, f6, f7),
-	 * where the individual fields are the value returned by calling {@link Object#toString} on that field.
-	 * @return The string representation of the tuple.
-	 */
-	@Override
-	public String toString() {
-		return "(" + StringUtils.arrayAwareToString(this.f0)
-			+ "," + StringUtils.arrayAwareToString(this.f1)
-			+ "," + StringUtils.arrayAwareToString(this.f2)
-			+ "," + StringUtils.arrayAwareToString(this.f3)
-			+ "," + StringUtils.arrayAwareToString(this.f4)
-			+ "," + StringUtils.arrayAwareToString(this.f5)
-			+ "," + StringUtils.arrayAwareToString(this.f6)
-			+ "," + StringUtils.arrayAwareToString(this.f7)
-			+ ")";
-	}
-
-	/**
-	 * Deep equality for tuples by calling equals() on the tuple members
-	 * @param o the object checked for equality
-	 * @return true if this is equal to o.
-	 */
-	@Override
-	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; }
-		if (f2 != null ? !f2.equals(tuple.f2) : tuple.f2 != null) { return false; }
-		if (f3 != null ? !f3.equals(tuple.f3) : tuple.f3 != null) { return false; }
-		if (f4 != null ? !f4.equals(tuple.f4) : tuple.f4 != null) { return false; }
-		if (f5 != null ? !f5.equals(tuple.f5) : tuple.f5 != null) { return false; }
-		if (f6 != null ? !f6.equals(tuple.f6) : tuple.f6 != null) { return false; }
-		if (f7 != null ? !f7.equals(tuple.f7) : tuple.f7 != null) { return false; }
-		return true;
-	}
-
-	@Override
-	public int hashCode() {
-		int result = f0 != null ? f0.hashCode() : 0;
-		result = 31 * result + (f1 != null ? f1.hashCode() : 0);
-		result = 31 * result + (f2 != null ? f2.hashCode() : 0);
-		result = 31 * result + (f3 != null ? f3.hashCode() : 0);
-		result = 31 * result + (f4 != null ? f4.hashCode() : 0);
-		result = 31 * result + (f5 != null ? f5.hashCode() : 0);
-		result = 31 * result + (f6 != null ? f6.hashCode() : 0);
-		result = 31 * result + (f7 != null ? f7.hashCode() : 0);
-		return result;
-	}
-
-	/**
-	* 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,
-			this.f2,
-			this.f3,
-			this.f4,
-			this.f5,
-			this.f6,
-			this.f7);
-	}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 * This is more convenient than using the constructor, because the compiler can
-	 * infer the generic type arguments implicitly. For example:
-	 * {@code Tuple3.of(n, x, s)}
-	 * instead of
-	 * {@code new Tuple3<Integer, Double, String>(n, x, s)}
-	 */
-	public static <T0,T1,T2,T3,T4,T5,T6,T7> Tuple8<T0,T1,T2,T3,T4,T5,T6,T7> of(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7) {
-		return new Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>(value0, value1, value2, value3, value4, value5, value6, value7);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/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
deleted file mode 100644
index 86ea998..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/Tuple9.java
+++ /dev/null
@@ -1,274 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple;
-
-import org.apache.flink.util.StringUtils;
-
-/**
- * A tuple with 9 fields. Tuples are strongly typed; each field may be of a separate type.
- * The fields of the tuple can be accessed directly as public fields (f0, f1, ...) or via their position
- * through the {@link #getField(int)} method. The tuple field positions start at zero.
- * <p>
- * Tuples are mutable types, meaning that their fields can be re-assigned. This allows functions that work
- * with Tuples to reuse objects in order to reduce pressure on the garbage collector.
- *
- * @see Tuple
- *
- * @param <T0> The type of field 0
- * @param <T1> The type of field 1
- * @param <T2> The type of field 2
- * @param <T3> The type of field 3
- * @param <T4> The type of field 4
- * @param <T5> The type of field 5
- * @param <T6> The type of field 6
- * @param <T7> The type of field 7
- * @param <T8> The type of field 8
- */
-public class Tuple9<T0, T1, T2, T3, T4, T5, T6, T7, T8> extends Tuple {
-
-	private static final long serialVersionUID = 1L;
-
-	/** Field 0 of the tuple. */
-	public T0 f0;
-	/** Field 1 of the tuple. */
-	public T1 f1;
-	/** Field 2 of the tuple. */
-	public T2 f2;
-	/** Field 3 of the tuple. */
-	public T3 f3;
-	/** Field 4 of the tuple. */
-	public T4 f4;
-	/** Field 5 of the tuple. */
-	public T5 f5;
-	/** Field 6 of the tuple. */
-	public T6 f6;
-	/** Field 7 of the tuple. */
-	public T7 f7;
-	/** Field 8 of the tuple. */
-	public T8 f8;
-
-	/**
-	 * Creates a new tuple where all fields are null.
-	 */
-	public Tuple9() {}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 * @param value5 The value for field 5
-	 * @param value6 The value for field 6
-	 * @param value7 The value for field 7
-	 * @param value8 The value for field 8
-	 */
-	public Tuple9(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7, T8 value8) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-		this.f5 = value5;
-		this.f6 = value6;
-		this.f7 = value7;
-		this.f8 = value8;
-	}
-
-	@Override
-	public int getArity() { return 9; }
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> T getField(int pos) {
-		switch(pos) {
-			case 0: return (T) this.f0;
-			case 1: return (T) this.f1;
-			case 2: return (T) this.f2;
-			case 3: return (T) this.f3;
-			case 4: return (T) this.f4;
-			case 5: return (T) this.f5;
-			case 6: return (T) this.f6;
-			case 7: return (T) this.f7;
-			case 8: return (T) this.f8;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	@Override
-	@SuppressWarnings("unchecked")
-	public <T> void setField(T value, int pos) {
-		switch(pos) {
-			case 0:
-				this.f0 = (T0) value;
-				break;
-			case 1:
-				this.f1 = (T1) value;
-				break;
-			case 2:
-				this.f2 = (T2) value;
-				break;
-			case 3:
-				this.f3 = (T3) value;
-				break;
-			case 4:
-				this.f4 = (T4) value;
-				break;
-			case 5:
-				this.f5 = (T5) value;
-				break;
-			case 6:
-				this.f6 = (T6) value;
-				break;
-			case 7:
-				this.f7 = (T7) value;
-				break;
-			case 8:
-				this.f8 = (T8) value;
-				break;
-			default: throw new IndexOutOfBoundsException(String.valueOf(pos));
-		}
-	}
-
-	/**
-	 * Sets new values to all fields of the tuple.
-	 *
-	 * @param value0 The value for field 0
-	 * @param value1 The value for field 1
-	 * @param value2 The value for field 2
-	 * @param value3 The value for field 3
-	 * @param value4 The value for field 4
-	 * @param value5 The value for field 5
-	 * @param value6 The value for field 6
-	 * @param value7 The value for field 7
-	 * @param value8 The value for field 8
-	 */
-	public void setFields(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7, T8 value8) {
-		this.f0 = value0;
-		this.f1 = value1;
-		this.f2 = value2;
-		this.f3 = value3;
-		this.f4 = value4;
-		this.f5 = value5;
-		this.f6 = value6;
-		this.f7 = value7;
-		this.f8 = value8;
-	}
-
-
-	// -------------------------------------------------------------------------------------------------
-	// standard utilities
-	// -------------------------------------------------------------------------------------------------
-
-	/**
-	 * Creates a string representation of the tuple in the form
-	 * (f0, f1, f2, f3, f4, f5, f6, f7, f8),
-	 * where the individual fields are the value returned by calling {@link Object#toString} on that field.
-	 * @return The string representation of the tuple.
-	 */
-	@Override
-	public String toString() {
-		return "(" + StringUtils.arrayAwareToString(this.f0)
-			+ "," + StringUtils.arrayAwareToString(this.f1)
-			+ "," + StringUtils.arrayAwareToString(this.f2)
-			+ "," + StringUtils.arrayAwareToString(this.f3)
-			+ "," + StringUtils.arrayAwareToString(this.f4)
-			+ "," + StringUtils.arrayAwareToString(this.f5)
-			+ "," + StringUtils.arrayAwareToString(this.f6)
-			+ "," + StringUtils.arrayAwareToString(this.f7)
-			+ "," + StringUtils.arrayAwareToString(this.f8)
-			+ ")";
-	}
-
-	/**
-	 * Deep equality for tuples by calling equals() on the tuple members
-	 * @param o the object checked for equality
-	 * @return true if this is equal to o.
-	 */
-	@Override
-	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; }
-		if (f2 != null ? !f2.equals(tuple.f2) : tuple.f2 != null) { return false; }
-		if (f3 != null ? !f3.equals(tuple.f3) : tuple.f3 != null) { return false; }
-		if (f4 != null ? !f4.equals(tuple.f4) : tuple.f4 != null) { return false; }
-		if (f5 != null ? !f5.equals(tuple.f5) : tuple.f5 != null) { return false; }
-		if (f6 != null ? !f6.equals(tuple.f6) : tuple.f6 != null) { return false; }
-		if (f7 != null ? !f7.equals(tuple.f7) : tuple.f7 != null) { return false; }
-		if (f8 != null ? !f8.equals(tuple.f8) : tuple.f8 != null) { return false; }
-		return true;
-	}
-
-	@Override
-	public int hashCode() {
-		int result = f0 != null ? f0.hashCode() : 0;
-		result = 31 * result + (f1 != null ? f1.hashCode() : 0);
-		result = 31 * result + (f2 != null ? f2.hashCode() : 0);
-		result = 31 * result + (f3 != null ? f3.hashCode() : 0);
-		result = 31 * result + (f4 != null ? f4.hashCode() : 0);
-		result = 31 * result + (f5 != null ? f5.hashCode() : 0);
-		result = 31 * result + (f6 != null ? f6.hashCode() : 0);
-		result = 31 * result + (f7 != null ? f7.hashCode() : 0);
-		result = 31 * result + (f8 != null ? f8.hashCode() : 0);
-		return result;
-	}
-
-	/**
-	* 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,
-			this.f2,
-			this.f3,
-			this.f4,
-			this.f5,
-			this.f6,
-			this.f7,
-			this.f8);
-	}
-
-	/**
-	 * Creates a new tuple and assigns the given values to the tuple's fields.
-	 * This is more convenient than using the constructor, because the compiler can
-	 * infer the generic type arguments implicitly. For example:
-	 * {@code Tuple3.of(n, x, s)}
-	 * instead of
-	 * {@code new Tuple3<Integer, Double, String>(n, x, s)}
-	 */
-	public static <T0,T1,T2,T3,T4,T5,T6,T7,T8> Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8> of(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7, T8 value8) {
-		return new Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>(value0, value1, value2, value3, value4, value5, value6, value7, value8);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/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
deleted file mode 100644
index 70b9393..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java
+++ /dev/null
@@ -1,879 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.api.java.tuple;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.io.PrintWriter;
-import java.util.Scanner;
-
-import com.google.common.base.Charsets;
-import com.google.common.io.Files;
-
-/**
- * Source code generator for tuple classes and classes which depend on the arity of tuples.
- */
-class TupleGenerator {
-
-	// Parameters for tuple classes
-
-	private static final String ROOT_DIRECTORY = "./src/main/java";
-
-	private static final String PACKAGE = "org.apache.flink.api.java.tuple";
-
-	private static final String BUILDER_SUFFIX = "builder";
-
-	private static final String GEN_TYPE_PREFIX = "T";
-
-	// Parameters for tuple-dependent classes
-	private static final String BEGIN_INDICATOR = "BEGIN_OF_TUPLE_DEPENDENT_CODE";
-
-	private static final String END_INDICATOR = "END_OF_TUPLE_DEPENDENT_CODE";
-
-	// Parameters for CsvReader
-	private static final String CSV_READER_PACKAGE = "org.apache.flink.api.java.io";
-
-	private static final String CSV_READER_CLASSNAME = "CsvReader";
-
-	// Parameters for TupleTypeInfo
-	private static final String TUPLE_PACKAGE = "org.apache.flink.api.java.tuple";
-
-	private static final String TUPLE_CLASSNAME = "Tuple";
-
-	// Parameters for ProjectOperator
-	private static final String PROJECT_OPERATOR_PACKAGE = "org.apache.flink.api.java.operators";
-
-	private static final String PROJECT_OPERATOR_CLASSNAME = "ProjectOperator";
-
-	// Parameters for JoinOperator
-	private static final String JOIN_OPERATOR_PACKAGE = "org.apache.flink.api.java.operators";
-
-	private static final String JOIN_OPERATOR_CLASSNAME = "JoinOperator";
-
-	// parameters for CrossOperator
-	private static final String CROSS_OPERATOR_PACKAGE = "org.apache.flink.api.java.operators";
-
-	private static final String CROSS_OPERATOR_CLASSNAME = "CrossOperator";
-
-	// min. and max. tuple arity
-	private static final int FIRST = 1;
-
-	private static final int LAST = 25;
-
-	public static void main(String[] args) throws Exception {
-		System.err.println("Current directory "+System.getProperty("user.dir"));
-		String rootDir = ROOT_DIRECTORY;
-		if(args.length > 0) {
-			rootDir = args[0] + "/" + ROOT_DIRECTORY;
-		}
-		System.err.println("Using root directory: "+rootDir);
-		File root = new File(rootDir);
-
-		createTupleClasses(root);
-
-		createTupleBuilderClasses(root);
-
-		modifyCsvReader(root);
-
-		modifyTupleType(root);
-
-		modifyProjectOperator(root);
-
-		modifyJoinProjectOperator(root);
-
-		modifyCrossProjectOperator(root);
-
-	}
-
-	private static File getPackage(File root, String packageString) {
-		File dir = new File(root, packageString.replace('.', '/'));
-		if (!dir.exists() && dir.isDirectory()) {
-			System.err.println("None existent directory: " + dir.getAbsolutePath());
-			System.exit(1);
-		}
-		return dir;
-	}
-
-	private static void insertCodeIntoFile(String code, File file) throws IOException {
-		String fileContent = Files.toString(file, Charsets.UTF_8);
-		Scanner s = new Scanner(fileContent);
-
-		StringBuilder sb = new StringBuilder();
-		String line = null;
-
-		boolean indicatorFound = false;
-
-		// add file beginning
-		while (s.hasNextLine() && (line = s.nextLine()) != null) {
-			sb.append(line + "\n");
-			if (line.contains(BEGIN_INDICATOR)) {
-				indicatorFound = true;
-				break;
-			}
-		}
-
-		if(!indicatorFound) {
-			System.out.println("No indicator found in '" + file + "'. Will skip code generation.");
-			s.close();
-			return;
-		}
-
-		// add generator signature
-		sb.append("\t// GENERATED FROM " + TupleGenerator.class.getName() + ".\n");
-
-		// add tuple dependent code
-		sb.append(code + "\n");
-
-		// skip generated code
-		while (s.hasNextLine() && (line = s.nextLine()) != null) {
-			if (line.contains(END_INDICATOR)) {
-				sb.append(line + "\n");
-				break;
-			}
-		}
-
-		// add file ending
-		while (s.hasNextLine() && (line = s.nextLine()) != null) {
-			sb.append(line + "\n");
-		}
-		s.close();
-		Files.write(sb.toString(), file, Charsets.UTF_8);
-	}
-
-	private static void modifyCrossProjectOperator(File root) throws IOException {
-		// generate code
-		StringBuilder sb = new StringBuilder();
-		
-		// method begin
-		sb.append("\n");
-		
-		// method comment
-		sb.append("\t\t/**\n");
-		sb.append("\t\t * Chooses a projectTupleX according to the length of\n");
-		sb.append("\t\t * {@link org.apache.flink.api.java.operators.CrossOperator.CrossProjection#fieldIndexes} \n");
-		sb.append("\t\t * \n");
-		sb.append("\t\t * @return The projected DataSet.\n");
-		sb.append("\t\t */\n");
-		
-		// method signature
-		sb.append("\t\t@SuppressWarnings(\"unchecked\")\n");
-		sb.append("\t\tpublic <OUT extends Tuple> ProjectCross<I1, I2, OUT> projectTupleX() {\n");
-		sb.append("\t\t\tProjectCross<I1, I2, OUT> projectionCross = null;\n\n");
-		sb.append("\t\t\tswitch (fieldIndexes.length) {\n");
-		for (int numFields = FIRST; numFields <= LAST; numFields++) {
-			sb.append("\t\t\tcase " + numFields +":" + " projectionCross = (ProjectCross<I1, I2, OUT>) projectTuple"+numFields+"(); break;\n");	
-		}
-		sb.append("\t\t\tdefault: throw new IllegalStateException(\"Excessive arity in tuple.\");\n");
-		sb.append("\t\t\t}\n\n");
-		sb.append("\t\t\treturn projectionCross;\n");
-		
-		// method end
-		sb.append("\t\t}\n");
-		
-		for (int numFields = FIRST; numFields <= LAST; numFields++) {
-
-			// method begin
-			sb.append("\n");
-
-			// method comment
-			sb.append("\t\t/**\n");
-			sb.append("\t\t * Projects a pair of crossed elements to a {@link Tuple} with the previously selected fields. \n");
-			sb.append("\t\t * \n");
-			sb.append("\t\t * @return The projected data set.\n");
-			sb.append("\t\t * \n");
-			sb.append("\t\t * @see Tuple\n");
-			sb.append("\t\t * @see DataSet\n");
-			sb.append("\t\t */\n");
-
-			// method signature
-			sb.append("\t\tpublic <");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append("> ProjectCross<I1, I2, Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> projectTuple"+numFields+"(");
-			sb.append(") {\n");
-
-			// extract field types
-			sb.append("\t\t\tTypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes);\n");
-
-			// create new tuple type info
-			sb.append("\t\t\tTupleTypeInfo<Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> tType = new TupleTypeInfo<Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(fTypes);\n\n");
-
-			// create and return new project operator
-			sb.append("\t\t\treturn new ProjectCross<I1, I2, Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(this.ds1, this.ds2, this.fieldIndexes, this.isFieldInFirst, tType, this, hint);\n");
-
-			// method end
-			sb.append("\t\t}\n");
-
-		}
-
-		// insert code into file
-		File dir = getPackage(root, CROSS_OPERATOR_PACKAGE);
-		File projectOperatorClass = new File(dir, CROSS_OPERATOR_CLASSNAME + ".java");
-		insertCodeIntoFile(sb.toString(), projectOperatorClass);
-	}
-
-	private static void modifyProjectOperator(File root) throws IOException {
-		// generate code
-		StringBuilder sb = new StringBuilder();
-		
-		// method begin
-		sb.append("\n");
-		
-		// method comment
-		sb.append("\t\t/**\n");
-		sb.append("\t\t * Chooses a projectTupleX according to the length of\n");
-		sb.append("\t\t * {@link org.apache.flink.api.java.operators.ProjectOperator.Projection#fieldIndexes} \n");
-		sb.append("\t\t * \n");
-		sb.append("\t\t * @return The projected DataSet.\n");
-		sb.append("\t\t * \n");
-		sb.append("\t\t * @see org.apache.flink.api.java.operators.ProjectOperator.Projection\n");
-		sb.append("\t\t */\n");
-		
-		// method signature
-		sb.append("\t\t@SuppressWarnings(\"unchecked\")\n");
-		sb.append("\t\tpublic <OUT extends Tuple> ProjectOperator<T, OUT> projectTupleX() {\n");
-		sb.append("\t\t\tProjectOperator<T, OUT> projOperator;\n\n");
-		sb.append("\t\t\tswitch (fieldIndexes.length) {\n");
-		for (int numFields = FIRST; numFields <= LAST; numFields++) {
-			sb.append("\t\t\tcase " + numFields +":" + " projOperator = (ProjectOperator<T, OUT>) projectTuple"+numFields+"(); break;\n");	
-		}
-		sb.append("\t\t\tdefault: throw new IllegalStateException(\"Excessive arity in tuple.\");\n");
-		sb.append("\t\t\t}\n\n");
-		sb.append("\t\t\treturn projOperator;\n");
-		
-		// method end
-		sb.append("\t\t}\n");
-		
-		for (int numFields = FIRST; numFields <= LAST; numFields++) {
-
-			// method begin
-			sb.append("\n");
-
-			// method comment
-			sb.append("\t\t/**\n");
-			sb.append("\t\t * Projects a {@link Tuple} {@link DataSet} to the previously selected fields. \n");
-			sb.append("\t\t * \n");
-			sb.append("\t\t * @return The projected DataSet.\n");
-			sb.append("\t\t * \n");
-			sb.append("\t\t * @see Tuple\n");
-			sb.append("\t\t * @see DataSet\n");
-			sb.append("\t\t */\n");
-
-			// method signature
-			sb.append("\t\tpublic <");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append("> ProjectOperator<T, Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> projectTuple"+numFields+"(");
-			sb.append(") {\n");
-			
-			// extract field types
-			sb.append("\t\t\tTypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes, ds.getType());\n");
-
-			// create new tuple type info
-			sb.append("\t\t\tTupleTypeInfo<Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> tType = new TupleTypeInfo<Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(fTypes);\n\n");
-
-			// create and return new project operator
-			sb.append("\t\t\treturn new ProjectOperator<T, Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(this.ds, this.fieldIndexes, tType);\n");
-
-			// method end
-			sb.append("\t\t}\n");
-
-		}
-
-		// insert code into file
-		File dir = getPackage(root, PROJECT_OPERATOR_PACKAGE);
-		File projectOperatorClass = new File(dir, PROJECT_OPERATOR_CLASSNAME + ".java");
-		insertCodeIntoFile(sb.toString(), projectOperatorClass);
-	}
-
-	private static void modifyJoinProjectOperator(File root) throws IOException {
-		// generate code
-		StringBuilder sb = new StringBuilder();
-		
-		// method begin
-		sb.append("\n");
-		
-		// method comment
-		sb.append("\t\t/**\n");
-		sb.append("\t\t * Chooses a projectTupleX according to the length of\n");
-		sb.append("\t\t * {@link org.apache.flink.api.java.operators.JoinOperator.JoinProjection#fieldIndexes}\n");
-		sb.append("\t\t * \n");
-		sb.append("\t\t * @return The projected DataSet.\n");
-		sb.append("\t\t * \n");
-		sb.append("\t\t * @see org.apache.flink.api.java.operators.JoinOperator.ProjectJoin\n");
-		sb.append("\t\t */\n");
-		
-		// method signature
-		sb.append("\t\t@SuppressWarnings(\"unchecked\")\n");
-		sb.append("\t\tpublic <OUT extends Tuple> ProjectJoin<I1, I2, OUT> projectTupleX() {\n");
-		sb.append("\t\t\tProjectJoin<I1, I2, OUT> projectJoin = null;\n\n");
-		sb.append("\t\t\tswitch (fieldIndexes.length) {\n");
-		for (int numFields = FIRST; numFields <= LAST; numFields++) {
-			sb.append("\t\t\tcase " + numFields +":" + " projectJoin = (ProjectJoin<I1, I2, OUT>) projectTuple"+numFields+"(); break;\n");	
-		}
-		sb.append("\t\t\tdefault: throw new IllegalStateException(\"Excessive arity in tuple.\");\n");
-		sb.append("\t\t\t}\n\n");
-		sb.append("\t\t\treturn projectJoin;\n");
-		
-		// method end
-		sb.append("\t\t}\n");
-		
-		for (int numFields = FIRST; numFields <= LAST; numFields++) {
-
-			// method begin
-			sb.append("\n");
-
-			// method comment
-			sb.append("\t\t/**\n");
-			sb.append("\t\t * Projects a pair of joined elements to a {@link Tuple} with the previously selected fields. \n");
-			sb.append("\t\t * Requires the classes of the fields of the resulting tuples. \n");
-			sb.append("\t\t * \n");
-			sb.append("\t\t * @return The projected data set.\n");
-			sb.append("\t\t * \n");
-			sb.append("\t\t * @see Tuple\n");
-			sb.append("\t\t * @see DataSet\n");
-			sb.append("\t\t */\n");
-
-			// method signature
-			sb.append("\t\tpublic <");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append("> ProjectJoin<I1, I2, Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> projectTuple"+numFields+"(");
-			sb.append(") {\n");
-
-			// extract field types
-			sb.append("\t\t\tTypeInformation<?>[] fTypes = extractFieldTypes(fieldIndexes);\n");
-
-			// create new tuple type info
-			sb.append("\t\t\tTupleTypeInfo<Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> tType = new TupleTypeInfo<Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(fTypes);\n\n");
-
-			// create and return new project operator
-			sb.append("\t\t\treturn new ProjectJoin<I1, I2, Tuple"+numFields+"<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(this.ds1, this.ds2, this.keys1, this.keys2, this.hint, this.fieldIndexes, this.isFieldInFirst, tType, this);\n");
-
-			// method end
-			sb.append("\t\t}\n");
-
-		}
-
-		// insert code into file
-		File dir = getPackage(root, JOIN_OPERATOR_PACKAGE);
-		File projectOperatorClass = new File(dir, JOIN_OPERATOR_CLASSNAME + ".java");
-		insertCodeIntoFile(sb.toString(), projectOperatorClass);
-	}
-
-	private static void modifyTupleType(File root) throws IOException {
-		// generate code
-		StringBuilder sb = new StringBuilder();
-		sb.append("\tprivate static final Class<?>[] CLASSES = new Class<?>[] {\n\t\tTuple0.class");
-		for (int i = FIRST; i <= LAST; i++) {
-			sb.append(", Tuple" + i + ".class");
-		}
-		sb.append("\n\t};");
-
-		// insert code into file
-		File dir = getPackage(root, TUPLE_PACKAGE);
-		File tupleTypeInfoClass = new File(dir, TUPLE_CLASSNAME + ".java");
-		insertCodeIntoFile(sb.toString(), tupleTypeInfoClass);
-	}
-
-	private static void modifyCsvReader(File root) throws IOException {
-		// generate code
-		StringBuilder sb = new StringBuilder(1000);
-		for (int numFields = FIRST; numFields <= LAST; numFields++) {
-
-			// method begin
-			sb.append("\n");
-
-			// java doc
-			sb.append("\t/**\n");
-			sb.append("\t * Specifies the types for the CSV fields. This method parses the CSV data to a ").append(numFields).append("-tuple\n");
-			sb.append("\t * which has fields of the specified types.\n");
-			sb.append("\t * This method is overloaded for each possible length of the tuples to support type safe\n");
-			sb.append("\t * creation of data sets through CSV parsing.\n");
-			sb.append("\t *\n");
-
-			for (int pos = 0; pos < numFields; pos++) {
-				sb.append("\t * @param type").append(pos);
-				sb.append(" The type of CSV field ").append(pos).append(" and the type of field ");
-				sb.append(pos).append(" in the returned tuple type.\n");
-			}
-			sb.append("\t * @return The {@link org.apache.flink.api.java.DataSet} representing the parsed CSV data.\n");
-			sb.append("\t */\n");
-
-			// method signature
-			sb.append("\tpublic <");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append("> DataSource<Tuple" + numFields + "<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> types(");
-			for (int i = 0; i < numFields; i++) {
-				if (i > 0) {
-					sb.append(", ");
-				}
-				sb.append("Class<");
-				sb.append(GEN_TYPE_PREFIX + i);
-				sb.append("> type" + i);
-			}
-			sb.append(") {\n");
-
-			// get TupleTypeInfo
-			sb.append("\t\tTupleTypeInfo<Tuple" + numFields + "<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> types = TupleTypeInfo.getBasicAndBasicValueTupleTypeInfo(");
-			for (int i = 0; i < numFields; i++) {
-				if (i > 0) {
-					sb.append(", ");
-				}
-				sb.append("type" + i);
-			}
-			sb.append(");\n");
-
-			// create csv input format
-			sb.append("\t\tCsvInputFormat<Tuple" + numFields + "<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">> inputFormat = new TupleCsvInputFormat<Tuple" + numFields + "<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(path, types, this.includedMask);\n");
-
-			// configure input format
-			sb.append("\t\tconfigureInputFormat(inputFormat);\n");
-
-			// return
-			sb.append("\t\treturn new DataSource<Tuple" + numFields + "<");
-			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(executionContext, inputFormat, types, Utils.getCallLocationName());\n");
-
-			// end of method
-			sb.append("\t}\n");
-		}
-
-		// insert code into file
-		File dir = getPackage(root, CSV_READER_PACKAGE);
-		File csvReaderClass = new File(dir, CSV_READER_CLASSNAME + ".java");
-		insertCodeIntoFile(sb.toString(), csvReaderClass);
-	}
-
-	private static void appendTupleTypeGenerics(StringBuilder sb, int numFields) {
-		for (int i = 0; i < numFields; i++) {
-			if (i > 0) {
-				sb.append(", ");
-			}
-			sb.append(GEN_TYPE_PREFIX + i);
-		}
-	}
-
-	private static void createTupleClasses(File root) throws FileNotFoundException {
-		File dir = getPackage(root, PACKAGE);
-
-		for (int i = FIRST; i <= LAST; i++) {
-			File tupleFile = new File(dir, "Tuple" + i + ".java");
-				PrintWriter writer = new PrintWriter(tupleFile);
-			writeTupleClass(writer, i);
-			writer.flush();
-			writer.close();
-		}
-	}
-
-	private static void writeTupleClass(PrintWriter w, int numFields) {
-		final String className = "Tuple" + numFields;
-
-		// head
-		w.print(HEADER);
-
-		// package and imports
-		w.println("package " + PACKAGE + ';');
-		w.println();
-		w.println("import org.apache.flink.util.StringUtils;");
-		w.println();
-
-		// class declaration and class comments
-		w.println("/**");
-		w.println(" * A tuple with " + numFields + " fields. Tuples are strongly typed; each field may be of a separate type.");
-		w.println(" * The fields of the tuple can be accessed directly as public fields (f0, f1, ...) or via their position");
-		w.println(" * through the {@link #getField(int)} method. The tuple field positions start at zero.");
-		w.println(" * <p>");
-		w.println(" * Tuples are mutable types, meaning that their fields can be re-assigned. This allows functions that work");
-		w.println(" * with Tuples to reuse objects in order to reduce pressure on the garbage collector.");
-		w.println(" *");
-		w.println(" * @see Tuple");
-		w.println(" *");
-		for (int i = 0; i < numFields; i++) {
-			w.println(" * @param <" + GEN_TYPE_PREFIX + i + "> The type of field " + i);
-		}
-		w.println(" */");
-		w.print("public class " + className + "<");
-		for (int i = 0; i < numFields; i++) {
-			if (i > 0) {
-				w.print(", ");
-			}
-			w.print(GEN_TYPE_PREFIX + i);
-		}
-		w.println("> extends Tuple {");
-		w.println();
-
-		w.println("\tprivate static final long serialVersionUID = 1L;");
-		w.println();
-
-		// fields
-		for (int i = 0; i < numFields; i++) {
-			w.println("\t/** Field " + i + " of the tuple. */");
-			w.println("\tpublic " + GEN_TYPE_PREFIX + i + " f" + i + ';');
-		}
-		w.println();
-
-		String paramList = "("; // This will be like "(T0 value0, T1 value1)"
-		for (int i = 0; i < numFields; i++) {
-			if (i > 0) {
-				paramList += ", ";
-			}
-			paramList += GEN_TYPE_PREFIX + i + " value" + i;
-		}
-		paramList += ")";
-
-		// constructors
-		w.println("\t/**");
-		w.println("\t * Creates a new tuple where all fields are null.");
-		w.println("\t */");
-		w.println("\tpublic " + className + "() {}");
-		w.println();
-		w.println("\t/**");
-		w.println("\t * Creates a new tuple and assigns the given values to the tuple's fields.");
-		w.println("\t *");
-		for (int i = 0; i < numFields; i++) {
-			w.println("\t * @param value" + i + " The value for field " + i);
-		}
-		w.println("\t */");
-		w.println("\tpublic " + className + paramList + " {");
-		for (int i = 0; i < numFields; i++) {
-			w.println("\t\tthis.f" + i + " = value" + i + ';');
-		}
-		w.println("\t}");
-		w.println();
-
-
-		// arity accessor
-		w.println("\t@Override");
-		w.println("\tpublic int getArity() { return " + numFields + "; }");
-		w.println();
-
-		// accessor getter method
-		w.println("\t@Override");
-		w.println("\t@SuppressWarnings(\"unchecked\")");
-		w.println("\tpublic <T> T getField(int pos) {");
-		w.println("\t\tswitch(pos) {");
-		for (int i = 0; i < numFields; i++) {
-			w.println("\t\t\tcase " + i + ": return (T) this.f" + i + ';');
-		}
-		w.println("\t\t\tdefault: throw new IndexOutOfBoundsException(String.valueOf(pos));");
-		w.println("\t\t}");
-		w.println("\t}");
-		w.println();
-
-		// accessor setter method
-		w.println("\t@Override");
-		w.println("\t@SuppressWarnings(\"unchecked\")");
-		w.println("\tpublic <T> void setField(T value, int pos) {");
-		w.println("\t\tswitch(pos) {");
-		for (int i = 0; i < numFields; i++) {
-			w.println("\t\t\tcase " + i + ':');
-			w.println("\t\t\t\tthis.f" + i + " = (" + GEN_TYPE_PREFIX + i + ") value;");
-			w.println("\t\t\t\tbreak;");
-		}
-		w.println("\t\t\tdefault: throw new IndexOutOfBoundsException(String.valueOf(pos));");
-		w.println("\t\t}");
-		w.println("\t}");
-		w.println();
-
-		// accessor setter method for all fields
-		w.println("\t/**");
-		w.println("\t * Sets new values to all fields of the tuple.");
-		w.println("\t *");
-		for (int i = 0; i < numFields; i++) {
-			w.println("\t * @param value" + i + " The value for field " + i);
-		}
-		w.println("\t */");
-		w.println("\tpublic void setFields" + paramList + " {");
-		for (int i = 0; i < numFields; i++) {
-			w.println("\t\tthis.f" + i + " = value" + i + ';');
-		}
-		w.println("\t}");
-		w.println();
-
-		// swap method only for Tuple2
-		if (numFields == 2) {
-			w.println("\t/**");
-			w.println("\t* Returns a shallow copy of the tuple with swapped values.");
-			w.println("\t*");
-			w.println("\t* @return shallow copy of the tuple with swapped values");
-			w.println("\t*/");
-			w.println("\tpublic Tuple2<T1, T0> swap() {");
-			w.println("\t\treturn new Tuple2<T1, T0>(f1, f0);");
-			w.println("\t}");
-		}
-
-		// standard utilities (toString, equals, hashCode, copy)
-		w.println();
-		w.println("\t// -------------------------------------------------------------------------------------------------");
-		w.println("\t// standard utilities");
-		w.println("\t// -------------------------------------------------------------------------------------------------");
-		w.println();
-		w.println("\t/**");
-		w.println("\t * Creates a string representation of the tuple in the form");
-		w.print("\t * (f0");
-		for (int i = 1; i < numFields; i++) {
-			w.print(", f" + i);
-		}
-		w.println("),");
-		w.println("\t * where the individual fields are the value returned by calling {@link Object#toString} on that field.");
-		w.println("\t * @return The string representation of the tuple.");
-		w.println("\t */");
-		w.println("\t@Override");
-		w.println("\tpublic String toString() {");
-		w.println("\t\treturn \"(\" + StringUtils.arrayAwareToString(this.f0)");
-		for (int i = 1; i < numFields; i++) {
-			w.println("\t\t\t+ \",\" + StringUtils.arrayAwareToString(this.f" + i + ")");
-		}
-		w.println("\t\t\t+ \")\";");
-		w.println("\t}");
-
-		w.println();
-		w.println("\t/**");
-		w.println("\t * Deep equality for tuples by calling equals() on the tuple members");
-		w.println("\t * @param o the object checked for equality");
-		w.println("\t * @return true if this is equal to o.");
-		w.println("\t */");
-		w.println("\t@Override");
-		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;
-			w.println("\t\tif (" + field + " != null ? !" + field +".equals(tuple." +
-					field + ") : tuple." + field + " != null) { return false; }");
-		}
-		w.println("\t\treturn true;");
-		w.println("\t}");
-
-		w.println();
-		w.println("\t@Override");
-		w.println("\tpublic int hashCode() {");
-		w.println("\t\tint result = f0 != null ? f0.hashCode() : 0;");
-		for (int i = 1; i < numFields; i++) {
-			String field = "f" + i;
-			w.println("\t\tresult = 31 * result + (" + field + " != null ? " + field + ".hashCode() : 0);");
-		}
-		w.println("\t\treturn result;");
-		w.println("\t}");
-
-
-		String tupleTypes = "<";
-		for (int i = 0; i < numFields; i++) {
-			tupleTypes += "T" + i;
-			if (i < numFields - 1) {
-				tupleTypes += ",";
-			}
-		}
-		tupleTypes += ">";
-
-		w.println();
-		w.println("\t/**");
-		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");
-		if (numFields > 1) {
-			w.println(",");
-		}
-		for (int i = 1; i < numFields; i++) {
-			String field = "f" + i;
-			w.print("\t\t\tthis." + field);
-			if (i < numFields - 1) {
-				w.println(",");
-			}
-		}
-		w.println(");");
-		w.println("\t}");
-
-		w.println();
-		w.println("\t/**");
-		w.println("\t * Creates a new tuple and assigns the given values to the tuple's fields.");
-		w.println("\t * This is more convenient than using the constructor, because the compiler can");
-		w.println("\t * infer the generic type arguments implicitly. For example:");
-		w.println("\t * {@code Tuple3.of(n, x, s)}");
-		w.println("\t * instead of");
-		w.println("\t * {@code new Tuple3<Integer, Double, String>(n, x, s)}");
-		w.println("\t */");
-		w.println("\tpublic static " + tupleTypes + " " + className + tupleTypes + " of" + paramList + " {");
-		w.print("\t\treturn new " + className + tupleTypes + "(");
-		for(int i = 0; i < numFields; i++) {
-			w.print("value" + i);
-			if(i < numFields - 1) {
-				w.print(", ");
-			}
-		}
-		w.println(");");
-		w.println("\t}");
-
-		// foot
-		w.println("}");
-	}
-
-	private static void createTupleBuilderClasses(File root) throws FileNotFoundException {
-		File dir = getPackage(root, PACKAGE+"."+BUILDER_SUFFIX);
-
-		for (int i = FIRST; i <= LAST; i++) {
-			File tupleFile = new File(dir, "Tuple" + i + "Builder.java");
-			PrintWriter writer = new PrintWriter(tupleFile);
-			writeTupleBuilderClass(writer, i);
-			writer.flush();
-			writer.close();
-		}
-	}
-
-	private static void printGenericsString(PrintWriter w, int numFields){
-		w.print("<");
-		for (int i = 0; i < numFields; i++) {
-			if (i > 0) {
-				w.print(", ");
-			}
-			w.print(GEN_TYPE_PREFIX + i);
-		}
-		w.print(">");
-	}
-
-	private static void writeTupleBuilderClass(PrintWriter w, int numFields) {
-		final String className = "Tuple" + numFields + "Builder";
-
-		// head
-		w.print(HEADER);
-
-		// package and imports
-		w.println("package " + PACKAGE + "." + BUILDER_SUFFIX + ';');
-		w.println();
-		w.println("import java.util.ArrayList;");
-		w.println("import java.util.List;");
-		w.println();
-		w.println("import " + PACKAGE + ".Tuple" + numFields + ";");
-		w.println();
-
-		// class declaration
-		w.print("public class " + className);
-		printGenericsString(w, numFields);
-		w.println(" {");
-		w.println();
-
-		// Class-Attributes - a list of tuples
-		w.print("\tprivate List<Tuple" + numFields);
-		printGenericsString(w, numFields);
-		w.print("> tuples = new ArrayList<Tuple" + numFields );
-		printGenericsString(w, numFields);
-		w.println(">();");
-		w.println();
-
-		// add(...) function for adding a single tuple
-		w.print("\tpublic " + className);
-		printGenericsString(w, numFields);
-		w.print(" add(");
-		for (int i = 0; i < numFields; i++) {
-			if (i > 0) {
-				w.print(", ");
-			}
-			w.print(GEN_TYPE_PREFIX + i + " value" + i);
-		}
-		w.println("){");
-		w.print("\t\ttuples.add(new Tuple" + numFields);
-		printGenericsString(w, numFields);
-		w.print("(");
-		for (int i = 0; i < numFields; i++) {
-			if (i > 0) {
-				w.print(", ");
-			}
-			w.print("value" + i);
-		}
-		w.println("));");
-		w.println("\t\treturn this;");
-		w.println("\t}");
-		w.println();
-
-		// build() function, returns an array of tuples
-		w.println("\t@SuppressWarnings(\"unchecked\")");
-		w.print("\tpublic Tuple" + numFields);
-		printGenericsString(w, numFields);
-		w.println("[] build(){");
-		w.println("\t\treturn tuples.toArray(new Tuple" + numFields + "[tuples.size()]);");
-		w.println("\t}");
-
-		// foot
-		w.println("}");
-	}
-
-	private static String HEADER =
-		"/*\n"
-		+ " * Licensed to the Apache Software Foundation (ASF) under one\n"
-		+ " * or more contributor license agreements.  See the NOTICE file\n"
-		+ " * distributed with this work for additional information\n"
-		+ " * regarding copyright ownership.  The ASF licenses this file\n"
-		+ " * to you under the Apache License, Version 2.0 (the\n"
-		+ " * \"License\"); you may not use this file except in compliance\n"
-		+ " * with the License.  You may obtain a copy of the License at\n"
-		+ " *\n"
-		+ " *     http://www.apache.org/licenses/LICENSE-2.0\n"
-		+ " *\n"
-		+ " * Unless required by applicable law or agreed to in writing, software\n"
-		+ " * distributed under the License is distributed on an \"AS IS\" BASIS,\n"
-		+ " * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n"
-		+ " * See the License for the specific language governing permissions and\n"
-		+ " * limitations under the License.\n"
-		+ " */" +
-		"\n" +
-		"\n" +
-		"\n" +
-		"// --------------------------------------------------------------\n" +
-		"//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!\n" +
-		"//  GENERATED FROM " + TupleGenerator.class.getName() + ".\n" +
-		"// --------------------------------------------------------------\n\n\n";
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple0Builder.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple0Builder.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple0Builder.java
deleted file mode 100644
index 5facb7e..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple0Builder.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple.builder;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.flink.api.java.tuple.Tuple0;
-
-public class Tuple0Builder {
-
-	private List<Tuple0> tuples = new ArrayList<Tuple0>();
-
-	public Tuple0Builder add() {
-		tuples.add(Tuple0.INSTANCE);
-		return this;
-	}
-
-	public Tuple0[] build() {
-		return tuples.toArray(new Tuple0[tuples.size()]);
-	}
-
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple10Builder.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple10Builder.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple10Builder.java
deleted file mode 100644
index d09ba11..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple10Builder.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple.builder;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.flink.api.java.tuple.Tuple10;
-
-public class Tuple10Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9> {
-
-	private List<Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9>> tuples = new ArrayList<Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9>>();
-
-	public Tuple10Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9> add(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7, T8 value8, T9 value9){
-		tuples.add(new Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9>(value0, value1, value2, value3, value4, value5, value6, value7, value8, value9));
-		return this;
-	}
-
-	@SuppressWarnings("unchecked")
-	public Tuple10<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9>[] build(){
-		return tuples.toArray(new Tuple10[tuples.size()]);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple11Builder.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple11Builder.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple11Builder.java
deleted file mode 100644
index 727fab0..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple11Builder.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple.builder;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.flink.api.java.tuple.Tuple11;
-
-public class Tuple11Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> {
-
-	private List<Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>> tuples = new ArrayList<Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>>();
-
-	public Tuple11Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> add(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7, T8 value8, T9 value9, T10 value10){
-		tuples.add(new Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>(value0, value1, value2, value3, value4, value5, value6, value7, value8, value9, value10));
-		return this;
-	}
-
-	@SuppressWarnings("unchecked")
-	public Tuple11<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>[] build(){
-		return tuples.toArray(new Tuple11[tuples.size()]);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple12Builder.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple12Builder.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple12Builder.java
deleted file mode 100644
index 7f77a8d..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple12Builder.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple.builder;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.flink.api.java.tuple.Tuple12;
-
-public class Tuple12Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> {
-
-	private List<Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>> tuples = new ArrayList<Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>>();
-
-	public Tuple12Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> add(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7, T8 value8, T9 value9, T10 value10, T11 value11){
-		tuples.add(new Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(value0, value1, value2, value3, value4, value5, value6, value7, value8, value9, value10, value11));
-		return this;
-	}
-
-	@SuppressWarnings("unchecked")
-	public Tuple12<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>[] build(){
-		return tuples.toArray(new Tuple12[tuples.size()]);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple13Builder.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple13Builder.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple13Builder.java
deleted file mode 100644
index e223e7a..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple13Builder.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple.builder;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.flink.api.java.tuple.Tuple13;
-
-public class Tuple13Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> {
-
-	private List<Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>> tuples = new ArrayList<Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>>();
-
-	public Tuple13Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> add(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7, T8 value8, T9 value9, T10 value10, T11 value11, T12 value12){
-		tuples.add(new Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(value0, value1, value2, value3, value4, value5, value6, value7, value8, value9, value10, value11, value12));
-		return this;
-	}
-
-	@SuppressWarnings("unchecked")
-	public Tuple13<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>[] build(){
-		return tuples.toArray(new Tuple13[tuples.size()]);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple14Builder.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple14Builder.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple14Builder.java
deleted file mode 100644
index a3847c2..0000000
--- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple14Builder.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-// --------------------------------------------------------------
-//  THIS IS A GENERATED SOURCE FILE. DO NOT EDIT!
-//  GENERATED FROM org.apache.flink.api.java.tuple.TupleGenerator.
-// --------------------------------------------------------------
-
-
-package org.apache.flink.api.java.tuple.builder;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.flink.api.java.tuple.Tuple14;
-
-public class Tuple14Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> {
-
-	private List<Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>> tuples = new ArrayList<Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>>();
-
-	public Tuple14Builder<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> add(T0 value0, T1 value1, T2 value2, T3 value3, T4 value4, T5 value5, T6 value6, T7 value7, T8 value8, T9 value9, T10 value10, T11 value11, T12 value12, T13 value13){
-		tuples.add(new Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>(value0, value1, value2, value3, value4, value5, value6, value7, value8, value9, value10, value11, value12, value13));
-		return this;
-	}
-
-	@SuppressWarnings("unchecked")
-	public Tuple14<T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>[] build(){
-		return tuples.toArray(new Tuple14[tuples.size()]);
-	}
-}


Mime
View raw message