implement FlinkRescalingCompactionFilter for eliminating redundant keys in key groups
Implement FlinkRescalingCompactionFilter
, check the first bit (RescaleRound
) and further compare the key with the [Config::smallest_key, Config::largest]
to identify the current is to remove
, to keep
, or to change
.