How to read kudu table periodically and cache it in flink which is further used as filtering

41 views Asked by At

I am very new to Flink. I have to create a pipeline that will read streaming data from Kafka, read a kudu table every 10 mins (refresh kudu table data every 10 mins), perform join operation, and then finally store to another kudu table. In spark we can read the kudu table as a data frame and then cache that data frame but how to do the same thing in Flink?

Also, it will be really helpful if I get some examples regarding reading from Kudu to flink.

0

There are 0 answers