DataFunSummit
May 10, 2023 · Big Data
Field-Level Data Lineage Extraction for FlinkSQL Using Apache Calcite
This article explains how to derive field‑level data lineage for FlinkSQL by leveraging Apache Calcite, covering the Calcite framework, FlinkSQL execution stages, the three‑step parsing approach, core source code details, practical Insert/Join examples, and extensions for lookup joins and UDTFs.
Apache CalciteFlinkSQLRelNode
0 likes · 12 min read