用Table API的话，可以看一下这个： https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/tableapi/#joins <https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/tableapi/#joins>
另外，也可以直接在PyFlink中调用SQL语句： https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/python/table/intro_to_table_api/#write-sql-queries <https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/python/table/intro_to_table_api/#write-sql-queries> > 2021年5月17日 上午10:28，qianhuan <[email protected]> 写道： > > 想实现pyflink双流join，没有找到相关示例，有没有大神指导下用pyflink是否能实现？ > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
