From 26bab40934200496ba3be37b9954febc3d3e5f75 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Fri, 12 Mar 2021 17:56:16 +0100
Subject: [PATCH] Add TupleType class
---
.../theodolite/commons/flink/TupleType.java | 22 +++++++++++++++++++
1 file changed, 22 insertions(+)
create mode 100644 theodolite-benchmarks/flink-commons/src/main/java/theodolite/commons/flink/TupleType.java
diff --git a/theodolite-benchmarks/flink-commons/src/main/java/theodolite/commons/flink/TupleType.java b/theodolite-benchmarks/flink-commons/src/main/java/theodolite/commons/flink/TupleType.java
new file mode 100644
index 000000000..360331e4d
--- /dev/null
+++ b/theodolite-benchmarks/flink-commons/src/main/java/theodolite/commons/flink/TupleType.java
@@ -0,0 +1,22 @@
+package theodolite.commons.flink;
+
+import org.apache.flink.api.common.typeinfo.TypeInformation;
+import org.apache.flink.api.common.typeinfo.Types;
+import org.apache.flink.api.java.tuple.Tuple;
+import org.apache.flink.api.java.tuple.Tuple2;
+
+/**
+ * Helper methods for creating {@link TypeInformation} for {@link Tuple}s. In contrast to
+ * {@code Types#TUPLE(TypeInformation...)}, these methods bring real type safety.
+ */
+public final class TupleType {
+
+ private TupleType() {}
+
+ public static <T1, T2> TypeInformation<Tuple2<T1, T2>> of(// NOPMD
+ final TypeInformation<T1> t0,
+ final TypeInformation<T2> t1) {
+ return Types.TUPLE(t0, t1);
+ }
+
+}
--
GitLab