pyflink中Transform里的connect的使用方法是什么?
当command_stream没有数据进来的时候,http_data_stream的输出无论如何都是还没配置,当command_stream写入数据后,会执行map2的方法,即更新了配置项,对于接下来的http_data_stream来说就会以新的配置项来执行,输出为已经配置
class MyCoMapFunction(CoMapFunction):
message = "还没配置"
def map1(self, value):
return MyCoMapFunction.test
def map2(self, value):
# 修改某个配置项
MyCoMapFunction.test = "已经配置"
return []
http_data_stream = http_data_stream.connect(command_stream).key_by(lambda x: 0, lambda x: 0).map(
MyCoMapFunction(), Types.LIST(Types.STRING()))
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。