Re: TypeInformation in Custom Deserializer

[Ted Yu]

>From ResultTypeQueryable :

   * Gets the data type (as a {@link TypeInformation}) produced by this
function or input format.
   *
   * @return The data type produced by this function or input format.
   */
  TypeInformation<T> getProducedType();

You can look at classes which implement this method as examples.

flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseRowInputFormat.java


On Sun, Aug 13, 2017 at 7: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.
>