how to extract column&table lineage from flink sql

491 views Asked by At

I want to build a lineage system for a real-time data warehouse,how can I extract table and column lineage from flink sql?

1

There are 1 answers

0
morsapaes On

In addition to the answer in the Flink User Mailing List, I'd like to point out that there is ongoing work in the community to integrate Flink with Apache Atlas. This could be a more viable option for data governance than building your own custom implementation.

You can get some pointers in the initial discussion.