Hi, 你需要什么样的例子,如果你用的table/sql的话,在官方文档对应的地方都有java/scala/python的对应写法。如果是python udf相关的东西,你可以参考[1]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/ Best, Xingbo 小学生 <[email protected]> 于2020年7月16日周四 上午11:14写道: > 谢谢两位大佬的解答,但是理解有点抽象,不太清楚,有没有pyflink下一个简单例子呢。
