I have implemented a Cassandra sink and when I am trying to call it from another class via DataStream it is not calling any of the methods. I tried extending other interfaces like ProcessFunction and it is forcing me to implement its methods whereas. when it comes to RichSinkFunction it doesn't force me to do it. Is my problem due to this? or there is something else to it?
https://stackoverflow.com/questions/70592174/richsinkfunction-for-cassandra-in-flink/70593375
