序列化表格

程序包 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.HiveRowDataPartitionComputer扩展org.apache.flink.table.filesystem.RowDataPartitionComputer实现可序列化

序列化字段

partitionConverters

org.apache.flink.table.data.util.DataFormatConverters.DataFormatConverter<Internal,External>[] partitionConverters

hiveObjectConversions

HiveObjectConversion[] hiveObjectConversions

类org.apache.flink.connectors.hive.HiveRowPartitionComputer扩展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.HiveContinuousMonitoringFunction扩展org.apache.flink.streaming.api.functions.source.RichSourceFunction<TimestampedHiveInputSplit>实现可序列化

serialVersionUID:

1L

序列化字段

readerParallelism

int readerParallelism

The parallelism of the downstream readers.

interval

long interval

The interval between consecutive path scans.

hiveShim

HiveShim hiveShim

conf

JobConfWrapper conf

tablePath

org.apache.flink.table.catalog.ObjectPath tablePath

partitionKeys

List<E> partitionKeys

fieldNames

String[] fieldNames

fieldTypes

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

consumeOrder

ConsumeOrder consumeOrder

consumeOffset

String consumeOffset

extractorKind

String extractorKind

extractorClass

String extractorClass

extractorPattern

String extractorPattern

isRunning

boolean isRunning

currentReadTime

long currentReadTime

The maximum partition read time seen so far.

类org.apache.flink.connectors.hive.read.HiveTableFileInputFormat扩展org.apache.flink.api.common.io.FileInputFormat<org.apache.flink.table.data.RowData>实现可序列化

序列化字段

inputFormat

HiveTableInputFormat inputFormat

hiveTablePartition

HiveTablePartition hiveTablePartition

类org.apache.flink.connectors.hive.read.HiveTableInputFormat扩展org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase<org.apache.flink.table.data.RowData,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实现可序列化

serialVersionUID:

1L

序列化字段

hiveTablePartition

HiveTablePartition hiveTablePartition

类org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit扩展HiveTableInputSplit实现可序列化

serialVersionUID:

1L

序列化字段

modificationTime

long modificationTime

The modification time of the file this split belongs to.

splitState

Serializable splitState

The state of the split. This information is used when restoring from a checkpoint and allows to resume reading the underlying file from the point we left off.

类org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit.SplitTypeInfoFactory扩展org.apache.flink.api.common.typeinfo.TypeInfoFactory<TimestampedHiveInputSplit>实现可序列化

serialVersionUID:

1L

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

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

serialVersionUID:

1L

序列化字段

factory

HiveWriterFactory factory

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

serialVersionUID:

2L

序列化字段

factory

HiveWriterFactory factory

类org.apache.flink.connectors.hive.write.HiveWriterFactory扩展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.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