pyflink.datastream.data_stream.DataStream.process#
- DataStream.process(func: pyflink.datastream.functions.ProcessFunction, output_type: Optional[pyflink.common.typeinfo.TypeInformation] = None) pyflink.datastream.data_stream.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 ProcessFunction that is called for each element in the stream.
output_type – TypeInformation for the result type of the function.
- Returns
The transformed DataStream.