Class Hierarchy
- java.lang.Object
- org.apache.flink.table.catalog.AbstractCatalog (implements org.apache.flink.table.catalog.Catalog)
- 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.table.descriptors.CatalogDescriptorValidator (implements org.apache.flink.table.descriptors.DescriptorValidator)
- 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.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.descriptors.ModuleDescriptor
- org.apache.flink.connector.file.src.FileSourceSplit (implements java.io.Serializable, org.apache.flink.api.connector.source.SourceSplit)
- org.apache.flink.connectors.hive.HadoopFileSystemFactory (implements org.apache.flink.table.filesystem.FileSystemFactory)
- org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter (implements org.apache.flink.connector.file.src.reader.BulkFormat<T,SplitT>)
- 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.connectors.hive.read.HiveCompactReaderFactory (implements org.apache.flink.table.filesystem.stream.compact.CompactReader.Factory<T>)
- org.apache.flink.connectors.hive.util.HiveConfUtils
- org.apache.flink.connectors.hive.read.HiveContinuousPartitionFetcher<T> (implements org.apache.flink.table.filesystem.ContinuousPartitionFetcher<P,T>)
- 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.connectors.hive.read.HiveInputFormatPartitionReader (implements org.apache.flink.table.filesystem.PartitionReader<P,OUT>)
- 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.connectors.hive.read.HivePartitionFetcherContextBase<P> (implements org.apache.flink.table.filesystem.PartitionFetcher.Context<P>)
- org.apache.flink.connectors.hive.util.HivePartitionUtils
- 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.connectors.hive.HiveSource.HiveSourceBuilder
- 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.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.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.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.table.descriptors.ModuleDescriptorValidator (implements org.apache.flink.table.descriptors.DescriptorValidator)
- org.apache.flink.connector.file.src.PendingSplitsCheckpoint<SplitT>
- 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.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.table.filesystem.RowPartitionComputer (implements org.apache.flink.table.filesystem.PartitionComputer<T>)
- org.apache.flink.util.SerializedValue<T> (implements java.io.Serializable)
- java.lang.Throwable (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.ImperativeAggregateFunction<T,ACC>
- org.apache.flink.table.functions.AggregateFunction<T,ACC>
- org.apache.flink.table.functions.ScalarFunction
- org.apache.flink.table.functions.TableFunction<T>
- org.apache.flink.table.functions.hive.conversion.WritableHiveObjectConversion (implements org.apache.flink.table.functions.hive.conversion.HiveObjectConversion)
Interface Hierarchy
Enum Hierarchy
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.