Re: TypeInformation in Custom Deserializer

2017-08-13 Thread AndreaKinn
gt; Double>> getProducedType() { >> //to do >> } >> >> Honestly I investigated in link >> <https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/types_serialization.html>; >> >> but I didn't understand what is this m

Re: TypeInformation in Custom Deserializer

2017-08-13 Thread Greg Hogan
; //to do > } > > Honestly I investigated in link > <https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/types_serialization.html> > > but I didn't understand what is this method and how to implement it. > > > > -- > View this message

Re: TypeInformation in Custom Deserializer

2017-08-13 Thread Ted Yu
-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. >

Re: TypeInformation in Custom Deserializer

2017-08-13 Thread AndreaKinn
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

Re: TypeInformation in Custom Deserializer

2017-08-13 Thread Ted Yu
ps://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/types_ > serialization.html> > but I didn't understand what is this method and how to implement it. > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/TypeInform

TypeInformation in Custom Deserializer

2017-08-13 Thread AndreaKinn
in link <https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/types_serialization.html> but I didn't understand what is this method and how to implement it. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/TypeInformation-in-