Re: TypeInformation in Custom Deserializer

Thank you, I solved in this way Greg Hogan wrote > You should be able to implement this using a TypeHint (see the Creating a > TypeInformation or TypeSerializer section from the linked page): > > return TypeInformation.of(new TypeHint Date, > String, String, Doubl

Re: TypeInformation in Custom Deserializer

You should be able to implement this using a TypeHint (see the Creating a TypeInformation or TypeSerializer section from the linked page): return TypeInformation.of(new TypeHint>(){}); > On Aug 13, 2017, at 10:31 AM, AndreaKinn wrote: > > Hi, > I'm trying to implement a custom deseria

Re: TypeInformation in Custom Deserializer

Please take a look at the following in flink-java/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopInputFormat.java public TypeInformation> getProducedType() { return new TupleTypeInfo<>(TypeExtractor.createTypeInfo(keyClass), TypeExtractor.createTypeInfo(valueClass)); FYI On S

Re: TypeInformation in Custom Deserializer

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

Re: TypeInformation in Custom Deserializer

>From ResultTypeQueryable : * Gets the data type (as a {@link TypeInformation}) produced by this function or input format. * * @return The data type produced by this function or input format. */ TypeInformation getProducedType(); You can look at classes which implement this method a