flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shashank agarwal <shashank...@gmail.com>
Subject Can i use Avro serializer as default instead of kryo serializer in Flink for scala API ?
Date Sat, 23 Sep 2017 08:11:28 GMT
Hello Team,

As our schema evolves due to business logics. We want to use expendable
schema like Avro as default serializer and deserializer for flink program
and states.

My doubt is, We are using Scala API in our flink program, But Avro default
supports Java POJO. So how we can use this in our scala APi should we have
to use serializer like Avro4s ? Or we can use default Avro in our Scala
flink app than what will be the steps ?

Please guide.

Thanks Regards

 ---  Trying to mobilize the things....


View raw message