Avro serde classes in Flink

[Debasish Ghosh]

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.

--

[Fabian Hueske-2]

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 <[hidden email]>:

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]

Thanks Fabian .. I will take a look.

On Tue, Jun 11, 2019 at 9:16 PM Fabian Hueske <[hidden email]> 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 <[hidden email]>:

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.

--

--