ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined
types in CsvReader
URL: https://github.com/apache/flink/pull/5862#discussion_r221242052
##########
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TupleTypeInfo.java
##########
@@ -238,6 +238,37 @@ public String toString() {
return tupleInfo;
}
+ /**
+ * Resolves a type information for each specified income type and forms
an instance of a resulting {@link TupleTypeInfo} type.
+ * @param incomeTypes tuple fields' types
+ * @param <X> a resulting type of a tuple, e.g. Tuple1, Tuple2...
+ * @return A tuple information type, built from the specified income
types.
+ */
+ @SuppressWarnings("unchecked")
+ @PublicEvolving
+ public static <X extends Tuple> TupleTypeInfo<X>
getTupleTypeInfo(Class<?>... incomeTypes) {
+ if (incomeTypes == null || incomeTypes.length == 0) {
+ throw new IllegalArgumentException();
Review comment:
I think the good idea add here message for exception.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
