pyflink.datastream.data_stream.KeyedStream.process

KeyedStream.process(func: pyflink.datastream.functions.KeyedProcessFunction, output_type: Optional[pyflink.common.typeinfo.TypeInformation] = None) → pyflink.datastream.data_stream.DataStream

Applies the given ProcessFunction on the input stream, thereby creating a transformed output stream.

The function will be called for every element in the input streams and can produce zero or more output elements.

Parameters

• func – The KeyedProcessFunction that is called for each element in the stream.

• output_type – TypeInformation for the result type of the function.

Returns

The transformed DataStream.