Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r156937828
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/Types.scala ---
@@ -0,0 +1,371 @@
+/*
+ * 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.scala.typeutils
+
+import org.apache.flink.annotation.PublicEvolving
+import org.apache.flink.api.common.functions.InvalidTypesException
+import org.apache.flink.api.common.typeinfo.{TypeInformation, Types =>
JTypes}
+import org.apache.flink.types.Row
+
+import _root_.scala.collection.JavaConverters._
+import _root_.scala.util.{Either, Try}
+
+/**
+ * This class gives access to the type information of the most common
Scala types for which Flink
+ * has built-in serializers and comparators.
+ *
+ * This class contains types of
[[org.apache.flink.api.common.typeinfo.Types]] and adds
+ * types for Scala specific classes (such as [[Unit]] or case classes).
+ *
+ * In many cases, Flink tries to analyze generic signatures of functions
to determine return
+ * types automatically. This class is intended for cases where type
information has to be
+ * supplied manually or would result in an inefficient type.
+ *
+ * Scala macros allow to determine type information of classes and type
parameters. You can
+ * use [[Types.of]] to let type information be determined automatically.
+ */
+@PublicEvolving
+object Types {
+
+ /**
+ * Generates type information based on the given class and/or its type
parameters.
+ *
+ * The definition is similar to a
[[org.apache.flink.api.common.typeinfo.TypeHint]] but does
+ * not require to implement anonymous classes.
+ *
+ * If the class could not be analyzed by the Scala type analyzer, the
Java analyzer
+ * will be used.
+ *
+ * Example use:
+ *
+ * `Types.of[(Int, String, String)]` for Scala tuples
+ * `Types.of[Unit]` for Scala specific types
+ *
+ * @tparam T class to be analyzed
+ */
+ def of[T: TypeInformation]: TypeInformation[T] = {
+ val typeInfo: TypeInformation[T] = implicitly[TypeInformation[T]]
+ typeInfo
+ }
+
+ /**
+ * Returns type information for Scala [[Nothing]]. Does not support a
null value.
+ */
+ val NOTHING: TypeInformation[Nothing] = new ScalaNothingTypeInfo
+
+ /**
+ * Returns type information for Scala [[Unit]]. Does not support a null
value.
+ */
+ val UNIT: TypeInformation[Unit] = new UnitTypeInfo
+
+ /**
+ * Returns type information for [[String]] and [[java.lang.String]].
Supports a null value.
+ */
+ val STRING: TypeInformation[String] = JTypes.STRING
+
+ /**
+ * Returns type information for primitive [[Byte]] and
[[java.lang.Byte]]. Does not
+ * support a null value.
+ */
+ val BYTE: TypeInformation[java.lang.Byte] = JTypes.BYTE
+
+ /**
+ * Returns type information for primitive [[Boolean]] and
[[java.lang.Boolean]]. Does not
+ * support a null value.
+ */
+ val BOOLEAN: TypeInformation[java.lang.Boolean] = JTypes.BOOLEAN
+
+ /**
+ * Returns type information for primitive [[Short]] and
[[java.lang.Short]]. Does not
+ * support a null value.
+ */
+ val SHORT: TypeInformation[java.lang.Short] = JTypes.SHORT
+
+ /**
+ * Returns type information for primitive [[Int]] and
[[java.lang.Integer]]. Does not
+ * support a null value.
+ */
+ val INT: TypeInformation[java.lang.Integer] = JTypes.INT
+
+ /**
+ * Returns type information for primitive [[Long]] and
[[java.lang.Long]]. Does not
+ * support a null value.
+ */
+ val LONG: TypeInformation[java.lang.Long] = JTypes.LONG
+
+ /**
+ * Returns type information for primitive [[Float]] and
[[java.lang.Float]]. Does not
+ * support a null value.
+ */
+ val FLOAT: TypeInformation[java.lang.Float] = JTypes.FLOAT
+
+ /**
+ * Returns type information for primitive [[Double]] and
[[java.lang.Double]]. Does not
+ * support a null value.
+ */
+ val DOUBLE: TypeInformation[java.lang.Double] = JTypes.DOUBLE
+
+ /**
+ * Returns type information for primitive [[Char]] and
[[java.lang.Character]]. Does not
+ * support a null value.
+ */
+ val CHAR: TypeInformation[java.lang.Character] = JTypes.CHAR
+
+ /**
+ * Returns type information for Java [[java.math.BigDecimal]]. Supports
a null value.
+ *
+ * Note that Scala [[BigDecimal]] is not supported yet.
+ */
+ val JAVA_BIG_DEC: TypeInformation[java.math.BigDecimal] = JTypes.BIG_DEC
+
+ /**
+ * Returns type information for Java [[java.math.BigInteger]]. Supports
a null value.
+ *
+ * Note that Scala [[BigInt]] is not supported yet.
+ */
+ val JAVA_BIG_INT: TypeInformation[java.math.BigInteger] = JTypes.BIG_INT
+
+ /**
+ * Returns type information for [[java.sql.Date]]. Supports a null
value.
+ */
+ val SQL_DATE: TypeInformation[java.sql.Date] = JTypes.SQL_DATE
+
+ /**
+ * Returns type information for [[java.sql.Time]]. Supports a null
value.
+ */
+ val SQL_TIME: TypeInformation[java.sql.Time] = JTypes.SQL_TIME
+
+ /**
+ * Returns type information for [[java.sql.Timestamp]]. Supports a null
value.
+ */
+ val SQL_TIMESTAMP: TypeInformation[java.sql.Timestamp] =
JTypes.SQL_TIMESTAMP
+
+ /**
+ * Returns type information for [[org.apache.flink.types.Row]] with
fields of the given types.
+ * A row itself must not be null.
+ *
+ * A row is a fixed-length, null-aware composite type for storing
multiple values in a
+ * deterministic field order. Every field can be null independent of
the field's type.
+ * The type of row fields cannot be automatically inferred; therefore,
it is required to pass
+ * type information whenever a row is used.
+ *
+ * <p>The schema of rows can have up to <code>Integer.MAX_VALUE</code>
fields, however, all row instances
--- End diff --
line exceeds 100 characters.
---
