Hierarchy For Package org.apache.flink.connectors.hive

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.connector.file.src.AbstractFileSource<T,SplitT> (implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, org.apache.flink.api.connector.source.Source<T,SplitT,EnumChkT>)
    • org.apache.flink.connectors.hive.HiveSource (implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)
  • org.apache.flink.connector.file.src.AbstractFileSource.AbstractFileSourceBuilder<T,SplitT,SELF>
    • org.apache.flink.connectors.hive.HiveSource.HiveSourceBuilder
  • org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpointSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
  • org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator<T> (implements org.apache.flink.api.connector.source.SplitEnumerator<SplitT,CheckpointT>)
  • org.apache.flink.connectors.hive.HadoopFileSystemFactory (implements org.apache.flink.table.filesystem.FileSystemFactory)
  • org.apache.flink.connectors.hive.HiveDynamicTableFactory (implements org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory)
  • org.apache.flink.connectors.hive.HiveOptions
  • org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase<P> (implements org.apache.flink.table.filesystem.PartitionFetcher.Context<P>)
    • org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext<T> (implements org.apache.flink.table.filesystem.ContinuousPartitionFetcher.Context<P,T>)
  • org.apache.flink.connectors.hive.HiveSourceFileEnumerator (implements org.apache.flink.connector.file.src.enumerate.FileEnumerator)
  • org.apache.flink.connectors.hive.HiveSourceFileEnumerator.Provider (implements org.apache.flink.connector.file.src.enumerate.FileEnumerator.Provider)
  • org.apache.flink.connectors.hive.HiveSourceSplitSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
  • 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.connector.sink.DynamicTableSink, org.apache.flink.table.connector.sink.abilities.SupportsOverwrite, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning)
  • org.apache.flink.connectors.hive.HiveTableSource (implements org.apache.flink.table.connector.source.ScanTableSource, org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown, org.apache.flink.table.connector.source.abilities.SupportsPartitionPushDown, org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown)
    • org.apache.flink.connectors.hive.HiveLookupTableSource (implements org.apache.flink.table.connector.source.LookupTableSource)
  • org.apache.flink.connectors.hive.JobConfWrapper (implements java.io.Serializable)
  • org.apache.flink.connector.file.src.PendingSplitsCheckpoint<SplitT>
    • org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpoint
  • 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
  • org.apache.flink.util.SerializedValue<T> (implements java.io.Serializable)
    • org.apache.flink.connectors.hive.CachedSerializedValue<T>
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.flink.connectors.hive.FlinkHiveException

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.connectors.hive.ConsumeOrder