public class HiveRowDataPartitionComputer extends RowDataPartitionComputer
RowDataPartitionComputer
that converts Flink objects to Hive objects before computing
the partition value strings.defaultPartValue, nonPartitionFieldGetters, partitionColumns, partitionFieldGetters, partitionIndexes, partitionTypes
Constructor and Description |
---|
HiveRowDataPartitionComputer(HiveShim hiveShim,
String defaultPartValue,
String[] columnNames,
DataType[] columnTypes,
String[] partitionColumns) |
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,String> |
generatePartValues(RowData in)
Compute partition values from record.
|
projectColumnsToWrite
public LinkedHashMap<String,String> generatePartValues(RowData in)
PartitionComputer
generatePartValues
in interface PartitionComputer<RowData>
generatePartValues
in class RowDataPartitionComputer
in
- input record.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.