You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2021/06/07 16:04:51 UTC

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

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

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

Posted by LakeShen <sh...@gmail.com>.

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

Best，
LakeShen

casel.chen <ca...@126.com> 于2021年6月8日周二 上午12:05写道：

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