pyflink.datastream.data_stream.CachedDataStream.cache

CachedDataStream.cache() → pyflink.datastream.data_stream.CachedDataStream

Cache the intermediate result of the transformation. Only support bounded streams and currently only block mode is supported. The cache is generated lazily at the first time the intermediate result is computed. The cache will be clear when the StreamExecutionEnvironment close.

Returns

The cached DataStream that can use in later job to reuse the cached intermediate result.

New in version 1.16.0.