public class CodeGeneratorImpl extends Object implements CodeGenerator
CodeGenerator
.Constructor and Description |
---|
CodeGeneratorImpl() |
Modifier and Type | Method and Description |
---|---|
GeneratedClass<NormalizedKeyComputer> |
generateNormalizedKeyComputer(List<org.apache.flink.table.types.logical.LogicalType> fieldTypes,
String name)
Generate a
NormalizedKeyComputer . |
GeneratedClass<Projection> |
generateProjection(String name,
org.apache.flink.table.types.logical.RowType inputType,
int[] inputMapping) |
GeneratedClass<RecordComparator> |
generateRecordComparator(List<org.apache.flink.table.types.logical.LogicalType> fieldTypes,
String name)
Generate a
RecordComparator . |
public GeneratedClass<Projection> generateProjection(String name, org.apache.flink.table.types.logical.RowType inputType, int[] inputMapping)
generateProjection
in interface CodeGenerator
public GeneratedClass<NormalizedKeyComputer> generateNormalizedKeyComputer(List<org.apache.flink.table.types.logical.LogicalType> fieldTypes, String name)
CodeGenerator
NormalizedKeyComputer
.generateNormalizedKeyComputer
in interface CodeGenerator
fieldTypes
- Both the input row field types and the sort key field types. 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.public GeneratedClass<RecordComparator> generateRecordComparator(List<org.apache.flink.table.types.logical.LogicalType> fieldTypes, String name)
CodeGenerator
RecordComparator
.generateRecordComparator
in interface CodeGenerator
fieldTypes
- Both the input row field types and the sort key field types. 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.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.