public class KeyComparatorSupplier extends Object implements org.apache.flink.util.function.SerializableSupplier<Comparator<org.apache.flink.table.data.RowData>>
Supplier
that returns the comparator for the file store key.Constructor and Description |
---|
KeyComparatorSupplier(org.apache.flink.table.types.logical.RowType keyType) |
public KeyComparatorSupplier(org.apache.flink.table.types.logical.RowType keyType)
public RecordComparator get()
get
in interface java.util.function.Supplier<Comparator<org.apache.flink.table.data.RowData>>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.