如何获取flink sql的血缘关系?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

如何获取flink sql的血缘关系?

casel.chen
如何获取flink sql的血缘关系?如:表A -> 表B。有代码示例吗?谢谢!
Reply | Threaded
Open this post in threaded view
|

Re: 如何获取flink sql的血缘关系?

LakeShen
一种方法就是借助 Flink SQL Parser,解析你的 SQL,然后获取到不同的 SQL node,
然后每个 SQL Node 都有对应的类型,以及 connector 后面的 with 参数,你需要自己在
写代码判定一下即可。本质是通过解析 SQL,来获取血缘关系。

Best,
LakeShen

casel.chen <[hidden email]> 于2021年6月8日周二 上午12:05写道:

> 如何获取flink sql的血缘关系?如:表A -> 表B。有代码示例吗?谢谢!