You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Debasish Ghosh <gh...@gmail.com> on 2019/06/07 16:00:40 UTC

Avro serde classes in Flink

Hello -

Is there any specific reason we have AvroDeserializationSchema in Flink but
not AvroSerializationSchema ? Instead we have AvroRowSerializationSchema,
which serializes objects that are represented in (nested) Flink rows.

regards.

-- 
Debasish Ghosh
http://manning.com/ghosh2
http://manning.com/ghosh

Twttr: @debasishg
Blog: http://debasishg.blogspot.com
Code: http://github.com/debasishg

Re: Avro serde classes in Flink

Posted by Debasish Ghosh <gh...@gmail.com>.

Thanks Fabian .. I will take a look.

On Tue, Jun 11, 2019 at 9:16 PM Fabian Hueske <fh...@gmail.com> wrote:

> Hi Debasish,
>
> No, I don't think there's a particular reason.
> There a few Jira issues that propose adding an Avro Serialization Schema
> for Confluent Schema Registry [1] [2].
> Please check them out and add a new one if they don't describe what you
> are looking for.
>
> Cheers,
> Fabian
>
> [1] https://issues.apache.org/jira/browse/FLINK-9679
> [2] https://issues.apache.org/jira/browse/FLINK-8378
>
> Am Fr., 7. Juni 2019 um 18:01 Uhr schrieb Debasish Ghosh <
> ghosh.debasish@gmail.com>:
>
>> Hello -
>>
>> Is there any specific reason we have AvroDeserializationSchema in Flink
>> but not AvroSerializationSchema ? Instead we have
>> AvroRowSerializationSchema, which serializes objects that are
>> represented in (nested) Flink rows.
>>
>> regards.
>>
>> --
>> Debasish Ghosh
>> http://manning.com/ghosh2
>> http://manning.com/ghosh
>>
>> Twttr: @debasishg
>> Blog: http://debasishg.blogspot.com
>> Code: http://github.com/debasishg
>>
>

-- 
Debasish Ghosh
http://manning.com/ghosh2
http://manning.com/ghosh

Twttr: @debasishg
Blog: http://debasishg.blogspot.com
Code: http://github.com/debasishg

Re: Avro serde classes in Flink

Posted by Fabian Hueske <fh...@gmail.com>.

Hi Debasish,

No, I don't think there's a particular reason.
There a few Jira issues that propose adding an Avro Serialization Schema
for Confluent Schema Registry [1] [2].
Please check them out and add a new one if they don't describe what you are
looking for.

Cheers,
Fabian

[1] https://issues.apache.org/jira/browse/FLINK-9679
[2] https://issues.apache.org/jira/browse/FLINK-8378

Am Fr., 7. Juni 2019 um 18:01 Uhr schrieb Debasish Ghosh <
ghosh.debasish@gmail.com>:

> Hello -
>
> Is there any specific reason we have AvroDeserializationSchema in Flink
> but not AvroSerializationSchema ? Instead we have
> AvroRowSerializationSchema, which serializes objects that are represented
> in (nested) Flink rows.
>
> regards.
>
> --
> Debasish Ghosh
> http://manning.com/ghosh2
> http://manning.com/ghosh
>
> Twttr: @debasishg
> Blog: http://debasishg.blogspot.com
> Code: http://github.com/debasishg
>