org.apache.paimon.codegen

Class CodeGenUtils

java.lang.Object

org.apache.paimon.codegen.CodeGenUtils

public class CodeGenUtils
extends Object

Utils for code generations.

Field Summary

Fields

Modifier and Type	Field and Description
static Projection	EMPTY_PROJECTION

Constructor Summary

Constructors

Constructor and Description
CodeGenUtils()

Method Summary

Modifier and Type	Method and Description
static NormalizedKeyComputer	newNormalizedKeyComputer(List<DataType> inputTypes, int[] sortFields)
static Projection	newProjection(RowType inputType, int[] mapping)
static Projection	newProjection(RowType inputType, List<String> fields)
static RecordComparator	newRecordComparator(List<DataType> inputTypes)
static RecordComparator	newRecordComparator(List<DataType> inputTypes, int[] sortFields, boolean isAscendingOrder)
static RecordEqualiser	newRecordEqualiser(List<DataType> fieldTypes)
static RecordEqualiser	newRecordEqualiser(List<DataType> fieldTypes, int[] fields)

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_PROJECTION

public static final Projection EMPTY_PROJECTION

Constructor Detail

CodeGenUtils

public CodeGenUtils()

Method Detail

newProjection

public static Projection newProjection(RowType inputType,
                                       List<String> fields)

newProjection

public static Projection newProjection(RowType inputType,
                                       int[] mapping)

newNormalizedKeyComputer

public static NormalizedKeyComputer newNormalizedKeyComputer(List<DataType> inputTypes,
                                                             int[] sortFields)

newRecordComparator

public static RecordComparator newRecordComparator(List<DataType> inputTypes)

newRecordComparator

public static RecordComparator newRecordComparator(List<DataType> inputTypes,
                                                   int[] sortFields,
                                                   boolean isAscendingOrder)

newRecordEqualiser

public static RecordEqualiser newRecordEqualiser(List<DataType> fieldTypes)

newRecordEqualiser

public static RecordEqualiser newRecordEqualiser(List<DataType> fieldTypes,
                                                 int[] fields)