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()))