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

Class 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

All Implemented Interfaces:

Serializable, HiveShim

Direct Known Subclasses:

HiveShimV111

public class HiveShimV110
extends HiveShimV101

Shim for Hive version 1.1.0.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV100

holdDDLTime, inheritTableSpecs, isAcid, isSkewedStoreAsSubdir

Constructor Summary

Constructors

Constructor and Description
HiveShimV110()

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV100

alterPartition, alterTable, createOrcBulkWriterFactory, createTableWithConstraints, createUDAFParameterInfo, getBuiltInFunctionInfo, getDateDataTypeClass, getDateWritableClass, getHiveMetastoreClient, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, getPrimaryKey, getTimestampDataTypeClass, getTimestampWritableClass, getViews, hivePrimitiveToWritable, isDateStats, listBuiltInFunctions, loadPartition, loadTable, registerTemporaryFunction, toFlinkDate, toFlinkDateColStats, toFlinkTimestamp, toHiveDate, toHiveDateColStats, toHiveTimestamp

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.catalog.hive.client.HiveShim

getIntervalDayTimeTypeInfo, getIntervalYearMonthTypeInfo, isIntervalDayTimeType, isIntervalYearMonthType, isMaterializedView

Constructor Detail

HiveShimV110

public HiveShimV110()

Method Detail

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)

Description copied from interface: HiveShim

Get Hive's FileSinkOperator.RecordWriter.

Specified by:

getHiveRecordWriter in interface HiveShim

Overrides:

getHiveRecordWriter in class HiveShimV100

getHiveOutputFormatClass

public Class getHiveOutputFormatClass(Class outputFormatClz)

Description copied from interface: HiveShim

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

Specified by:

getHiveOutputFormatClass in interface HiveShim

Overrides:

getHiveOutputFormatClass in class 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)

Description copied from interface: HiveShim

Get Hive table schema from deserializer.

Specified by:

getFieldsFromDeserializer in interface HiveShim

Overrides:

getFieldsFromDeserializer in class HiveShimV100