pyflink.datastream.data_stream.ConnectedStreams.process

ConnectedStreams.process(func: CoProcessFunction | KeyedCoProcessFunction, output_type: TypeInformation | None = None) → DataStream