org.apache.paimon.codegen

Interface CodeGenerator

All Known Implementing Classes:

CodeGeneratorImpl

public interface CodeGenerator

GeneratedClass generator.

Method Summary

Modifier and Type	Method and Description
GeneratedClass<NormalizedKeyComputer>	generateNormalizedKeyComputer(List<DataType> inputTypes, int[] sortFields) Generate a NormalizedKeyComputer.
GeneratedClass<Projection>	generateProjection(RowType inputType, int[] inputMapping)
GeneratedClass<RecordComparator>	generateRecordComparator(List<DataType> inputTypes, int[] sortFields, boolean isAscendingOrder) Generate a RecordComparator.
GeneratedClass<RecordEqualiser>	generateRecordEqualiser(List<DataType> fieldTypes, int[] fields) Generate a RecordEqualiser with fields.

Method Detail

generateProjection

GeneratedClass<Projection> generateProjection(RowType inputType,
                                              int[] inputMapping)

generateNormalizedKeyComputer

GeneratedClass<NormalizedKeyComputer> generateNormalizedKeyComputer(List<DataType> inputTypes,
                                                                    int[] sortFields)

Generate a NormalizedKeyComputer.

Parameters:

inputTypes - input types.

sortFields - the sort key fields. Records are compared by the first field, then the second field, then the third field and so on. All fields are compared in ascending order.

generateRecordComparator

GeneratedClass<RecordComparator> generateRecordComparator(List<DataType> inputTypes,
                                                          int[] sortFields,
                                                          boolean isAscendingOrder)

Generate a RecordComparator.

Parameters:

inputTypes - input types.

sortFields - the sort key fields. Records are compared by the first field, then the second field, then the third field and so on. All fields are compared in ascending order.

isAscendingOrder - decide the sort key fields order whether is ascending

generateRecordEqualiser

GeneratedClass<RecordEqualiser> generateRecordEqualiser(List<DataType> fieldTypes,
                                                        int[] fields)

Generate a RecordEqualiser with fields.