1
条回答
写回答
写回答
-
数据流处理的框架 这个框架是同时运行在多台主机上 通过某种方式这多台主机之间可以通信 可以单机运行 pyflink只是对java的flink的一个调用工具，不能直接用python来对source、sink组件进行实现。 对于其他方面pyflink与其他普通python程序无异。
我们把输入叫做source，处理叫做transform，输出叫做sink。
因为是多台主机同时运行的，所以不会支持单机的输入和单机的输出，所以常规的标准输入输出准确的来说是不适用的，所以尽量不要使用print和input之类的方法。另外还有一个pyflink与普通python程序有非常大的不同的地方是，有一部分代码运行在python环境中，有一部分代码运行在jre中，这也对初学者理解pyflink产生了干扰。
2021-12-07 15:24:59赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
