pyflink.datastream.data_stream.ConnectedStreams.process

ConnectedStreams.process(func: Union[CoProcessFunction, KeyedCoProcessFunction], output_type: Optional[TypeInformation] = None) → DataStream