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 methods in SinkFunction you need to implement. For example you can deal with the records fed to the sink in the invoke method or clean up the resources in the finish method.
Siddhesh Kalgaonkar <kalgaonkarsiddh...@gmail.com> 于2022年1月6日周四 03:11写道： > 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 >
