类分层结构 (flink-connector-hive 1.11.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.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
  - org.apache.flink.streaming.api.functions.source.RichSourceFunction<OUT> (implements org.apache.flink.streaming.api.functions.source.SourceFunction<T>)
    - org.apache.flink.connectors.hive.read.HiveContinuousMonitoringFunction (implements org.apache.flink.streaming.api.checkpoint.CheckpointedFunction)
- 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.read.DirectoryMonitorDiscovery (implements org.apache.flink.connectors.hive.read.PartitionDiscovery)
- org.apache.flink.connectors.hive.HadoopFileSystemFactory (implements org.apache.flink.table.filesystem.FileSystemFactory)
- org.apache.flink.connectors.hive.write.HiveBulkWriterFactory (implements org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter.Factory<T>)
- 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.HiveDatabaseUtil
- org.apache.flink.connectors.hive.HiveDynamicTableFactory (implements org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory)
- 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.write.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.HiveTableSink (implements org.apache.flink.table.sinks.AppendStreamTableSink<T>, org.apache.flink.table.sinks.OverwritableTableSink, org.apache.flink.table.sinks.PartitionableTableSink)
- org.apache.flink.connectors.hive.HiveTableSource (implements org.apache.flink.table.sources.LimitableTableSource<T>, org.apache.flink.table.sources.LookupableTableSource<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.connectors.hive.read.HiveVectorizedParquetSplitReader (implements org.apache.flink.connectors.hive.read.SplitReader)
- org.apache.flink.connectors.hive.write.HiveWriterFactory (implements java.io.Serializable)
- 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.connectors.hive.read.TimestampedHiveInputSplit (implements org.apache.flink.streaming.api.functions.source.TimestampedInputSplit)
- org.apache.flink.table.descriptors.ModuleDescriptorValidator (implements org.apache.flink.table.descriptors.DescriptorValidator)
  - org.apache.flink.table.module.hive.HiveModuleDescriptorValidator
- org.apache.flink.api.common.io.RichInputFormat<OT,T> (implements org.apache.flink.api.common.io.InputFormat<OT,T>)
  - org.apache.flink.api.common.io.FileInputFormat<OT>
    - org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
  - org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase<T,SPITTYPE>
    - org.apache.flink.connectors.hive.read.HiveTableInputFormat (implements org.apache.flink.api.common.io.CheckpointableInputFormat<S,T>)
- org.apache.flink.table.filesystem.RowDataPartitionComputer (implements org.apache.flink.table.filesystem.PartitionComputer<T>)
  - org.apache.flink.connectors.hive.HiveRowDataPartitionComputer
- org.apache.flink.table.filesystem.RowPartitionComputer (implements org.apache.flink.table.filesystem.PartitionComputer<T>)
  - org.apache.flink.connectors.hive.HiveRowPartitionComputer
- 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.api.common.typeinfo.TypeInfoFactory<T>
  - org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit.SplitTypeInfoFactory (implements java.io.Serializable)
- 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
org.apache.flink.connectors.hive.read.PartitionDiscovery
org.apache.flink.connectors.hive.read.PartitionDiscovery.Context
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.connectors.hive.ConsumeOrder
  - org.apache.flink.table.catalog.hive.util.HiveTypeUtil.HivePrimitiveCategory

所有程序包的分层结构

类分层结构

接口分层结构

枚举分层结构