Serialized Form (Flink : Connectors : Hive 1.12.2 API)

Package org.apache.flink.connectors.hive
- Class org.apache.flink.connectors.hive.CachedSerializedValue extends org.apache.flink.util.SerializedValue<T> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connectors.hive.FlinkHiveException extends RuntimeException implements Serializable
- Class org.apache.flink.connectors.hive.HadoopFileSystemFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
- Class org.apache.flink.connectors.hive.HiveRowDataPartitionComputer extends org.apache.flink.table.filesystem.RowDataPartitionComputer implements Serializable
  - Serialized Fields
    - partitionConverters
```
org.apache.flink.table.data.util.DataFormatConverters.DataFormatConverter<Internal,External>[] partitionConverters
```
    - hiveObjectConversions
```
HiveObjectConversion[] hiveObjectConversions
```
- Class org.apache.flink.connectors.hive.HiveRowPartitionComputer extends org.apache.flink.table.filesystem.RowPartitionComputer implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partColConversions
```
HiveObjectConversion[] partColConversions
```
- Class org.apache.flink.connectors.hive.HiveSource extends org.apache.flink.connector.file.src.AbstractFileSource<org.apache.flink.table.data.RowData,HiveSourceSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fetcher
```
org.apache.flink.table.filesystem.ContinuousPartitionFetcher<P,T extends Comparable<T>> fetcher
```
    - fetcherContext
```
HiveTableSource.HiveContinuousPartitionFetcherContext<T extends Comparable<T>> fetcherContext
```
    - tablePath
```
org.apache.flink.table.catalog.ObjectPath tablePath
```
- Class org.apache.flink.connectors.hive.HiveSourceFileEnumerator.Provider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitions
```
List<E> partitions
```
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
- Class org.apache.flink.connectors.hive.HiveTableMetaStoreFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
```
JobConfWrapper conf
```
    - hiveVersion
```
String hiveVersion
```
    - database
```
String database
```
    - tableName
```
String tableName
```
- Class org.apache.flink.connectors.hive.HiveTablePartition extends Object implements Serializable
  
  serialVersionUID:
  
  4145470177119940673L
  - Serialized Fields
    - storageDescriptor
```
CachedSerializedValue<T> storageDescriptor
```
      Partition storage descriptor.
    - partitionSpec
```
Map<K,V> partitionSpec
```
      The map of partition key names and their values.
    - tableProps
```
Properties tableProps
```
- Class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext extends HivePartitionFetcherContextBase<org.apache.hadoop.hive.metastore.api.Partition> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - typeSerializer
```
org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer
```
    - consumeStartOffset
```
Comparable<T> consumeStartOffset
```
- Class org.apache.flink.connectors.hive.JobConfWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
Package org.apache.flink.connectors.hive.read
- Class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fieldNames
```
String[] fieldNames
```
    - fieldTypes
```
org.apache.flink.table.types.DataType[] fieldTypes
```
    - hiveVersion
```
String hiveVersion
```
    - hiveShim
```
HiveShim hiveShim
```
    - producedRowType
```
org.apache.flink.table.types.logical.RowType producedRowType
```
    - useMapRedReader
```
boolean useMapRedReader
```
- Class org.apache.flink.connectors.hive.read.HiveCompactReaderFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sd
```
CachedSerializedValue<T> sd
```
    - properties
```
Properties properties
```
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fieldNames
```
String[] fieldNames
```
    - fieldTypes
```
org.apache.flink.table.types.DataType[] fieldTypes
```
    - hiveVersion
```
String hiveVersion
```
    - shim
```
HiveShim shim
```
    - producedRowType
```
org.apache.flink.table.types.logical.RowType producedRowType
```
    - useMapRedReader
```
boolean useMapRedReader
```
- Class org.apache.flink.connectors.hive.read.HiveContinuousPartitionFetcher extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConfWrapper
```
JobConfWrapper jobConfWrapper
```
    - hiveVersion
```
String hiveVersion
```
    - tablePath
```
org.apache.flink.table.catalog.ObjectPath tablePath
```
    - fieldTypes
```
org.apache.flink.table.types.DataType[] fieldTypes
```
    - fieldNames
```
String[] fieldNames
```
    - partitionKeys
```
List<E> partitionKeys
```
    - selectedFields
```
int[] selectedFields
```
    - useMapRedReader
```
boolean useMapRedReader
```
- Class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tablePath
```
org.apache.flink.table.catalog.ObjectPath tablePath
```
    - hiveShim
```
HiveShim hiveShim
```
    - confWrapper
```
JobConfWrapper confWrapper
```
    - partitionKeys
```
List<E> partitionKeys
```
    - fieldTypes
```
org.apache.flink.table.types.DataType[] fieldTypes
```
    - fieldNames
```
String[] fieldNames
```
    - configuration
```
org.apache.flink.configuration.Configuration configuration
```
    - defaultPartitionName
```
String defaultPartitionName
```
    - consumeOrder
```
ConsumeOrder consumeOrder
```
- Class org.apache.flink.connectors.hive.read.HiveSourceSplit extends org.apache.flink.connector.file.src.FileSourceSplit implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hiveTablePartition
```
HiveTablePartition hiveTablePartition
```
- Class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat extends org.apache.flink.api.common.io.FileInputFormat<org.apache.flink.table.data.RowData> implements Serializable
  - Serialized Fields
    - inputFormat
```
HiveTableInputFormat inputFormat
```
    - hiveTablePartition
```
HiveTablePartition hiveTablePartition
```
- Class org.apache.flink.connectors.hive.read.HiveTableInputFormat extends org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase<org.apache.flink.table.data.RowData,HiveTableInputSplit> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobConf
```
JobConfWrapper 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
```
- Class org.apache.flink.connectors.hive.read.HiveTableInputSplit extends org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hiveTablePartition
```
HiveTablePartition hiveTablePartition
```
Package org.apache.flink.connectors.hive.write
- Class org.apache.flink.connectors.hive.write.HiveBulkWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - factory
```
HiveWriterFactory factory
```
- Class org.apache.flink.connectors.hive.write.HiveOutputFormatFactory extends Object implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - factory
```
HiveWriterFactory factory
```
- Class org.apache.flink.connectors.hive.write.HiveWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hiveOutputFormatClz
```
Class<T> hiveOutputFormatClz
```
    - serDeInfo
```
CachedSerializedValue<T> 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
```
Package org.apache.flink.table.catalog.hive.client
- Class org.apache.flink.table.catalog.hive.client.HiveShimV100 extends Object implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV101 extends HiveShimV100 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV110 extends HiveShimV101 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV111 extends HiveShimV110 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV120 extends HiveShimV111 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV121 extends HiveShimV120 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV122 extends HiveShimV121 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV200 extends HiveShimV122 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV201 extends HiveShimV200 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV210 extends HiveShimV201 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV211 extends HiveShimV210 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV220 extends HiveShimV211 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV230 extends HiveShimV220 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV231 extends HiveShimV230 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV232 extends HiveShimV231 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV233 extends HiveShimV232 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV234 extends HiveShimV233 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV235 extends HiveShimV234 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV236 extends HiveShimV235 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV310 extends HiveShimV235 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV311 extends HiveShimV310 implements Serializable
- Class org.apache.flink.table.catalog.hive.client.HiveShimV312 extends HiveShimV311 implements Serializable
Package org.apache.flink.table.functions.hive
- Class org.apache.flink.table.functions.hive.FlinkHiveUDFException extends org.apache.flink.util.FlinkRuntimeException implements Serializable
- Class org.apache.flink.table.functions.hive.HiveFunctionWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  393313529306818205L
  - Serialized Fields
    - className
```
String className
```
- Class org.apache.flink.table.functions.hive.HiveGenericUDAF extends org.apache.flink.table.functions.AggregateFunction<Object,org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer> implements Serializable
  - Serialized Fields
    - hiveFunctionWrapper
```
HiveFunctionWrapper<UDFType> hiveFunctionWrapper
```
    - isUDAFBridgeRequired
```
boolean isUDAFBridgeRequired
```
    - constantArguments
```
Object[] constantArguments
```
    - argTypes
```
org.apache.flink.table.types.DataType[] argTypes
```
    - hiveShim
```
HiveShim hiveShim
```
- Class org.apache.flink.table.functions.hive.HiveGenericUDF extends HiveScalarFunction<org.apache.hadoop.hive.ql.udf.generic.GenericUDF> implements Serializable
  - Serialized Fields
    - hiveShim
```
HiveShim hiveShim
```
- Class org.apache.flink.table.functions.hive.HiveGenericUDTF extends org.apache.flink.table.functions.TableFunction<org.apache.flink.types.Row> implements Serializable
  - Serialized Fields
    - hiveFunctionWrapper
```
HiveFunctionWrapper<UDFType> hiveFunctionWrapper
```
    - constantArguments
```
Object[] constantArguments
```
    - argTypes
```
org.apache.flink.table.types.DataType[] argTypes
```
    - hiveShim
```
HiveShim hiveShim
```
- Class org.apache.flink.table.functions.hive.HiveScalarFunction extends org.apache.flink.table.functions.ScalarFunction implements Serializable
  - Serialized Fields
    - hiveFunctionWrapper
```
HiveFunctionWrapper<UDFType> hiveFunctionWrapper
```
    - constantArguments
```
Object[] constantArguments
```
    - argTypes
```
org.apache.flink.table.types.DataType[] argTypes
```
- Class org.apache.flink.table.functions.hive.HiveSimpleUDF extends HiveScalarFunction<org.apache.hadoop.hive.ql.exec.UDF> implements Serializable
  - Serialized Fields
    - hiveShim
```
HiveShim hiveShim
```
Package org.apache.flink.table.functions.hive.conversion
- Class org.apache.flink.table.functions.hive.conversion.IdentityConversion extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.table.functions.hive.conversion.WritableHiveObjectConversion extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - flinkToJavaConversion
```
HiveObjectConversion flinkToJavaConversion
```
    - hiveShim
```
HiveShim hiveShim
```

Serialized Form

Package org.apache.flink.connectors.hive

Class org.apache.flink.connectors.hive.CachedSerializedValue extends org.apache.flink.util.SerializedValue<T> implements Serializable

Class org.apache.flink.connectors.hive.FlinkHiveException extends RuntimeException implements Serializable

Class org.apache.flink.connectors.hive.HadoopFileSystemFactory extends Object implements Serializable

Serialized Fields

jobConfWrapper

Class org.apache.flink.connectors.hive.HiveRowDataPartitionComputer extends org.apache.flink.table.filesystem.RowDataPartitionComputer implements Serializable

Serialized Fields

partitionConverters

hiveObjectConversions

Class org.apache.flink.connectors.hive.HiveRowPartitionComputer extends org.apache.flink.table.filesystem.RowPartitionComputer implements Serializable

Serialized Fields

partColConversions

Class org.apache.flink.connectors.hive.HiveSource extends org.apache.flink.connector.file.src.AbstractFileSource<org.apache.flink.table.data.RowData,HiveSourceSplit> implements Serializable

Serialized Fields

jobConfWrapper

partitionKeys

fetcher

fetcherContext

tablePath

Class org.apache.flink.connectors.hive.HiveSourceFileEnumerator.Provider extends Object implements Serializable

Serialized Fields

partitions

jobConfWrapper

Class org.apache.flink.connectors.hive.HiveTableMetaStoreFactory extends Object implements Serializable

Serialized Fields

conf

hiveVersion

database

tableName

Class org.apache.flink.connectors.hive.HiveTablePartition extends Object implements Serializable

Serialized Fields

storageDescriptor

partitionSpec

tableProps

Class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext extends HivePartitionFetcherContextBase<org.apache.hadoop.hive.metastore.api.Partition> implements Serializable

Serialized Fields

typeSerializer

consumeStartOffset

Class org.apache.flink.connectors.hive.JobConfWrapper extends Object implements Serializable

Serialization Methods

readObject

writeObject

Package org.apache.flink.connectors.hive.read

Class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter extends Object implements Serializable

Serialized Fields

jobConfWrapper

partitionKeys

fieldNames

fieldTypes

hiveVersion

hiveShim

producedRowType

useMapRedReader

Class org.apache.flink.connectors.hive.read.HiveCompactReaderFactory extends Object implements Serializable

Serialized Fields

sd

properties

jobConfWrapper

partitionKeys

fieldNames

fieldTypes

hiveVersion

shim

producedRowType

useMapRedReader

Class org.apache.flink.connectors.hive.read.HiveContinuousPartitionFetcher extends Object implements Serializable

Class org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader extends Object implements Serializable

Serialized Fields

jobConfWrapper

hiveVersion

tablePath

fieldTypes

fieldNames

partitionKeys

selectedFields

useMapRedReader

Class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase extends Object implements Serializable

Serialized Fields