序列化表格

程序包 org.apache.flink.connectors.hive

类org.apache.flink.connectors.hive.FlinkHiveException扩展RuntimeException实现可序列化

类org.apache.flink.connectors.hive.HadoopFileSystemFactory扩展Object实现可序列化

serialVersionUID:

1L

序列化字段

jobConfWrapper

JobConfWrapper jobConfWrapper

类org.apache.flink.connectors.hive.HiveOutputFormatFactory扩展Object实现可序列化

serialVersionUID:

1L

序列化字段

hiveOutputFormatClz

Class<T> hiveOutputFormatClz

serDeInfo

org.apache.hadoop.hive.metastore.api.SerDeInfo serDeInfo

allColumns

String[] allColumns

allTypes

org.apache.flink.table.types.DataType[] allTypes

partitionColumns

String[] partitionColumns

tableProperties

Properties tableProperties

confWrapper

JobConfWrapper confWrapper

hiveShim

HiveShim hiveShim

isCompressed

boolean isCompressed

类org.apache.flink.connectors.hive.HivePartitionComputer扩展org.apache.flink.table.filesystem.RowPartitionComputer实现可序列化

serialVersionUID:

1L

序列化字段

partColConversions

HiveObjectConversion[] partColConversions

类org.apache.flink.connectors.hive.HiveTableMetaStoreFactory扩展Object实现可序列化

serialVersionUID:

1L

序列化字段

conf

JobConfWrapper conf

hiveVersion

String hiveVersion

database

String database

tableName

String tableName

类org.apache.flink.connectors.hive.HiveTablePartition扩展Object实现可序列化

serialVersionUID:

4145470177119940673L

序列化字段

storageDescriptor

org.apache.hadoop.hive.metastore.api.StorageDescriptor storageDescriptor

Partition storage descriptor.

partitionSpec

Map<K,V> partitionSpec

The map of partition key names and their values.

tableProps

Properties tableProps

类org.apache.flink.connectors.hive.JobConfWrapper扩展Object实现可序列化

serialVersionUID:

1L

序列化方法

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

抛出:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

抛出:

IOException

序列化字段

jobConf

org.apache.hadoop.mapred.JobConf jobConf

程序包 org.apache.flink.connectors.hive.read

类org.apache.flink.connectors.hive.read.HiveTableInputFormat扩展org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase<org.apache.flink.table.dataformat.BaseRow,HiveTableInputSplit>实现可序列化

serialVersionUID:

1L

序列化方法

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

抛出:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

抛出:

IOException

序列化字段

jobConf

org.apache.hadoop.mapred.JobConf jobConf

hiveVersion

String hiveVersion

partitionKeys

List<E> partitionKeys

fieldTypes

org.apache.flink.table.types.DataType[] fieldTypes

fieldNames

String[] fieldNames

partitions

List<E> partitions

selectedFields

int[] selectedFields

limit

long limit

useMapRedReader

boolean useMapRedReader

类org.apache.flink.connectors.hive.read.HiveTableInputSplit扩展org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit实现可序列化

序列化字段

hiveTablePartition

HiveTablePartition hiveTablePartition

程序包 org.apache.flink.table.catalog.hive.client

类org.apache.flink.table.catalog.hive.client.HiveShimV100扩展Object实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV101扩展HiveShimV100实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV110扩展HiveShimV101实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV111扩展HiveShimV110实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV120扩展HiveShimV111实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV121扩展HiveShimV120实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV122扩展HiveShimV121实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV200扩展HiveShimV122实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV201扩展HiveShimV200实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV210扩展HiveShimV201实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV211扩展HiveShimV210实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV220扩展HiveShimV211实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV230扩展HiveShimV220实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV231扩展HiveShimV230实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV232扩展HiveShimV231实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV233扩展HiveShimV232实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV234扩展HiveShimV233实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV235扩展HiveShimV234实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV236扩展HiveShimV235实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV310扩展HiveShimV235实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV311扩展HiveShimV310实现可序列化

类org.apache.flink.table.catalog.hive.client.HiveShimV312扩展HiveShimV311实现可序列化

程序包 org.apache.flink.table.functions.hive

类org.apache.flink.table.functions.hive.FlinkHiveUDFException扩展org.apache.flink.util.FlinkRuntimeException实现可序列化

类org.apache.flink.table.functions.hive.HiveFunctionWrapper扩展Object实现可序列化

serialVersionUID:

393313529306818205L

序列化字段

className

String className

类org.apache.flink.table.functions.hive.HiveGenericUDAF扩展org.apache.flink.table.functions.AggregateFunction<Object,org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer>实现可序列化

序列化字段

hiveFunctionWrapper

HiveFunctionWrapper<UDFType> hiveFunctionWrapper

isUDAFBridgeRequired

boolean isUDAFBridgeRequired

constantArguments

Object[] constantArguments

argTypes

org.apache.flink.table.types.DataType[] argTypes

hiveShim

HiveShim hiveShim

类org.apache.flink.table.functions.hive.HiveGenericUDF扩展HiveScalarFunction<org.apache.hadoop.hive.ql.udf.generic.GenericUDF>实现可序列化

序列化字段

hiveShim

HiveShim hiveShim

类org.apache.flink.table.functions.hive.HiveGenericUDTF扩展org.apache.flink.table.functions.TableFunction<org.apache.flink.types.Row>实现可序列化

序列化字段

hiveFunctionWrapper

HiveFunctionWrapper<UDFType> hiveFunctionWrapper

constantArguments

Object[] constantArguments

argTypes

org.apache.flink.table.types.DataType[] argTypes

hiveShim

HiveShim hiveShim

类org.apache.flink.table.functions.hive.HiveScalarFunction扩展org.apache.flink.table.functions.ScalarFunction实现可序列化

序列化字段

hiveFunctionWrapper

HiveFunctionWrapper<UDFType> hiveFunctionWrapper

constantArguments

Object[] constantArguments

argTypes

org.apache.flink.table.types.DataType[] argTypes

类org.apache.flink.table.functions.hive.HiveSimpleUDF扩展HiveScalarFunction<org.apache.hadoop.hive.ql.exec.UDF>实现可序列化

序列化字段

hiveShim

HiveShim hiveShim

程序包 org.apache.flink.table.functions.hive.conversion

类org.apache.flink.table.functions.hive.conversion.IdentityConversion扩展Object实现可序列化

serialVersionUID:

1L

类org.apache.flink.table.functions.hive.conversion.WritableHiveObjectConversion扩展Object实现可序列化

serialVersionUID:

1L

序列化字段

flinkToJavaConversion

HiveObjectConversion flinkToJavaConversion

hiveShim

HiveShim hiveShim