Google BigQuery as Sink

We need to create custom Sink to be able to store data to Google BigQuery.

circle-info

We need to import and extend this class: org.apache.flink.streaming.api.functions.sink.RichSinkFunction;and override invoke function.

Last updated