yepeng05 / flink-sql-lineage Goto Github PK
View Code? Open in Web Editor NEWThis project forked from hamawhitegg/flink-sql-lineage
FlinkSQL字段血缘解决方案及源码。FlinkSQL field lineage solution and source code, The core idea is to parse SQL through Calcite to generate a RelNode tree of relational expressions. Then get the optimized logical paln through optimization stage, and finally call Calcite RelMetadataQuery to get the lineage relationship at the field level.
License: Apache License 2.0