索引 (flink-connector-hive 1.10.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
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
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

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.HiveMapredSplitReader
close() - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
close() - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader
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
COMMENT - 类中的静态变量org.apache.flink.table.catalog.hive.HiveCatalogConfig
conf() - 类中的方法org.apache.flink.connectors.hive.JobConfWrapper
configure(String[], TypeInformation<?>[]) - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
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
create(URI) - 类中的方法org.apache.flink.connectors.hive.HadoopFileSystemFactory
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
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
createModule(Map<String, String>) - 类中的方法org.apache.flink.table.module.hive.HiveModuleFactory
createOutputFormat(Path) - 类中的方法org.apache.flink.connectors.hive.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.
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(Map<String, String>) - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
createTableSink(ObjectPath, CatalogTable) - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
createTableSource(Map) - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
createTableSource(ObjectPath, CatalogTable) - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
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

DATABASE_LOCATION_URI - 类中的静态变量org.apache.flink.table.catalog.hive.HiveCatalogConfig
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
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
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

F

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(Row) - 类中的方法org.apache.flink.connectors.hive.HivePartitionComputer
GENERIC_TABLE_SCHEMA_PREFIX - 类中的静态变量org.apache.flink.table.catalog.hive.HiveCatalogConfig
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
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
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.
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
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
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
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
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
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.
getOutputFormat() - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
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
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.
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
HiveCatalog - org.apache.flink.table.catalog.hive中的类: A catalog implementation for Hive.
HiveCatalog(String, String, String, String) - 类的构造器org.apache.flink.table.catalog.hive.HiveCatalog
HiveCatalog(String, String, HiveConf, String) - 类的构造器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
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(String) - 类的构造器org.apache.flink.table.module.hive.HiveModule
HiveModuleDescriptor - org.apache.flink.table.module.hive中的类: Module descriptor for HiveModule.
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中的类: Hive OutputFormatFactory, use FileSinkOperator.RecordWriter to write record.
HiveOutputFormatFactory(JobConf, Class, SerDeInfo, TableSchema, String[], Properties, HiveShim, boolean) - 类的构造器org.apache.flink.connectors.hive.HiveOutputFormatFactory
HivePartitionComputer - org.apache.flink.connectors.hive中的类: A RowPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.
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
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
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
HiveTableSink - org.apache.flink.connectors.hive中的类: Table sink to write to Hive tables.
HiveTableSink(JobConf, ObjectPath, CatalogTable) - 类的构造器org.apache.flink.connectors.hive.HiveTableSink
HiveTableSource - org.apache.flink.connectors.hive中的类: A TableSource implementation to read data from Hive tables.
HiveTableSource(JobConf, 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
hiveVersion(String) - 类中的方法org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor

I

IdentityConversion - org.apache.flink.table.functions.hive.conversion中的类: Conversion that return the same object.
INSTANCE - 类中的静态变量org.apache.flink.table.functions.hive.conversion.IdentityConversion
instantiateHiveTable(ObjectPath, CatalogBaseTable) - 类中的静态方法org.apache.flink.table.catalog.hive.HiveCatalog
invokeMethod(Class, Object, String, Class[], Object[]) - 类中的静态方法org.apache.flink.table.catalog.hive.util.HiveReflectionUtils
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
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.

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.
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(BaseRow) - 类中的方法org.apache.flink.connectors.hive.read.HiveMapredSplitReader
nextRecord(BaseRow) - 类中的方法org.apache.flink.connectors.hive.read.HiveTableInputFormat
nextRecord(BaseRow) - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader
nextRecord(BaseRow) - 接口中的方法org.apache.flink.connectors.hive.read.SplitReader: Reads the next record from the input.

O

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
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
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.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
partitionExists(ObjectPath, CatalogPartitionSpec) - 类中的方法org.apache.flink.table.catalog.hive.HiveCatalog
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.HiveTableInputFormat
reachedEnd() - 类中的方法org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader
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
requiredContext() - 类中的方法org.apache.flink.connectors.hive.HiveTableFactory
requiredContext() - 类中的方法org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory
requiredContext() - 类中的方法org.apache.flink.table.module.hive.HiveModuleFactory
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

S

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
setOverwrite(boolean) - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
setStaticPartition(Map<String, String>) - 类中的方法org.apache.flink.connectors.hive.HiveTableSink
SplitReader - org.apache.flink.connectors.hive.read中的接口: Split reader to read record from files.
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_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
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
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

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.table.catalog.hive.util.HiveTypeUtil.HivePrimitiveCategory: 返回带有指定名称的该类型的枚举常量。
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