org.apache.paimon.flink.sink

Interface StoreSinkWriteState.StateValueFilter

Enclosing class:

StoreSinkWriteState

public static interface StoreSinkWriteState.StateValueFilter

Given the table name, partition and bucket of a StoreSinkWriteState.StateValue in a union list state, decide whether to keep this StoreSinkWriteState.StateValue in this subtask.

Method Summary

Modifier and Type	Method and Description
boolean	filter(String tableName, BinaryRow partition, int bucket)

Method Detail

filter

boolean filter(String tableName,
               BinaryRow partition,
               int bucket)