org.apache.flink.table.catalog.hive.client

类 HiveShimV110

java.lang.Object

org.apache.flink.table.catalog.hive.client.HiveShimV100

org.apache.flink.table.catalog.hive.client.HiveShimV101

org.apache.flink.table.catalog.hive.client.HiveShimV110

所有已实现的接口:

Serializable, HiveShim

直接已知子类:

HiveShimV111

public class HiveShimV110
extends HiveShimV101

Shim for Hive version 1.1.0.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
HiveShimV110()

方法概要

限定符和类型	方法和说明
List<org.apache.hadoop.hive.metastore.api.FieldSchema>	getFieldsFromDeserializer(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hive.metastore.api.Table table, boolean skipConfError) Get Hive table schema from deserializer.
Class	getHiveOutputFormatClass(Class outputFormatClz) For a given OutputFormat class, get the corresponding HiveOutputFormat class.
org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter	getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jobConf, Class outputFormatClz, Class<? extends org.apache.hadoop.io.Writable> outValClz, boolean isCompressed, Properties tableProps, org.apache.hadoop.fs.Path outPath) Get Hive's FileSinkOperator.RecordWriter.

从类继承的方法 org.apache.flink.table.catalog.hive.client.HiveShimV100

alterPartition, alterTable, createUDAFParameterInfo, getBuiltInFunctionInfo, getDateDataTypeClass, getHiveMetastoreClient, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, getPrimaryKey, getTimestampDataTypeClass, getViews, hivePrimitiveToWritable, isDateStats, listBuiltInFunctions, toFlinkDate, toFlinkDateColStats, toFlinkTimestamp, toHiveDate, toHiveDateColStats, toHiveTimestamp

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

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

构造器详细资料

HiveShimV110

public HiveShimV110()

方法详细资料

getHiveRecordWriter

public org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jobConf,
                                                                                        Class outputFormatClz,
                                                                                        Class<? extends org.apache.hadoop.io.Writable> outValClz,
                                                                                        boolean isCompressed,
                                                                                        Properties tableProps,
                                                                                        org.apache.hadoop.fs.Path outPath)

从接口复制的说明: HiveShim

Get Hive's FileSinkOperator.RecordWriter.

指定者:

getHiveRecordWriter 在接口中 HiveShim

覆盖:

getHiveRecordWriter 在类中 HiveShimV100

getHiveOutputFormatClass

public Class getHiveOutputFormatClass(Class outputFormatClz)

从接口复制的说明: HiveShim

For a given OutputFormat class, get the corresponding HiveOutputFormat class.

指定者:

getHiveOutputFormatClass 在接口中 HiveShim

覆盖:

getHiveOutputFormatClass 在类中 HiveShimV100

getFieldsFromDeserializer

public List<org.apache.hadoop.hive.metastore.api.FieldSchema> getFieldsFromDeserializer(org.apache.hadoop.conf.Configuration conf,
                                                                                        org.apache.hadoop.hive.metastore.api.Table table,
                                                                                        boolean skipConfError)

从接口复制的说明: HiveShim

Get Hive table schema from deserializer.

指定者:

getFieldsFromDeserializer 在接口中 HiveShim

覆盖:

getFieldsFromDeserializer 在类中 HiveShimV100