You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Vishnu Viswanath <vi...@gmail.com> on 2017/07/18 20:12:31 UTC
AVRO Union type support in Flink
Hi All,
Does Flink support AVRO union types - Documentation says it supports
nullable types: {"name": "type_double_test", "type": ["null", "double"]}
But my schema has something like : {"name": "union_field", "type":
["string", "double"]}
Thanks
Vishnu
Re: AVRO Union type support in Flink
Posted by Timo Walther <tw...@apache.org>.
Hi Vishnu,
I took a look into the code. Actually, we should support it. However,
those types might be mapped to Java Objects that will be serialized with
our generic Kryo serializer. Have you tested it?
Regards,
Timo
Am 19.07.17 um 06:30 schrieb Martin Eden:
> Hey Vishnu,
>
> For those of us on the list that are not very familiar with Flink and
> Avro can you give a pointed to the docs you are referring to and how
> you intend to use it? Just so we gain understanding as well.
>
> Thanks,
> Martin
>
> On Tue, Jul 18, 2017 at 9:12 PM, Vishnu Viswanath
> <vishnu.viswanath25@gmail.com <ma...@gmail.com>>
> wrote:
>
> Hi All,
>
> Does Flink support AVRO union types - Documentation says it
> supports nullable types: {"name": "type_double_test", "type":
> ["null", "double"]}
>
> But my schema has something like : {"name": "union_field", "type":
> ["string", "double"]}
>
> Thanks
> Vishnu
>
>
>
Re: AVRO Union type support in Flink
Posted by Martin Eden <ma...@gmail.com>.
Hey Vishnu,
For those of us on the list that are not very familiar with Flink and Avro
can you give a pointed to the docs you are referring to and how you intend
to use it? Just so we gain understanding as well.
Thanks,
Martin
On Tue, Jul 18, 2017 at 9:12 PM, Vishnu Viswanath <
vishnu.viswanath25@gmail.com> wrote:
> Hi All,
>
> Does Flink support AVRO union types - Documentation says it supports
> nullable types: {"name": "type_double_test", "type": ["null", "double"]}
>
> But my schema has something like : {"name": "union_field", "type":
> ["string", "double"]}
>
> Thanks
> Vishnu
>
>
>