Re: TypeInformation in Custom Deserializer

[Greg Hogan]

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<Tuple6<String, String, Date, 
String, String, Double>>(){});


> On Aug 13, 2017, at 10:31 AM, AndreaKinn <kinn6...@hotmail.it> wrote:
> 
> Hi,
> I'm trying to implement a custom deserialiser to deserialise data from a
> kafka sink.
> So I'm implementing a KeyedDeserializedSchema<Tuple6&lt;String, String,
> Date, String, String, Double>>
> which ask me to override the method:
> 
> @Override
> public TypeInformation<Tuple6&lt;String, String, Date, String, String,
> 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 method and how to implement it.
> 
> 
> 
> --
> View this message in context: 
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/TypeInformation-in-Custom-Deserializer-tp14861.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at 
> Nabble.com.