Thanks Rafi .. will try it out ..
On Tue, 14 May 2019 at 1:26 PM, Rafi Aroch wrote:
> Hi Debasish,
>
> It would be a bit tedious, but in order to override the default
> AvroSerializer you could specify a TypeInformation object where needed.
> You would need to implement your own
Hi Debasish,
It would be a bit tedious, but in order to override the default
AvroSerializer you could specify a TypeInformation object where needed.
You would need to implement your own MyAvroTypeInfo instead of the provided
AvroTypeInfo.
For example:
env.addSource(kafkaConsumer
Hi Konstantin -
I did take a look at the option you mentioned. Using that option I can
register a custom serializer for a custom type. But my requirement is a bit
different - I would like to have a custom AvroSerializer for *all* types
which implement SpecificRecordBase of Avro. The reason is I
/java/org/apache/flink/api/common/typeinfo/TypeInfo.html
On Mon, May 13, 2019 at 6:50 PM Debasish Ghosh
wrote:
> Hello -
>
> I am using Avro based encoding with Flink. I see that Flink has an
> AvroSerializer that gets used for serializing Avro. Is it possible to
> provide a custom
Hello -
I am using Avro based encoding with Flink. I see that Flink has an
AvroSerializer that gets used for serializing Avro. Is it possible to
provide a custom implementation of the serializer e.g. I want to use
MyAvroSerializer instead of AvroSerializer in *all* places. Is there any
way
