索引 (flink-connector-hive 1.11.2 API)

A C D E F G H I J K L M N O P R S T U V W

A

accumulate(GenericUDAFEvaluator.AggregationBuffer, Object...) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF
add_partition(Partition) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
add_partitions(List<Partition>) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
alter_partition(String, String, Partition) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
alter_table(String, String, Table) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
alterColumns(StorageDescriptor, CatalogTable) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
alterDatabase(String, Database) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
alterDatabase(String, CatalogDatabase, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
alterFunction(String, String, Function) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
alterFunction(ObjectPath, CatalogFunction, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
alterPartition(IMetaStoreClient, String, String, Partition) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim
alterPartition(IMetaStoreClient, String, String, Partition) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
alterPartition(IMetaStoreClient, String, String, Partition) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV210
alterPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
alterPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec, CatalogColumnStatistics, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
alterPartitionStatistics(ObjectPath, CatalogPartitionSpec, CatalogTableStatistics, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
alterTable(IMetaStoreClient, String, String, Table) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Alters a Hive table.
alterTable(IMetaStoreClient, String, String, Table) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
alterTable(IMetaStoreClient, String, String, Table) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV120
alterTable(IMetaStoreClient, String, String, Table) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV230
alterTable(ObjectPath, CatalogBaseTable, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
alterTableColumnStatistics(ObjectPath, CatalogColumnStatistics, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
alterTableStatistics(ObjectPath, CatalogTableStatistics, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
alterTableViaCatalogBaseTable(ObjectPath, CatalogBaseTable, Table, HiveConf) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
applyLimit(long) - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
applyPartitionPruning(List<Map<String, String>>) - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
argTypes - 类中的变量org.apache.flink.table.functions.hive.HiveScalarFunction

C

cancel() - 类中的方法org.apache.flink.connectors.hive.read.HiveContinuousMonitoringFunction
CATALOG_HIVE_CONF_DIR - 类中的静态变量org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator
CATALOG_HIVE_VERSION - 类中的静态变量org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator
CATALOG_TYPE_VALUE_HIVE - 类中的静态变量org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator
close() - 类中的方法org.apache.flink.connectors.hive.read.HiveContinuousMonitoringFunction
close() - 类中的方法org.apache.flink.connectors.hive.read.HiveMapredSplitReader
close() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
close() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
close() - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader
close() - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader
close() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
close() - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
close() - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDTF
closeInputFormat() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
COMMENT - 类中的静态变量org.apache.flink.table.catalog.hive.HiveCatalogConfig
compareTo(TimestampedInputSplit) - 类中的方法org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit: Note Again: this class has a natural ordering that is inconsistent with equals.
conf() - 类中的方法org.apache.flink.connectors.hive.JobConfWrapper
configure(String[], TypeInformation[]) - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
configure(Configuration) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
configure(Configuration) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
configurePartitionGrouping(boolean) - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
constantArguments - 类中的变量org.apache.flink.table.functions.hive.HiveScalarFunction
consumeDataStream(DataStream) - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
ConsumeOrder - org.apache.flink.connectors.hive中的枚举: ConsumeOrder defines the orders to continuously consume stream source.
create(URI) - 类中的方法org.apache.flink.connectors.hive.HadoopFileSystemFactory
create(Path, Path) - 类中的方法org.apache.flink.connectors.hive.write.HiveBulkWriterFactory
create(HiveConf, String) - 类中的静态方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientFactory
createAccumulator() - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF: This is invoked without calling open() in Blink, so we need to call init() for getNewAggregationBuffer().
createCatalog(String, Map<String, String>) - 类中的方法org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory
createCatalogColumnStats(List<ColumnStatisticsObj>, String) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveStatsUtil: Create a map of Flink column stats from the given Hive column stats.
createConstantObjectInspector(String, Object) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveReflectionUtils
createDatabase(Database) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
createDatabase(String, CatalogDatabase, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
createDynamicTableSink(DynamicTableFactory.Context) - 类中的方法org.apache.flink.connectors.hive.HiveDynamicTableFactory
createDynamicTableSource(DynamicTableFactory.Context) - 类中的方法org.apache.flink.connectors.hive.HiveDynamicTableFactory
createFunction(Function) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
createFunction(ObjectPath, CatalogFunction, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
createFunction() - 类中的方法org.apache.flink.table.functions.hive.HiveFunctionWrapper: Instantiate a Hive function instance.
createFunctionDefinition(String, CatalogFunction) - 类中的方法org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory
createFunctionDefinitionFromHiveFunction(String, String) - 类中的方法org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory: Create a FunctionDefinition from a Hive function's class name.
createHiveColumns(TableSchema) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil: Create Hive columns from Flink TableSchema.
createHivePartition(String, String, List<String>, StorageDescriptor, Map<String, String>) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil: Creates a Hive partition instance.
createInputSplits(int) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
createInputSplits(int, List<HiveTablePartition>, JobConf) - 类中的静态方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
createModule(Map<String, String>) - 类中的方法org.apache.flink.table.module.hive.HiveModuleFactory
createOrcBulkWriterFactory(Configuration, String, LogicalType[]) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Create orc BulkWriter.Factory for different hive versions.
createOrcBulkWriterFactory(Configuration, String, LogicalType[]) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
createOrcBulkWriterFactory(Configuration, String, LogicalType[]) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV200
createOutputFormat(Path) - 类中的方法org.apache.flink.connectors.hive.write.HiveOutputFormatFactory
createPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
createPartitionColumnStats(Partition, String, Map<String, CatalogColumnStatisticsDataBase>, String) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveStatsUtil: Create columnStatistics from the given Hive column stats of a hive partition.
createRecordWriter(Path) - 类中的方法org.apache.flink.connectors.hive.write.HiveWriterFactory: Create a FileSinkOperator.RecordWriter from path.
createRowConverter() - 类中的方法org.apache.flink.connectors.hive.write.HiveWriterFactory
createRowDataConverter() - 类中的方法org.apache.flink.connectors.hive.write.HiveWriterFactory
createTable(Table) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
createTable(ObjectPath, CatalogBaseTable, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
createTableColumnStats(Table, Map<String, CatalogColumnStatisticsDataBase>, String) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveStatsUtil: Create columnStatistics from the given Hive column stats of a hive table.
createTableMetaStore() - 类中的方法org.apache.flink.connectors.hive.HiveTableMetaStoreFactory
createTableSchema(List<FieldSchema>, List<FieldSchema>, Set<String>, UniqueConstraint) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil: Create a Flink's TableSchema from Hive table's columns and partition keys.
createTableSink(TableSinkFactory.Context) - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
createTableSource(TableSourceFactory.Context) - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
createTableWithConstraints(Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
createTableWithConstraints(IMetaStoreClient, Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Creates a table with PK and NOT NULL constraints.
createTableWithConstraints(IMetaStoreClient, Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
createTableWithConstraints(IMetaStoreClient, Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV210
createTableWithConstraints(IMetaStoreClient, Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
createTypeInfo(Type, Map) - 类中的方法org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit.SplitTypeInfoFactory
createUDAFParameterInfo(ObjectInspector[], boolean, boolean, boolean) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Creates SimpleGenericUDAFParameterInfo.
createUDAFParameterInfo(ObjectInspector[], boolean, boolean, boolean) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
createUDAFParameterInfo(ObjectInspector[], boolean, boolean, boolean) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV230

D

databaseExists(String) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
DEFAULT_DB - 类中的静态变量org.apache.flink.table.catalog.hive.HiveCatalog
DEFAULT_LIST_COLUMN_TYPES_SEPARATOR - 类中的静态变量org.apache.flink.table.catalog.hive.HiveCatalogConfig
DeferredObjectAdapter - org.apache.flink.table.functions.hive中的类: Adapter from Java Object to Hive DeferredObject.
DeferredObjectAdapter(ObjectInspector, LogicalType, HiveShim) - 类的构造器org.apache.flink.table.functions.hive.DeferredObjectAdapter
DirectoryMonitorDiscovery - org.apache.flink.connectors.hive.read中的类: Directory monitor PartitionDiscovery.
DirectoryMonitorDiscovery() - 类的构造器org.apache.flink.connectors.hive.read.DirectoryMonitorDiscovery
disallowChangeIsGeneric(boolean, boolean) - 类中的静态方法org.apache.flink.table.catalog.hive.HiveCatalog
dropDatabase(String, boolean, boolean) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
dropDatabase(String, boolean, boolean, boolean) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
dropDatabase(String, boolean, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
dropFunction(String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
dropFunction(ObjectPath, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
dropPartition(String, String, List<String>, boolean) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
dropPartition(ObjectPath, CatalogPartitionSpec, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
dropTable(String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
dropTable(String, String, boolean, boolean) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
dropTable(ObjectPath, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog

E

enableConstraint(byte) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
equals(Object) - 类中的方法org.apache.flink.connectors.hive.HiveTablePartition
equals(Object) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputSplit
equals(Object) - 类中的方法org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit
eval(Object...) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDTF
eval(Object...) - 类中的方法org.apache.flink.table.functions.hive.HiveScalarFunction
evalInternal(Object[]) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDF
evalInternal(Object[]) - 类中的方法org.apache.flink.table.functions.hive.HiveScalarFunction: Evaluation logical, args will be wrapped when is a single array.
evalInternal(Object[]) - 类中的方法org.apache.flink.table.functions.hive.HiveSimpleUDF
explainSource() - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
extractAlterTableOp(Map<String, String>) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
extractLocation(StorageDescriptor, Map<String, String>) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
extractRowFormat(StorageDescriptor, Map<String, String>) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
extractTimestamp(List<String>, List<String>, Supplier<Long>) - 接口中的方法org.apache.flink.connectors.hive.read.PartitionDiscovery.Context: Extract timestamp from partition.

F

factoryIdentifier() - 类中的方法org.apache.flink.connectors.hive.HiveDynamicTableFactory
fetchPartitions(PartitionDiscovery.Context, long) - 类中的方法org.apache.flink.connectors.hive.read.DirectoryMonitorDiscovery
fetchPartitions(PartitionDiscovery.Context, long) - 接口中的方法org.apache.flink.connectors.hive.read.PartitionDiscovery: Fetch partitions by previous timestamp (Including).
fileSystem() - 接口中的方法org.apache.flink.connectors.hive.read.PartitionDiscovery.Context: Hadoop filesystem.
FlinkHiveException - org.apache.flink.connectors.hive中的异常错误: Exception used by flink's hive data connector.
FlinkHiveException(String) - 异常错误的构造器org.apache.flink.connectors.hive.FlinkHiveException
FlinkHiveException(Throwable) - 异常错误的构造器org.apache.flink.connectors.hive.FlinkHiveException
FlinkHiveException(String, Throwable) - 异常错误的构造器org.apache.flink.connectors.hive.FlinkHiveException
FlinkHiveUDFException - org.apache.flink.table.functions.hive中的异常错误: Hive UDF related exceptions in Flink.
FlinkHiveUDFException(String) - 异常错误的构造器org.apache.flink.table.functions.hive.FlinkHiveUDFException
FlinkHiveUDFException(Throwable) - 异常错误的构造器org.apache.flink.table.functions.hive.FlinkHiveUDFException
FlinkHiveUDFException(String, Throwable) - 异常错误的构造器org.apache.flink.table.functions.hive.FlinkHiveUDFException
function - 类中的变量org.apache.flink.table.functions.hive.HiveScalarFunction
functionExists(ObjectPath) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog

G

generatePartValues(RowData) - 类中的方法org.apache.flink.connectors.hive.HiveRowDataPartitionComputer
generatePartValues(Row) - 类中的方法org.apache.flink.connectors.hive.HiveRowPartitionComputer
get() - 类中的方法org.apache.flink.table.functions.hive.DeferredObjectAdapter
getAccumulatorType() - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF
getAllDatabases() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getAllTables(String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getAsyncLookupFunction(String[]) - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
getBuiltInFunctionInfo(String) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Get a Hive built-in function by name.
getBuiltInFunctionInfo(String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getBuiltInFunctionInfo(String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV120
getClassName() - 类中的方法org.apache.flink.table.functions.hive.HiveFunctionWrapper: Get class name of the Hive function.
getConsumedDataType() - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
getConsumeOrder(String) - 枚举中的静态方法org.apache.flink.connectors.hive.ConsumeOrder: Get ConsumeOrder from consume order string.
getConversion(ObjectInspector, LogicalType, HiveShim) - 类中的静态方法org.apache.flink.table.functions.hive.conversion.HiveInspectors: Get conversion for converting Flink object to Hive object from an ObjectInspector and the corresponding Flink DataType.
getCurrentState() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
getDatabase(String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getDatabase(String) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getDatabases(String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getDataStream(StreamExecutionEnvironment) - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
getDateDataTypeClass() - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Hive Date data type class was changed in Hive 3.1.0.
getDateDataTypeClass() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getDateDataTypeClass() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
getFactory() - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getFieldNames(List<FieldSchema>) - 类中的静态方法org.apache.flink.table.catalog.hive.HiveCatalog: Get field names from field schemas.
getFieldsFromDeserializer(Configuration, Table, boolean) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Get Hive table schema from deserializer.
getFieldsFromDeserializer(Configuration, Table, boolean) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getFieldsFromDeserializer(Configuration, Table, boolean) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV110
getFunction(String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getFunction(ObjectPath) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getFunctionDefinition(String) - 类中的方法org.apache.flink.table.module.hive.HiveModule
getFunctionDefinitionFactory() - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getFunctions(String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getHiveConf() - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getHiveDatabase(String) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getHiveMetastoreClient(HiveConf) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Create a Hive Metastore client based on the given HiveConf object.
getHiveMetastoreClient(HiveConf) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getHiveMetastoreClient(HiveConf) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV120
getHiveMetastoreClient(HiveConf) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV200
getHiveMetastoreClient(HiveConf) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV230
getHiveMetastoreClient(HiveConf) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
getHiveMetaStoreUtilsClass() - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Get the class of Hive's HiveMetaStoreUtils as it was split from MetaStoreUtils class in Hive 3.1.0.
getHiveMetaStoreUtilsClass() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getHiveMetaStoreUtilsClass() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
getHiveOutputFormatClass(Class) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: For a given OutputFormat class, get the corresponding HiveOutputFormat class.
getHiveOutputFormatClass(Class) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getHiveOutputFormatClass(Class) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV110
getHivePartition(Table, CatalogPartitionSpec) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getHiveRecordWriter(JobConf, Class, Class<? extends Writable>, boolean, Properties, Path) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Get Hive's FileSinkOperator.RecordWriter.
getHiveRecordWriter(JobConf, Class, Class<? extends Writable>, boolean, Properties, Path) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getHiveRecordWriter(JobConf, Class, Class<? extends Writable>, boolean, Properties, Path) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV110
getHiveResultType(Object[], DataType[]) - 接口中的方法org.apache.flink.table.functions.hive.HiveFunction: Get result type by arguments and argTypes.
getHiveResultType(Object[], DataType[]) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF
getHiveResultType(Object[], DataType[]) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDF
getHiveResultType(Object[], DataType[]) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDTF
getHiveResultType(Object[], DataType[]) - 类中的方法org.apache.flink.table.functions.hive.HiveSimpleUDF
getHiveTable(ObjectPath) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getHiveTablePartition() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputSplit
getHiveVersion() - 类中的静态方法org.apache.flink.table.catalog.hive.client.HiveShimLoader
getHiveVersion() - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getHiveVersion() - 类中的方法org.apache.flink.table.module.hive.HiveModule
getInputSplitAssigner(HiveTableInputSplit[]) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
getJobConf() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
getJobConf() - 类中的方法org.apache.flink.connectors.hive.write.HiveWriterFactory
getLookupFunction(String[]) - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
getMetaStoreUtilsClass() - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Get the class of Hive's MetaStoreUtils because its package name was changed in Hive 3.1.0.
getMetaStoreUtilsClass() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getMetaStoreUtilsClass() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
getModificationTime() - 类中的方法org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit
getNotNullColumns(Configuration, String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getNotNullColumns(IMetaStoreClient, Configuration, String, String) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Get the set of columns that have NOT NULL constraints.
getNotNullColumns(IMetaStoreClient, Configuration, String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getNotNullColumns(IMetaStoreClient, Configuration, String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
getObjectInspector(DataType) - 类中的静态方法org.apache.flink.table.functions.hive.conversion.HiveInspectors: Get Hive ObjectInspector for a Flink DataType.
getPartition(List<String>) - 接口中的方法org.apache.flink.connectors.hive.read.PartitionDiscovery.Context: See IMetaStoreClient.getPartition(java.lang.String, java.lang.String, java.util.List<java.lang.String>).
getPartition(String, String, List<String>) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getPartition(ObjectPath, CatalogPartitionSpec) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getPartitionColumnStatistics(String, String, List<String>, List<String>) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getPartitions() - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
getPartitionSpec() - 类中的方法org.apache.flink.connectors.hive.HiveTablePartition
getPartitionStatistics(ObjectPath, CatalogPartitionSpec) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getPrimaryKey(String, String, byte) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getPrimaryKey(IMetaStoreClient, String, String, byte) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Get the primary key of a Hive table and convert it to a UniqueConstraint.
getPrimaryKey(IMetaStoreClient, String, String, byte) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getPrimaryKey(IMetaStoreClient, String, String, byte) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV210
getProducedDataType() - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
getPvals(HiveShim, List<FieldSchema>, Map<String, String>) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveReflectionUtils
getResultType() - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF
getResultType() - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDTF
getResultType(Class[]) - 类中的方法org.apache.flink.table.functions.hive.HiveScalarFunction
getSplitState() - 类中的方法org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit
getStatistics(BaseStatistics) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
getStorageDescriptor() - 类中的方法org.apache.flink.connectors.hive.HiveTablePartition
getTable(String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getTable(ObjectPath) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getTableColumnStatistics(String, String, List<String>) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getTableColumnStatistics(ObjectPath) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getTableFactory() - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getTableMetadata(HiveShim, Table) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveReflectionUtils
getTableProps() - 类中的方法org.apache.flink.connectors.hive.HiveTablePartition
getTableSchema() - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
getTableSchema() - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
getTableStatistics(ObjectPath) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
getTimestampDataTypeClass() - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Hive Timestamp data type class was changed in Hive 3.1.0.
getTimestampDataTypeClass() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getTimestampDataTypeClass() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
getUDFClass() - 类中的方法org.apache.flink.table.functions.hive.HiveFunctionWrapper: Get class of the Hive function.
getValue(GenericUDAFEvaluator.AggregationBuffer) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF
getViews(String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
getViews(IMetaStoreClient, String) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Get a list of views in the given database from the given Hive Metastore client.
getViews(IMetaStoreClient, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
getViews(IMetaStoreClient, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV230

H

HadoopFileSystemFactory - org.apache.flink.connectors.hive中的类: Hive FileSystemFactory, hive need use job conf to create file system.
hashCode() - 类中的方法org.apache.flink.connectors.hive.HiveTablePartition
hashCode() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputSplit
hashCode() - 类中的方法org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit
HIVE_VERSION_V1_0_0 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V1_0_1 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V1_1_0 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V1_1_1 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V1_2_0 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V1_2_1 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V1_2_2 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_0_0 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_0_1 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_1_0 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_1_1 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_2_0 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_3_0 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_3_1 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_3_2 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_3_3 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_3_4 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_3_5 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V2_3_6 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V3_1_0 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V3_1_1 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HIVE_VERSION_V3_1_2 - 类中的静态变量org.apache.flink.table.catalog.hive.client.HiveShimLoader
HiveBulkWriterFactory - org.apache.flink.connectors.hive.write中的类: Hive bulk writer factory for path-based bulk file writer that writes to the specific hadoop path.
HiveBulkWriterFactory(HiveWriterFactory) - 类的构造器org.apache.flink.connectors.hive.write.HiveBulkWriterFactory
HiveCatalog - org.apache.flink.table.catalog.hive中的类: A catalog implementation for Hive.
HiveCatalog(String, String, String) - 类的构造器org.apache.flink.table.catalog.hive.HiveCatalog
HiveCatalog(String, String, String, String) - 类的构造器org.apache.flink.table.catalog.hive.HiveCatalog
HiveCatalog(String, String, HiveConf, String, boolean) - 类的构造器org.apache.flink.table.catalog.hive.HiveCatalog
HiveCatalogConfig - org.apache.flink.table.catalog.hive中的类: Configs for catalog meta-objects in HiveCatalog.
HiveCatalogConfig() - 类的构造器org.apache.flink.table.catalog.hive.HiveCatalogConfig
HiveCatalogDescriptor - org.apache.flink.table.catalog.hive.descriptors中的类: Catalog descriptor for HiveCatalog.
HiveCatalogDescriptor() - 类的构造器org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor
HiveCatalogFactory - org.apache.flink.table.catalog.hive.factories中的类: Catalog factory for HiveCatalog.
HiveCatalogFactory() - 类的构造器org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory
HiveCatalogValidator - org.apache.flink.table.catalog.hive.descriptors中的类: Validator for HiveCatalogDescriptor.
HiveCatalogValidator() - 类的构造器org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator
HiveContinuousMonitoringFunction - org.apache.flink.connectors.hive.read中的类: This is the single (non-parallel) monitoring task which takes a HiveTableInputFormat, it is responsible for: Monitoring partitions of hive meta store.
HiveContinuousMonitoringFunction(HiveShim, JobConf, ObjectPath, CatalogTable, int, ConsumeOrder, String, String, String, String, long) - 类的构造器org.apache.flink.connectors.hive.read.HiveContinuousMonitoringFunction
HiveDatabaseUtil - org.apache.flink.table.catalog.hive中的类: Util methods for processing databases in HiveCatalog.
HiveDynamicTableFactory - org.apache.flink.connectors.hive中的类: A dynamic table factory implementation for Hive catalog.
HiveDynamicTableFactory() - 类的构造器org.apache.flink.connectors.hive.HiveDynamicTableFactory
HiveFunction - org.apache.flink.table.functions.hive中的接口: Interface for Hive simple udf, generic udf, and generic udtf.
HiveFunctionDefinitionFactory - org.apache.flink.table.catalog.hive.factories中的类: A factory to instantiate Hive UDFs as Flink UDFs.
HiveFunctionDefinitionFactory(HiveShim) - 类的构造器org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory
HiveFunctionUtil - org.apache.flink.table.functions.hive.util中的类: Util for Hive functions.
HiveFunctionUtil() - 类的构造器org.apache.flink.table.functions.hive.util.HiveFunctionUtil
HiveFunctionWrapper<UDFType> - org.apache.flink.table.functions.hive中的类: A wrapper of Hive functions that instantiate function instances and ser/de functino instance cross process boundary.
HiveFunctionWrapper(String) - 类的构造器org.apache.flink.table.functions.hive.HiveFunctionWrapper
hiveFunctionWrapper - 类中的变量org.apache.flink.table.functions.hive.HiveScalarFunction
HiveGenericUDAF - org.apache.flink.table.functions.hive中的类: An AggregateFunction implementation that calls Hive's UDAF or GenericUDAFEvaluator.
HiveGenericUDAF(HiveFunctionWrapper, HiveShim) - 类的构造器org.apache.flink.table.functions.hive.HiveGenericUDAF
HiveGenericUDAF(HiveFunctionWrapper, boolean, HiveShim) - 类的构造器org.apache.flink.table.functions.hive.HiveGenericUDAF
HiveGenericUDF - org.apache.flink.table.functions.hive中的类: A ScalarFunction implementation that calls Hive's GenericUDF.
HiveGenericUDF(HiveFunctionWrapper<GenericUDF>, HiveShim) - 类的构造器org.apache.flink.table.functions.hive.HiveGenericUDF
HiveGenericUDTF - org.apache.flink.table.functions.hive中的类: A TableFunction implementation that calls Hive's GenericUDTF.
HiveGenericUDTF(HiveFunctionWrapper<GenericUDTF>, HiveShim) - 类的构造器org.apache.flink.table.functions.hive.HiveGenericUDTF
HiveInspectors - org.apache.flink.table.functions.hive.conversion中的类: Util for any ObjectInspector related inspection and conversion of Hive data to/from Flink data.
HiveInspectors() - 类的构造器org.apache.flink.table.functions.hive.conversion.HiveInspectors
HiveMapredSplitReader - org.apache.flink.connectors.hive.read中的类: Hive SplitReader to read files using hadoop mapred RecordReader.
HiveMapredSplitReader(JobConf, List<String>, DataType[], int[], HiveTableInputSplit, HiveShim) - 类的构造器org.apache.flink.connectors.hive.read.HiveMapredSplitReader
HiveMetastoreClientFactory - org.apache.flink.table.catalog.hive.client中的类: Factory to create Hive metastore client.
HiveMetastoreClientWrapper - org.apache.flink.table.catalog.hive.client中的类: Wrapper class for Hive Metastore Client, which embeds a HiveShim layer to handle different Hive versions.
HiveMetastoreClientWrapper(HiveConf, String) - 类的构造器org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
HiveModule - org.apache.flink.table.module.hive中的类: Module to provide Hive built-in metadata.
HiveModule() - 类的构造器org.apache.flink.table.module.hive.HiveModule
HiveModule(String) - 类的构造器org.apache.flink.table.module.hive.HiveModule
HiveModuleDescriptor - org.apache.flink.table.module.hive中的类: Module descriptor for HiveModule.
HiveModuleDescriptor() - 类的构造器org.apache.flink.table.module.hive.HiveModuleDescriptor
HiveModuleDescriptor(String) - 类的构造器org.apache.flink.table.module.hive.HiveModuleDescriptor
HiveModuleDescriptorValidator - org.apache.flink.table.module.hive中的类: Validator for HiveModuleDescriptor.
HiveModuleDescriptorValidator() - 类的构造器org.apache.flink.table.module.hive.HiveModuleDescriptorValidator
HiveModuleFactory - org.apache.flink.table.module.hive中的类: Factory for HiveModule.
HiveModuleFactory() - 类的构造器org.apache.flink.table.module.hive.HiveModuleFactory
HiveObjectConversion - org.apache.flink.table.functions.hive.conversion中的接口: Interface to convert Flink object to Hive object.
HiveOptions - org.apache.flink.connectors.hive中的类: This class holds configuration constants used by hive connector.
HiveOptions() - 类的构造器org.apache.flink.connectors.hive.HiveOptions
HiveOutputFormatFactory - org.apache.flink.connectors.hive.write中的类: Hive OutputFormatFactory, use FileSinkOperator.RecordWriter to write record.
HiveOutputFormatFactory(HiveWriterFactory) - 类的构造器org.apache.flink.connectors.hive.write.HiveOutputFormatFactory
hivePrimitiveToWritable(Object) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Converts a Hive primitive java object to corresponding Writable object.
hivePrimitiveToWritable(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
hivePrimitiveToWritable(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
HiveReflectionUtils - org.apache.flink.table.catalog.hive.util中的类: Utilities for accessing Hive class or methods via Java reflection.
HiveReflectionUtils() - 类的构造器org.apache.flink.table.catalog.hive.util.HiveReflectionUtils
HiveRowDataPartitionComputer - org.apache.flink.connectors.hive中的类: A RowDataPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.
HiveRowDataPartitionComputer(HiveShim, String, String[], DataType[], String[]) - 类的构造器org.apache.flink.connectors.hive.HiveRowDataPartitionComputer
HiveRowPartitionComputer - org.apache.flink.connectors.hive中的类: A RowPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.
HiveScalarFunction<UDFType> - org.apache.flink.table.functions.hive中的类: Abstract class to provide more information for Hive UDF and GenericUDF functions.
HiveShim - org.apache.flink.table.catalog.hive.client中的接口: A shim layer to support different versions of Hive.
HiveShimLoader - org.apache.flink.table.catalog.hive.client中的类: A loader to load HiveShim.
HiveShimV100 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 1.0.0.
HiveShimV100() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV100
HiveShimV101 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 1.0.1.
HiveShimV101() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV101
HiveShimV110 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 1.1.0.
HiveShimV110() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV110
HiveShimV111 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 1.1.1.
HiveShimV111() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV111
HiveShimV120 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 1.2.0.
HiveShimV120() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV120
HiveShimV121 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 1.2.1.
HiveShimV121() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV121
HiveShimV122 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 1.2.2.
HiveShimV122() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV122
HiveShimV200 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.0.0.
HiveShimV200() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV200
HiveShimV201 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.0.1.
HiveShimV201() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV201
HiveShimV210 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.1.0.
HiveShimV210() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV210
HiveShimV211 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.1.1.
HiveShimV211() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV211
HiveShimV220 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.2.0.
HiveShimV220() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV220
HiveShimV230 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.3.0.
HiveShimV230() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV230
HiveShimV231 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.3.1.
HiveShimV231() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV231
HiveShimV232 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.3.2.
HiveShimV232() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV232
HiveShimV233 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.3.3.
HiveShimV233() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV233
HiveShimV234 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.3.4.
HiveShimV234() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV234
HiveShimV235 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.3.5.
HiveShimV235() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV235
HiveShimV236 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 2.3.6.
HiveShimV236() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV236
HiveShimV310 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 3.1.0.
HiveShimV310() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV310
HiveShimV311 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 3.1.1.
HiveShimV311() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV311
HiveShimV312 - org.apache.flink.table.catalog.hive.client中的类: Shim for Hive version 3.1.2.
HiveShimV312() - 类的构造器org.apache.flink.table.catalog.hive.client.HiveShimV312
HiveSimpleUDF - org.apache.flink.table.functions.hive中的类: A ScalarFunction implementation that calls Hive's UDF.
HiveSimpleUDF(HiveFunctionWrapper<UDF>, HiveShim) - 类的构造器org.apache.flink.table.functions.hive.HiveSimpleUDF
hiveSitePath(String) - 类中的方法org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor
HiveStatsUtil - org.apache.flink.table.catalog.hive.util中的类: Utils for stats of HiveCatalog.
HiveTableFactory - org.apache.flink.connectors.hive中的类: A table factory implementation for Hive catalog.
HiveTableFactory(HiveConf) - 类的构造器org.apache.flink.connectors.hive.HiveTableFactory
HiveTableFileInputFormat - org.apache.flink.connectors.hive.read中的类: A FileInputFormat that wraps a HiveTableInputFormat.
HiveTableFileInputFormat(HiveTableInputFormat, HiveTablePartition) - 类的构造器org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
HiveTableInputFormat - org.apache.flink.connectors.hive.read中的类: The HiveTableInputFormat are inspired by the HCatInputFormat and HadoopInputFormatBase.
HiveTableInputFormat(JobConf, CatalogTable, List<HiveTablePartition>, int[], long, String, boolean) - 类的构造器org.apache.flink.connectors.hive.read.HiveTableInputFormat
HiveTableInputSplit - org.apache.flink.connectors.hive.read中的类: An wrapper class that wraps info needed for a hadoop input split.
HiveTableInputSplit(int, InputSplit, JobConf, HiveTablePartition) - 类的构造器org.apache.flink.connectors.hive.read.HiveTableInputSplit
HiveTableMetaStoreFactory - org.apache.flink.connectors.hive中的类: Hive TableMetaStoreFactory, use HiveMetastoreClientWrapper to communicate with hive meta store.
HiveTablePartition - org.apache.flink.connectors.hive中的类: A class that describes a partition of a Hive table.
HiveTablePartition(StorageDescriptor, Properties) - 类的构造器org.apache.flink.connectors.hive.HiveTablePartition
HiveTablePartition(StorageDescriptor, Map<String, Object>, Properties) - 类的构造器org.apache.flink.connectors.hive.HiveTablePartition
hiveTablePartition - 类中的变量org.apache.flink.connectors.hive.read.HiveTableInputSplit
HiveTableSink - org.apache.flink.connectors.hive中的类: Table sink to write to Hive tables.
HiveTableSink(boolean, boolean, JobConf, ObjectIdentifier, CatalogTable) - 类的构造器org.apache.flink.connectors.hive.HiveTableSink
HiveTableSource - org.apache.flink.connectors.hive中的类: A TableSource implementation to read data from Hive tables.
HiveTableSource(JobConf, ReadableConfig, ObjectPath, CatalogTable) - 类的构造器org.apache.flink.connectors.hive.HiveTableSource
HiveTableUtil - org.apache.flink.table.catalog.hive.util中的类: Utils to for Hive-backed table.
HiveTypeUtil - org.apache.flink.table.catalog.hive.util中的类: Utils to convert data types between Flink and Hive.
HiveTypeUtil.HivePrimitiveCategory - org.apache.flink.table.catalog.hive.util中的枚举: INTERVAL are not available in older versions.
HiveVectorizedOrcSplitReader - org.apache.flink.connectors.hive.read中的类: Orc SplitReader to read files using OrcColumnarRowSplitReader.
HiveVectorizedOrcSplitReader(String, JobConf, String[], DataType[], int[], HiveTableInputSplit) - 类的构造器org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader
HiveVectorizedParquetSplitReader - org.apache.flink.connectors.hive.read中的类: Orc SplitReader to read files using ParquetColumnarRowSplitReader.
HiveVectorizedParquetSplitReader(String, JobConf, String[], DataType[], int[], HiveTableInputSplit) - 类的构造器org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader
hiveVersion(String) - 类中的方法org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor
HiveWriterFactory - org.apache.flink.connectors.hive.write中的类: Factory for creating FileSinkOperator.RecordWriter and converters for writing.
HiveWriterFactory(JobConf, Class, SerDeInfo, TableSchema, String[], Properties, HiveShim, boolean) - 类的构造器org.apache.flink.connectors.hive.write.HiveWriterFactory

I

IdentityConversion - org.apache.flink.table.functions.hive.conversion中的类: Conversion that return the same object.
initializeState(FunctionInitializationContext) - 类中的方法org.apache.flink.connectors.hive.read.HiveContinuousMonitoringFunction
initiateTableFromProperties(Table, Map<String, String>, HiveConf) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil: Extract DDL semantics from properties and use it to initiate the table.
INSTANCE - 类中的静态变量org.apache.flink.table.functions.hive.conversion.IdentityConversion
instantiateHiveTable(ObjectPath, CatalogBaseTable, HiveConf) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
invokeMethod(Class, Object, String, Class[], Object[]) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveReflectionUtils
isAsyncEnabled() - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
isBounded() - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
isDateStats(ColumnStatisticsData) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Whether a Hive ColumnStatisticsData is for DATE columns.
isDateStats(ColumnStatisticsData) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
isDateStats(ColumnStatisticsData) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV120
isDeterministic() - 类中的方法org.apache.flink.table.functions.hive.HiveScalarFunction
isGenericForCreate(Map<String, String>) - 类中的静态方法org.apache.flink.table.catalog.hive.HiveCatalog
isGenericForGet(Map<String, String>) - 类中的静态方法org.apache.flink.table.catalog.hive.HiveCatalog
isLimitPushedDown() - 类中的方法org.apache.flink.connectors.hive.HiveTableSource
isSingleBoxedArray(DataType[]) - 类中的静态方法org.apache.flink.table.functions.hive.util.HiveFunctionUtil

J

JobConfWrapper - org.apache.flink.connectors.hive中的类: Wrap JobConf to a serializable class.
JobConfWrapper(JobConf) - 类的构造器org.apache.flink.connectors.hive.JobConfWrapper

K

key - 类中的变量org.apache.flink.connectors.hive.read.HiveMapredSplitReader

L

listBuiltInFunctions() - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: List names of all built-in functions.
listBuiltInFunctions() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
listBuiltInFunctions() - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV120
listDatabases() - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
listFunctions(String) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
listFunctions() - 类中的方法org.apache.flink.table.module.hive.HiveModule
listPartitionNames(String, String, short) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
listPartitionNames(String, String, List<String>, short) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
listPartitions(String, String, List<String>, short) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
listPartitions(String, String, short) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
listPartitions(ObjectPath) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
listPartitions(ObjectPath, CatalogPartitionSpec) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
listPartitionsByFilter(ObjectPath, List<Expression>) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
listPartitionSpecsByFilter(String, String, String, short) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
listTables(String) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
listViews(String) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
loadHiveShim(String) - 类中的静态方法org.apache.flink.table.catalog.hive.client.HiveShimLoader

M

makePartitionFilter(int, List<String>, List<Expression>, HiveShim) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil: Generates a filter string for partition columns from the given filter expressions.
maskFlinkProperties(Map<String, String>) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil: Add a prefix to Flink-created properties to distinguish them from Hive-created properties.
merge(GenericUDAFEvaluator.AggregationBuffer, Iterable<GenericUDAFEvaluator.AggregationBuffer>) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF
MODULE_HIVE_VERSION - 类中的静态变量org.apache.flink.table.module.hive.HiveModuleDescriptorValidator
MODULE_TYPE_HIVE - 类中的静态变量org.apache.flink.table.module.hive.HiveModuleDescriptorValidator

N

nextRecord(RowData) - 类中的方法org.apache.flink.connectors.hive.read.HiveMapredSplitReader
nextRecord(RowData) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
nextRecord(RowData) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
nextRecord(RowData) - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader
nextRecord(RowData) - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader
nextRecord(RowData) - 接口中的方法org.apache.flink.connectors.hive.read.SplitReader: Reads the next record from the input.

O

open(FileInputSplit) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
open(HiveTableInputSplit) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
open() - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
open(FunctionContext) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF
open(FunctionContext) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDTF
open(FunctionContext) - 类中的方法org.apache.flink.table.functions.hive.HiveScalarFunction
openInputFormat() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
openInternal() - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDF
openInternal() - 类中的方法org.apache.flink.table.functions.hive.HiveScalarFunction: See UserDefinedFunction.open(FunctionContext).
openInternal() - 类中的方法org.apache.flink.table.functions.hive.HiveSimpleUDF
optionalOptions() - 类中的方法org.apache.flink.connectors.hive.HiveDynamicTableFactory
org.apache.flink.connectors.hive - 程序包 org.apache.flink.connectors.hive
org.apache.flink.connectors.hive.read - 程序包 org.apache.flink.connectors.hive.read
org.apache.flink.connectors.hive.write - 程序包 org.apache.flink.connectors.hive.write
org.apache.flink.table.catalog.hive - 程序包 org.apache.flink.table.catalog.hive
org.apache.flink.table.catalog.hive.client - 程序包 org.apache.flink.table.catalog.hive.client
org.apache.flink.table.catalog.hive.descriptors - 程序包 org.apache.flink.table.catalog.hive.descriptors
org.apache.flink.table.catalog.hive.factories - 程序包 org.apache.flink.table.catalog.hive.factories
org.apache.flink.table.catalog.hive.util - 程序包 org.apache.flink.table.catalog.hive.util
org.apache.flink.table.functions.hive - 程序包 org.apache.flink.table.functions.hive
org.apache.flink.table.functions.hive.conversion - 程序包 org.apache.flink.table.functions.hive.conversion
org.apache.flink.table.functions.hive.util - 程序包 org.apache.flink.table.functions.hive.util
org.apache.flink.table.module.hive - 程序包 org.apache.flink.table.module.hive

P

parsePositiveIntStat(Map<String, String>, String) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveStatsUtil
parsePositiveLongStat(Map<String, String>, String) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveStatsUtil
PARTITION_LOCATION - 类中的静态变量org.apache.flink.table.catalog.hive.HiveCatalogConfig
PartitionDiscovery - org.apache.flink.connectors.hive.read中的接口: Partition strategy for helping fetch hive partitioned table.
PartitionDiscovery.Context - org.apache.flink.connectors.hive.read中的接口: Context for fetch partitions, partition information is stored in hive meta store.
partitionExists(ObjectPath, CatalogPartitionSpec) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
partitionKeys() - 接口中的方法org.apache.flink.connectors.hive.read.PartitionDiscovery.Context: Partition keys of this table.
prepare(int) - 类中的方法org.apache.flink.table.functions.hive.DeferredObjectAdapter
projectFields(int[]) - 类中的方法org.apache.flink.connectors.hive.HiveTableSource

R

reachedEnd() - 类中的方法org.apache.flink.connectors.hive.read.HiveMapredSplitReader
reachedEnd() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
reachedEnd() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
reachedEnd() - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader
reachedEnd() - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader
reachedEnd() - 接口中的方法org.apache.flink.connectors.hive.read.SplitReader: Method used to check if the end of the input is reached.
reader - 类中的变量org.apache.flink.connectors.hive.read.HiveTableInputFormat
relyConstraint(byte) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
renamePartition(String, String, List<String>, Partition) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
renameTable(ObjectPath, String, boolean) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
reopen(HiveTableInputSplit, Long) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
requiredContext() - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
requiredContext() - 类中的方法org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory
requiredContext() - 类中的方法org.apache.flink.table.module.hive.HiveModuleFactory
requiredOptions() - 类中的方法org.apache.flink.connectors.hive.HiveDynamicTableFactory
requireEnableConstraint(byte) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
requireRelyConstraint(byte) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
requireValidateConstraint(byte) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
returnInspector - 类中的变量org.apache.flink.table.functions.hive.HiveScalarFunction
run(SourceFunction.SourceContext<TimestampedHiveInputSplit>) - 类中的方法org.apache.flink.connectors.hive.read.HiveContinuousMonitoringFunction

S

seekToRow(long, RowData) - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader
seekToRow(long, RowData) - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader
seekToRow(long, RowData) - 接口中的方法org.apache.flink.connectors.hive.read.SplitReader: Seek to a particular row number.
serialVersionUID - 类中的静态变量org.apache.flink.table.functions.hive.HiveFunctionWrapper
set(Object) - 类中的方法org.apache.flink.table.functions.hive.DeferredObjectAdapter
setArgumentTypesAndConstants(Object[], DataType[]) - 接口中的方法org.apache.flink.table.functions.hive.HiveFunction: Set arguments and argTypes for Function instance.
setArgumentTypesAndConstants(Object[], DataType[]) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDAF
setArgumentTypesAndConstants(Object[], DataType[]) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDTF
setArgumentTypesAndConstants(Object[], DataType[]) - 类中的方法org.apache.flink.table.functions.hive.HiveScalarFunction
setCollector(Collector) - 类中的方法org.apache.flink.table.functions.hive.HiveGenericUDTF
setDefaultStorageFormat(StorageDescriptor, HiveConf) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
setOverwrite(boolean) - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
setRuntimeContext(RuntimeContext) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableFileInputFormat
setSplitState(Serializable) - 类中的方法org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit
setStaticPartition(Map<String, String>) - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
setStorageFormat(StorageDescriptor, String, HiveConf) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
snapshotState(FunctionSnapshotContext) - 类中的方法org.apache.flink.connectors.hive.read.HiveContinuousMonitoringFunction
SplitReader - org.apache.flink.connectors.hive.read中的接口: Split reader to read record from files.
SplitTypeInfoFactory() - 类的构造器org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit.SplitTypeInfoFactory
supportedProperties() - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
supportedProperties() - 类中的方法org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory
supportedProperties() - 类中的方法org.apache.flink.table.module.hive.HiveModuleFactory

T

TABLE_EXEC_HIVE_FALLBACK_MAPRED_READER - 类中的静态变量org.apache.flink.connectors.hive.HiveOptions
TABLE_EXEC_HIVE_FALLBACK_MAPRED_WRITER - 类中的静态变量org.apache.flink.connectors.hive.HiveOptions
TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM - 类中的静态变量org.apache.flink.connectors.hive.HiveOptions
TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM_MAX - 类中的静态变量org.apache.flink.connectors.hive.HiveOptions
tableExists(String, String) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
tableExists(ObjectPath) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
tableLocation() - 接口中的方法org.apache.flink.connectors.hive.read.PartitionDiscovery.Context: Root location of table.
TimestampedHiveInputSplit - org.apache.flink.connectors.hive.read中的类: A HiveTableInputSplit with TimestampedInputSplit.
TimestampedHiveInputSplit(long, HiveTableInputSplit) - 类的构造器org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit
TimestampedHiveInputSplit.SplitTypeInfoFactory - org.apache.flink.connectors.hive.read中的类: TypeInfoFactory for TimestampedHiveInputSplit.
toCatalogProperties() - 类中的方法org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor
toFlinkDate(Object) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Converts a hive date instance to LocalDate which is expected by DataFormatConverter.
toFlinkDate(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
toFlinkDate(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
toFlinkDateColStats(ColumnStatisticsData) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Generate Flink CatalogColumnStatisticsDataDate from Hive ColumnStatisticsData for DATE columns.
toFlinkDateColStats(ColumnStatisticsData) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
toFlinkDateColStats(ColumnStatisticsData) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV120
toFlinkObject(ObjectInspector, Object, HiveShim) - 类中的静态方法org.apache.flink.table.functions.hive.conversion.HiveInspectors: Converts a Hive object to Flink object with an ObjectInspector.
toFlinkTimestamp(Object) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Converts a hive timestamp instance to LocalDateTime which is expected by DataFormatConverter.
toFlinkTimestamp(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
toFlinkTimestamp(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
toFlinkType(ObjectInspector) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTypeUtil: Convert a Hive ObjectInspector to a Flink data type.
toFlinkType(TypeInfo) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTypeUtil: Convert Hive data type to a Flink data type.
toHiveDate(Object) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Converts a Flink date instance to what's expected by Hive.
toHiveDate(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
toHiveDate(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
toHiveDateColStats(CatalogColumnStatisticsDataDate) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Generate Hive ColumnStatisticsData from Flink CatalogColumnStatisticsDataDate for DATE columns.
toHiveDateColStats(CatalogColumnStatisticsDataDate) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
toHiveDateColStats(CatalogColumnStatisticsDataDate) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV120
toHiveObject(Object) - 接口中的方法org.apache.flink.table.functions.hive.conversion.HiveObjectConversion
toHiveObject(Object) - 类中的方法org.apache.flink.table.functions.hive.conversion.IdentityConversion
toHiveObject(Object) - 类中的方法org.apache.flink.table.functions.hive.conversion.WritableHiveObjectConversion
toHiveTablePartition(List<String>, String[], DataType[], HiveShim, Properties, String, Partition) - 类中的静态方法org.apache.flink.connectors.hive.HiveTableSource
toHiveTimestamp(Object) - 接口中的方法org.apache.flink.table.catalog.hive.client.HiveShim: Converts a Flink timestamp instance to what's expected by Hive.
toHiveTimestamp(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV100
toHiveTimestamp(Object) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveShimV310
toHiveTypeInfo(DataType, boolean) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTypeUtil: Convert Flink DataType to Hive TypeInfo.
toInspectors(HiveShim, Object[], DataType[]) - 类中的静态方法org.apache.flink.table.functions.hive.conversion.HiveInspectors: Get an array of ObjectInspector from the give array of args and their types.
toModuleProperties() - 类中的方法org.apache.flink.table.module.hive.HiveModuleDescriptor
toString() - 枚举中的方法org.apache.flink.connectors.hive.ConsumeOrder
toString() - 类中的方法org.apache.flink.connectors.hive.HiveTablePartition
toString() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputSplit
toString() - 类中的方法org.apache.flink.connectors.hive.read.TimestampedHiveInputSplit

U

updatePartitionColumnStatistics(ColumnStatistics) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper
updateTableColumnStatistics(ColumnStatistics) - 类中的方法org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

V

validate(DescriptorProperties) - 类中的方法org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator
validate(DescriptorProperties) - 类中的方法org.apache.flink.table.module.hive.HiveModuleDescriptorValidator
validateConstraint(byte) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveTableUtil
value - 类中的变量org.apache.flink.connectors.hive.read.HiveMapredSplitReader
valueOf(String) - 枚举中的静态方法org.apache.flink.connectors.hive.ConsumeOrder: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.table.catalog.hive.util.HiveTypeUtil.HivePrimitiveCategory: 返回带有指定名称的该类型的枚举常量。
values() - 枚举中的静态方法org.apache.flink.connectors.hive.ConsumeOrder: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.table.catalog.hive.util.HiveTypeUtil.HivePrimitiveCategory: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。

W

WritableHiveObjectConversion - org.apache.flink.table.functions.hive.conversion中的类: A HiveObjectConversion that converts Flink objects to Hive Writable objects.

A C D E F G H I J K L M N O P R S T U V W