flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From AndreaKinn <kinn6...@hotmail.it>
Subject Re: TypeInformation in Custom Deserializer
Date Sun, 13 Aug 2017 17:24:29 GMT
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&lt;Tuple6&lt;String, String, Date,
> String, String, Double&gt;>(){});
> 
> 
>> On Aug 13, 2017, at 10:31 AM, AndreaKinn &lt;

> kinn6aer@

> &gt; wrote:
>> 
>> Hi,
>> I'm trying to implement a custom deserialiser to deserialise data from a
>> kafka sink.
>> So I'm implementing a KeyedDeserializedSchema&lt;Tuple6&amp;lt;String,
>> String,
> &gt; Date, String, String, Double>>
>> which ask me to override the method:
>> 
>> @Override
>> public TypeInformation&lt;Tuple6&amp;lt;String, String, Date, String,
>> String,
> &gt; Double>> getProducedType() {
>> 	//to do 
>> }
>> 
>> Honestly I investigated in  link
>> &lt;https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/types_serialization.html&gt;
 
>> 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.

Mime
View raw message