Re: TypeInformation in Custom Deserializer

[AndreaKinn]

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<Tuple6<String, String, 
> Date,
> String, String, Double>>(){});
> 
> 
>> On Aug 13, 2017, at 10:31 AM, AndreaKinn <

> kinn6aer@

> > wrote:
>> 
>> Hi,
>> I'm trying to implement a custom deserialiser to deserialise data from a
>> kafka sink.
>> So I'm implementing a KeyedDeserializedSchema<Tuple6<String,
>> String,
> > Date, String, String, Double>>
>> which ask me to override the method:
>> 
>> @Override
>> public TypeInformation<Tuple6<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.





--
View this message in context: 
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/TypeInformation-in-Custom-Deserializer-tp14861p14868.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at 
Nabble.com.