类分层结构 (flink-connector-hive 1.10.2 API)

类分层结构

java.lang.Object
- org.apache.flink.table.catalog.AbstractCatalog (implements org.apache.flink.table.catalog.Catalog)
  - org.apache.flink.table.catalog.hive.HiveCatalog
- org.apache.flink.table.descriptors.CatalogDescriptorValidator (implements org.apache.flink.table.descriptors.DescriptorValidator)
  - org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator
- org.apache.flink.table.functions.hive.DeferredObjectAdapter (implements org.apache.hadoop.hive.ql.udf.generic.GenericUDF.DeferredObject)
- org.apache.flink.table.descriptors.DescriptorBase (implements org.apache.flink.table.descriptors.Descriptor)
  - org.apache.flink.table.descriptors.CatalogDescriptor
    - org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor
  - org.apache.flink.table.descriptors.ModuleDescriptor
    - org.apache.flink.table.module.hive.HiveModuleDescriptor
- org.apache.flink.connectors.hive.HadoopFileSystemFactory (implements org.apache.flink.table.filesystem.FileSystemFactory)
- org.apache.flink.table.catalog.hive.HiveCatalogConfig
- org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory (implements org.apache.flink.table.factories.CatalogFactory)
- org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory (implements org.apache.flink.table.factories.FunctionDefinitionFactory)
- org.apache.flink.table.functions.hive.util.HiveFunctionUtil
- org.apache.flink.table.functions.hive.HiveFunctionWrapper<UDFType> (implements java.io.Serializable)
- org.apache.flink.table.functions.hive.conversion.HiveInspectors
- org.apache.flink.connectors.hive.read.HiveMapredSplitReader (implements org.apache.flink.connectors.hive.read.SplitReader)
- org.apache.flink.table.catalog.hive.client.HiveMetastoreClientFactory
- org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper (implements java.lang.AutoCloseable)
- org.apache.flink.table.module.hive.HiveModule (implements org.apache.flink.table.module.Module)
- org.apache.flink.table.module.hive.HiveModuleFactory (implements org.apache.flink.table.factories.ModuleFactory)
- org.apache.flink.connectors.hive.HiveOptions
- org.apache.flink.connectors.hive.HiveOutputFormatFactory (implements org.apache.flink.table.filesystem.OutputFormatFactory<T>)
- org.apache.flink.table.catalog.hive.util.HiveReflectionUtils
- org.apache.flink.table.catalog.hive.client.HiveShimLoader
- org.apache.flink.table.catalog.hive.client.HiveShimV100 (implements org.apache.flink.table.catalog.hive.client.HiveShim)
  - org.apache.flink.table.catalog.hive.client.HiveShimV101
    - org.apache.flink.table.catalog.hive.client.HiveShimV110
      - org.apache.flink.table.catalog.hive.client.HiveShimV111
        
        org.apache.flink.table.catalog.hive.client.HiveShimV120
        
        org.apache.flink.table.catalog.hive.client.HiveShimV121
        
        org.apache.flink.table.catalog.hive.client.HiveShimV122
        
        org.apache.flink.table.catalog.hive.client.HiveShimV200
        
        org.apache.flink.table.catalog.hive.client.HiveShimV201
        
        org.apache.flink.table.catalog.hive.client.HiveShimV210
        
        org.apache.flink.table.catalog.hive.client.HiveShimV211
        
        org.apache.flink.table.catalog.hive.client.HiveShimV220
        
        org.apache.flink.table.catalog.hive.client.HiveShimV230
        
        org.apache.flink.table.catalog.hive.client.HiveShimV231
        
        org.apache.flink.table.catalog.hive.client.HiveShimV232
        
        org.apache.flink.table.catalog.hive.client.HiveShimV233
        
        org.apache.flink.table.catalog.hive.client.HiveShimV234
        
        org.apache.flink.table.catalog.hive.client.HiveShimV235
        
        org.apache.flink.table.catalog.hive.client.HiveShimV236
        
        org.apache.flink.table.catalog.hive.client.HiveShimV310
        
        org.apache.flink.table.catalog.hive.client.HiveShimV311
        
        org.apache.flink.table.catalog.hive.client.HiveShimV312
- org.apache.flink.table.catalog.hive.util.HiveStatsUtil
- org.apache.flink.connectors.hive.HiveTableFactory (implements org.apache.flink.table.factories.TableSinkFactory<T>, org.apache.flink.table.factories.TableSourceFactory<T>)
- org.apache.flink.connectors.hive.HiveTableMetaStoreFactory (implements org.apache.flink.table.filesystem.TableMetaStoreFactory)
- org.apache.flink.connectors.hive.HiveTablePartition (implements java.io.Serializable)
- org.apache.flink.connectors.hive.HiveTableSource (implements org.apache.flink.table.sources.LimitableTableSource<T>, org.apache.flink.table.sources.PartitionableTableSource, org.apache.flink.table.sources.ProjectableTableSource<T>, org.apache.flink.table.sources.StreamTableSource<T>)
- org.apache.flink.table.catalog.hive.util.HiveTableUtil
- org.apache.flink.table.catalog.hive.util.HiveTypeUtil
- org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader (implements org.apache.flink.connectors.hive.read.SplitReader)
- org.apache.flink.table.functions.hive.conversion.IdentityConversion (implements org.apache.flink.table.functions.hive.conversion.HiveObjectConversion)
- org.apache.flink.connectors.hive.JobConfWrapper (implements java.io.Serializable)
- org.apache.flink.core.io.LocatableInputSplit (implements org.apache.flink.core.io.InputSplit, java.io.Serializable)
  - org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit
    - org.apache.flink.connectors.hive.read.HiveTableInputSplit
- org.apache.flink.table.descriptors.ModuleDescriptorValidator (implements org.apache.flink.table.descriptors.DescriptorValidator)
  - org.apache.flink.table.module.hive.HiveModuleDescriptorValidator
- org.apache.flink.table.sinks.OutputFormatTableSink<T> (implements org.apache.flink.table.sinks.StreamTableSink<T>)
  - org.apache.flink.connectors.hive.HiveTableSink (implements org.apache.flink.table.sinks.OverwritableTableSink, org.apache.flink.table.sinks.PartitionableTableSink)
- org.apache.flink.api.common.io.RichInputFormat<OT,T> (implements org.apache.flink.api.common.io.InputFormat<OT,T>)
  - org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase<T,SPITTYPE>
    - org.apache.flink.connectors.hive.read.HiveTableInputFormat
- org.apache.flink.table.filesystem.RowPartitionComputer (implements org.apache.flink.table.filesystem.PartitionComputer<T>)
  - org.apache.flink.connectors.hive.HivePartitionComputer
- java.lang.Throwable (implements java.io.Serializable)
  - java.lang.Exception
    - java.lang.RuntimeException
      - org.apache.flink.connectors.hive.FlinkHiveException
      - org.apache.flink.util.FlinkRuntimeException
        
        org.apache.flink.table.functions.hive.FlinkHiveUDFException
- org.apache.flink.table.functions.UserDefinedFunction (implements org.apache.flink.table.functions.FunctionDefinition, java.io.Serializable)
  - org.apache.flink.table.functions.ScalarFunction
    - org.apache.flink.table.functions.hive.HiveScalarFunction<UDFType> (implements org.apache.flink.table.functions.hive.HiveFunction)
      - org.apache.flink.table.functions.hive.HiveGenericUDF
      - org.apache.flink.table.functions.hive.HiveSimpleUDF
  - org.apache.flink.table.functions.TableFunction<T>
    - org.apache.flink.table.functions.hive.HiveGenericUDTF (implements org.apache.flink.table.functions.hive.HiveFunction)
  - org.apache.flink.table.functions.UserDefinedAggregateFunction<T,ACC>
    - org.apache.flink.table.functions.AggregateFunction<T,ACC>
      - org.apache.flink.table.functions.hive.HiveGenericUDAF (implements org.apache.flink.table.functions.hive.HiveFunction)
- org.apache.flink.table.functions.hive.conversion.WritableHiveObjectConversion (implements org.apache.flink.table.functions.hive.conversion.HiveObjectConversion)

接口分层结构

java.lang.AutoCloseable
- java.io.Closeable
  - org.apache.flink.connectors.hive.read.SplitReader
- org.apache.flink.connectors.hive.read.SplitReader
org.apache.flink.table.functions.hive.HiveFunction
java.io.Serializable
- org.apache.flink.table.functions.hive.conversion.HiveObjectConversion
- org.apache.flink.table.catalog.hive.client.HiveShim

枚举分层结构

java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
  - org.apache.flink.table.catalog.hive.util.HiveTypeUtil.HivePrimitiveCategory

所有程序包的分层结构

类分层结构

接口分层结构

枚举分层结构