org.apache.flink.table.planner.plan.utils

Class UpsertKeyUtil

java.lang.Object

org.apache.flink.table.planner.plan.utils.UpsertKeyUtil

public class UpsertKeyUtil
extends Object

Utility for upsertKey which represented as a Set of ImmutableBitSet.

Constructor Summary

Constructors

Constructor and Description
UpsertKeyUtil()

Method Summary

Modifier and Type	Method and Description
static int[]	getSmallestKey(Set<org.apache.calcite.util.ImmutableBitSet> upsertKeys) Returns the smallest key of given upsert keys.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UpsertKeyUtil

public UpsertKeyUtil()

Method Detail

getSmallestKey

@Nonnull
public static int[] getSmallestKey(@Nullable
                                            Set<org.apache.calcite.util.ImmutableBitSet> upsertKeys)

Returns the smallest key of given upsert keys. The rule of 'small' is an upsert key represented by ImmutableBitSet has smaller cardinality or has a smaller leading element when the same cardinality. E.g., '{0,1}' is smaller than '{0,1,2}' and '{0,1}' is smaller than '{0,2}'.

Parameters:

upsertKeys - input upsert keys

Returns:

the smallest key