pyflink.datastream.state.StateTtlConfig.Builder.cleanup_in_rocksdb_compact_filter#
- Builder.cleanup_in_rocksdb_compact_filter(query_time_after_num_entries) pyflink.datastream.state.StateTtlConfig.Builder #
Cleanup expired state while Rocksdb compaction is running.
RocksDB compaction filter will query current timestamp, used to check expiration, from Flink every time after processing {@code queryTimeAfterNumEntries} number of state entries. Updating the timestamp more often can improve cleanup speed but it decreases compaction performance because it uses JNI call from native code.
- Parameters
query_time_after_num_entries – number of state entries to process by compaction filter before updating current timestamp
- Returns