org.apache.flink.fnexecution.v1

Interface FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategyOrBuilder

All Superinterfaces:

com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder

All Known Implementing Classes:

FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategy, FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategy.Builder

Enclosing class:

FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies

public static interface FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategyOrBuilder
extends com.google.protobuf.MessageOrBuilder

Method Summary

Modifier and Type	Method and Description
int	getCleanupSize() Max number of keys pulled from queue for clean up upon state touch for any key.
boolean	getRunCleanupForEveryRecord() Whether to run incremental cleanup per each processed record.

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

isInitialized

Method Detail

getCleanupSize

int getCleanupSize()

 Max number of keys pulled from queue for clean up upon state touch for any key.
 

int32 cleanup_size = 1;

Returns:

The cleanupSize.

getRunCleanupForEveryRecord

boolean getRunCleanupForEveryRecord()

 Whether to run incremental cleanup per each processed record.
 

bool run_cleanup_for_every_record = 2;

Returns:

The runCleanupForEveryRecord.