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下一个简单例子呢。

回复