org.apache.flink.connectors.hive

类 HiveRowDataPartitionComputer

java.lang.Object

org.apache.flink.table.filesystem.RowDataPartitionComputer

org.apache.flink.connectors.hive.HiveRowDataPartitionComputer

所有已实现的接口:

Serializable, org.apache.flink.table.filesystem.PartitionComputer<org.apache.flink.table.data.RowData>

public class HiveRowDataPartitionComputer
extends org.apache.flink.table.filesystem.RowDataPartitionComputer

A RowDataPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.

另请参阅:

序列化表格

字段概要

从类继承的字段 org.apache.flink.table.filesystem.RowDataPartitionComputer

defaultPartValue, partitionColumns, partitionIndexes, partitionTypes

构造器概要

构造器

构造器和说明
HiveRowDataPartitionComputer(HiveShim hiveShim, String defaultPartValue, String[] columnNames, org.apache.flink.table.types.DataType[] columnTypes, String[] partitionColumns)

方法概要

限定符和类型	方法和说明
LinkedHashMap<String,String>	generatePartValues(org.apache.flink.table.data.RowData in)

从类继承的方法 org.apache.flink.table.filesystem.RowDataPartitionComputer

projectColumnsToWrite

从类继承的方法 java.lang.Object

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

构造器详细资料

HiveRowDataPartitionComputer

public HiveRowDataPartitionComputer(HiveShim hiveShim,
                                    String defaultPartValue,
                                    String[] columnNames,
                                    org.apache.flink.table.types.DataType[] columnTypes,
                                    String[] partitionColumns)

方法详细资料

generatePartValues

public LinkedHashMap<String,String> generatePartValues(org.apache.flink.table.data.RowData in)

指定者:

generatePartValues 在接口中 org.apache.flink.table.filesystem.PartitionComputer<org.apache.flink.table.data.RowData>

覆盖:

generatePartValues 在类中 org.apache.flink.table.filesystem.RowDataPartitionComputer