pyflink.datastream.data_stream.DataStream.cache#
- DataStream.cache() CachedDataStream[source]#
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.
Added in version 1.16.0.