pyflink.datastream.data_stream.CachedDataStream.invalidate

CachedDataStream.invalidate()

Invalidate the cache intermediate result of this DataStream to release the physical resources. Users are not required to invoke this method to release physical resources unless they want to. Cache will be recreated if it is used after invalidated.

New in version 1.16.0.