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<T>
  • 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.connector.file.src.impl.DynamicFileSplitEnumerator<SplitT> (implements org.apache.flink.api.connector.source.SplitEnumerator<SplitT,CheckpointT>, org.apache.flink.api.connector.source.SupportsHandleExecutionAttemptSourceEvent)
    • org.apache.flink.connectors.hive.DynamicHiveSplitEnumerator
  • org.apache.flink.connectors.hive.HadoopFileSystemFactory (implements org.apache.flink.connector.file.table.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.HiveInternalOptions
  • org.apache.flink.connectors.hive.HiveOptions
  • org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase<P> (implements org.apache.flink.connectors.hive.read.HivePartitionContext<P>)
    • org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext<T> (implements org.apache.flink.connectors.hive.read.HiveContinuousPartitionContext<P,T>)
  • org.apache.flink.connectors.hive.HiveSourceBuilder
  • org.apache.flink.connectors.hive.HiveSourceDynamicFileEnumerator (implements org.apache.flink.connector.file.src.enumerate.DynamicFileEnumerator)
  • org.apache.flink.connectors.hive.HiveSourceDynamicFileEnumerator.Provider (implements org.apache.flink.connector.file.src.enumerate.DynamicFileEnumerator.Provider)
  • org.apache.flink.connectors.hive.HiveSourceFileEnumerator (implements org.apache.flink.connector.file.src.enumerate.FileEnumerator)
  • org.apache.flink.connectors.hive.HiveSourceFileEnumerator.PartitionFilesSizeCalculator (implements java.util.concurrent.Callable<V>)
  • 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.connector.file.table.TableMetaStoreFactory)
  • org.apache.flink.connectors.hive.HiveTablePartition (implements java.io.Serializable)
  • org.apache.flink.connectors.hive.HiveTablePartitionSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
  • org.apache.flink.connectors.hive.HiveTablePartitionSplits
  • 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.SupportsDynamicFiltering, 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.table.connector.source.abilities.SupportsStatisticReport)
    • 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.connectors.hive.MRSplitsGetter (implements java.io.Closeable)
  • org.apache.flink.connector.file.src.PendingSplitsCheckpoint<SplitT>
    • org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpoint
  • org.apache.flink.connector.file.table.RowDataPartitionComputer (implements org.apache.flink.connector.file.table.PartitionComputer<T>)
    • org.apache.flink.connectors.hive.HiveRowDataPartitionComputer
  • org.apache.flink.connector.file.table.RowPartitionComputer (implements org.apache.flink.connector.file.table.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
  • org.apache.flink.table.functions.UserDefinedFunction (implements org.apache.flink.table.functions.FunctionDefinition, java.io.Serializable)
    • org.apache.flink.table.functions.TableFunction<T>
      • org.apache.flink.connectors.hive.FileSystemLookupFunction<P>

Enum Hierarchy

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