pyflink.datastream.data_stream.CachedDataStream.process

CachedDataStream.process(func: pyflink.datastream.functions.ProcessFunction, 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 ProcessFunction that is called for each element in the stream.

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

Returns

The transformed DataStream.