Please take a look at the following
in
flink-java/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopInputFormat.java
public TypeInformation<Tuple2<K, V>> getProducedType() {
return new TupleTypeInfo<>(TypeExtractor.createTypeInfo(keyClass),
TypeExtractor.createTypeInfo(valueClass));
FYI
On Sun, Aug 13, 2017 at 8:23 AM, AndreaKinn <kinn6...@hotmail.it> wrote:
> But I'm using Java primitive type like String, Double plus Date types.
> Flink
> doesn't know how to handle them?
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/TypeInformation-
> in-Custom-Deserializer-tp14861p14863.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
