Hi Team,

I have a generic Question.

Let's say I have 2 Actions to be taken on Flink DATASTREAM (Kafka).
1) Convert some data fields, and write to external Database
2) Transform #1 converted data fields in to different record format say AVRO

*Here are Two approaches that are possible.*

a) One Map function doing both #1 and #2 actions

*datastream.map(1)*

b) Two maps doing separate Actions #1 and #2 .

 *datastream.map().map(1).map(2)     *

Which one would you prefer ?

Is there a way I can see Execution plan ?

Regards,
Vijay

Reply via email to