pyflink.datastream.data_stream.CachedDataStream.process

CachedDataStream.process(func: ProcessFunction, output_type: Optional[TypeInformation] = None) → 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.