pyflink.datastream.data_stream.KeyedStream.process#
- KeyedStream.process(func: KeyedProcessFunction, output_type: TypeInformation | None = None) DataStream[source]#
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.