public class RowDataPartitionComputer extends Object
RowData
.Modifier and Type | Field and Description |
---|---|
protected String |
defaultPartValue |
protected String[] |
partitionColumns |
protected org.apache.flink.table.data.RowData.FieldGetter[] |
partitionFieldGetters |
Constructor and Description |
---|
RowDataPartitionComputer(String defaultPartValue,
org.apache.flink.table.types.logical.RowType rowType,
String[] partitionColumns) |
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,String> |
generatePartValues(org.apache.flink.table.data.RowData in) |
protected final String defaultPartValue
protected final String[] partitionColumns
protected final org.apache.flink.table.data.RowData.FieldGetter[] partitionFieldGetters
public LinkedHashMap<String,String> generatePartValues(org.apache.flink.table.data.RowData in)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.