用python写flink程序,从哪里import各种operation?

2019-08-20 文章
在使用python写flink程序的时候,使用各种operation需要从不同的模块调用,官方给的几个样例的代码只用了部分的operation,在实际使用的时候,各种operation都应该从哪里调用呢?现在想使用WindowFunction,试了几个模块都不对。 发送自 Windows 10 版邮件应用

用python写flink程序,从哪里import各种operation?

2019-08-20 文章
在使用python写flink程序的时候,使用各种operation需要从不同的模块调用,官方给的几个样例的代码只用了部分的operation,在实际使用的时候,各种operation都应该从哪里调用呢?现在想使用WindowFunction,试了几个模块都不对。 发送自 Windows 10 版邮件应用