split avro kafka field

Posted by Youzha on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/split-avro-kafka-field-tp39486.html

hi, i’am a new comer to learn flink stream. and i wanna try to split the kafka avro field into multiple fields.

for example i have this one in my kafka topic :

{ 

   id : 12345,

   name : “john”,

   location : “indonesia;jakarta;south jakarta”

}

and then i wanna split the location value by “;” into this one :

{ 

   id : 12345,

   name : “john”,

   country : “indonesia”,

   city : “jakarta”,

   locality : “south jakarta”

}

how can i do this with flink stream? 

need advice.