org.apache.paimon.utils

Class UserDefinedSeqComparator

java.lang.Object

org.apache.paimon.utils.UserDefinedSeqComparator

All Implemented Interfaces:

Comparator<InternalRow>, FieldsComparator

public class UserDefinedSeqComparator
extends Object
implements FieldsComparator

A FieldsComparator for user defined sequence fields.

Constructor Summary

Constructors

Constructor and Description
UserDefinedSeqComparator(int[] fields, RecordComparator comparator)

Method Summary

Modifier and Type	Method and Description
int	compare(InternalRow o1, InternalRow o2)
int[]	compareFields()
static UserDefinedSeqComparator	create(RowType rowType, CoreOptions options)
static UserDefinedSeqComparator	create(RowType rowType, int[] sequenceFields, boolean isAscendingOrder)
static UserDefinedSeqComparator	create(RowType rowType, List<String> sequenceFields, boolean isAscendingOrder)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Comparator

comparing, comparing, comparingDouble, comparingInt, comparingLong, equals, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong

Constructor Detail

UserDefinedSeqComparator

public UserDefinedSeqComparator(int[] fields,
                                RecordComparator comparator)

Method Detail

compareFields

public int[] compareFields()

Specified by:

compareFields in interface FieldsComparator

compare

public int compare(InternalRow o1,
                   InternalRow o2)

Specified by:

compare in interface Comparator<InternalRow>

create

@Nullable
public static UserDefinedSeqComparator create(RowType rowType,
                                                        CoreOptions options)

create

@Nullable
public static UserDefinedSeqComparator create(RowType rowType,
                                                        List<String> sequenceFields,
                                                        boolean isAscendingOrder)

create

@Nullable
public static UserDefinedSeqComparator create(RowType rowType,
                                                        int[] sequenceFields,
                                                        boolean isAscendingOrder)