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.

Reply via email to