state schema evolution for case classes

Posted by ApoorvK on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/state-schema-evolution-for-case-classes-tp33058.html

Hi Team,

Earlier we have developed on flink 1.6.2 , So there are lots of case classes
which have Map,Nested case class within them for example below :

case class MyCaseClass(var a: Boolean,
                                 var b: Boolean,
                                 var c: Boolean,
                                 var d: NestedCaseClass,
                                 var e:Int){
def this(){this(false,false,new NestedCaseClass,0)}
}


Now we have migrated to flink 1.8.2 , I need help to figure out how can I
achieve state schema evolution for such classes.

1. Is creating avro for these classes now, and implement avro serialisation
will that work ?
2. Or if I register kyroserialiser with protobuf serialiser at env?

Please suggest what can be done here, or redirect for the avros
serialisation example.

Thanks
                               



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/