Hi Caizhi,
Thanks for your reply. Much appreciated. I understood the difference now.
Also, I have a flow like Kafka Sink Datastream -> Process Function
(Separate Class) -> Cassandra Sink(Separate Class).
Process Function returns me the output as a string and now I want to create
a DataStream out
Hi!
This is because ProcessFunction#processElement is a must while all methods
in SinkFunction are not mandatory (for example you can create a sink which
just discards all records by directly implementing SinkFunction). However
if you want your sink to be more useful you'll have to see which metho
