We need to create custom Sink to be able to store data to Google BigQuery.
We need to import and extend this class: org.apache.flink.streaming.api.functions.sink.RichSinkFunction;and override invoke function.
org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
invoke
Last updated 6 years ago