A B 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...) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF

add_partition(Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

add_partitions(List<Partition>) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

addReader(int) - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator

addSplitsBack(List<HiveSourceSplit>, int) - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator

alter_partition(String, String, Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

alter_table(String, String, Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

alterColumns(StorageDescriptor, CatalogTable) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

alterDatabase(String, Database) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

alterDatabase(String, CatalogDatabase, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

alterFunction(String, String, Function) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

alterFunction(ObjectPath, CatalogFunction, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

alterPartition(IMetaStoreClient, String, String, Partition) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

alterPartition(IMetaStoreClient, String, String, Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

alterPartition(IMetaStoreClient, String, String, Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV210

alterPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

alterPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec, CatalogColumnStatistics, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

alterPartitionStatistics(ObjectPath, CatalogPartitionSpec, CatalogTableStatistics, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

alterTable(IMetaStoreClient, String, String, Table) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Alters a Hive table.

alterTable(IMetaStoreClient, String, String, Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

alterTable(IMetaStoreClient, String, String, Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV120

alterTable(IMetaStoreClient, String, String, Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV230

alterTable(ObjectPath, CatalogBaseTable, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

alterTableColumnStatistics(ObjectPath, CatalogColumnStatistics, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

alterTableStatistics(ObjectPath, CatalogTableStatistics, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

alterTableViaCatalogBaseTable(ObjectPath, CatalogBaseTable, Table, HiveConf) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

applyLimit(long) - Method in class org.apache.flink.connectors.hive.HiveTableSource

applyOverwrite(boolean) - Method in class org.apache.flink.connectors.hive.HiveTableSink

applyPartitions(List<Map<String, String>>) - Method in class org.apache.flink.connectors.hive.HiveTableSource

applyProjection(int[][]) - Method in class org.apache.flink.connectors.hive.HiveTableSource

applyStaticPartition(Map<String, String>) - Method in class org.apache.flink.connectors.hive.HiveTableSink

argTypes - Variable in class org.apache.flink.table.functions.hive.HiveScalarFunction

asSummaryString() - Method in class org.apache.flink.connectors.hive.HiveTableSink

asSummaryString() - Method in class org.apache.flink.connectors.hive.HiveTableSource

B

build() - Method in class org.apache.flink.connectors.hive.HiveSource.HiveSourceBuilder

C

CachedSerializedValue<T> - Class in org.apache.flink.connectors.hive

An extension of SerializedValue which caches the deserialized data.

CachedSerializedValue(T) - Constructor for class org.apache.flink.connectors.hive.CachedSerializedValue

CATALOG_HADOOP_CONF_DIR - Static variable in class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator

CATALOG_HIVE_CONF_DIR - Static variable in class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator

CATALOG_HIVE_VERSION - Static variable in class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator

CATALOG_TYPE_VALUE_HIVE - Static variable in class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator

catalogTable - Variable in class org.apache.flink.connectors.hive.HiveTableSource

checkAcidTable(CatalogTable, ObjectPath) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

Check whether to read or write on the hive ACID table.

close() - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator

close() - Method in class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

close() - Method in class org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader

close() - Method in class org.apache.flink.connectors.hive.read.HiveMapredSplitReader

close() - Method in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

close() - Method in class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

close() - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

close() - Method in class org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader

close() - Method in class org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader

close() - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

close() - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

close() - Method in class org.apache.flink.table.functions.hive.HiveGenericUDTF

closeInputFormat() - Method in class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

COMMENT - Static variable in class org.apache.flink.table.catalog.hive.HiveCatalogConfig

conf() - Method in class org.apache.flink.connectors.hive.JobConfWrapper

configuration - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

configure(Configuration) - Method in class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

configure(Configuration) - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

confWrapper - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

constantArguments - Variable in class org.apache.flink.table.functions.hive.HiveScalarFunction

ConsumeOrder - Enum in org.apache.flink.connectors.hive

ConsumeOrder defines the orders to continuously consume stream source.

consumeOrder - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

ContinuousHivePendingSplitsCheckpoint - Class in org.apache.flink.connectors.hive

The checkpoint of current state of continuous hive source reading.

ContinuousHivePendingSplitsCheckpoint(Collection<HiveSourceSplit>, Comparable<?>, Collection<List<String>>) - Constructor for class org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpoint

ContinuousHivePendingSplitsCheckpointSerializer - Class in org.apache.flink.connectors.hive

SerDe for ContinuousHivePendingSplitsCheckpoint.

ContinuousHivePendingSplitsCheckpointSerializer(SimpleVersionedSerializer<HiveSourceSplit>) - Constructor for class org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpointSerializer

ContinuousHiveSplitEnumerator<T extends Comparable<T>> - Class in org.apache.flink.connectors.hive

A continuously monitoring SplitEnumerator for hive source.

ContinuousHiveSplitEnumerator(SplitEnumeratorContext<HiveSourceSplit>, T, Collection<List<String>>, FileSplitAssigner, long, JobConf, ObjectPath, ContinuousPartitionFetcher<Partition, T>, HiveTableSource.HiveContinuousPartitionFetcherContext<T>) - Constructor for class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator

copy() - Method in class org.apache.flink.connectors.hive.HiveTableSink

copy() - Method in class org.apache.flink.connectors.hive.HiveTableSource

create(URI) - Method in class org.apache.flink.connectors.hive.HadoopFileSystemFactory

create() - Method in class org.apache.flink.connectors.hive.HiveSourceFileEnumerator.Provider

create(CompactContext) - Method in class org.apache.flink.connectors.hive.read.HiveCompactReaderFactory

create(Configuration) - Static method in class org.apache.flink.connectors.hive.util.HiveConfUtils

Create HiveConf instance via Hadoop configuration.

create(Path, Path) - Method in class org.apache.flink.connectors.hive.write.HiveBulkWriterFactory

create(HiveConf, String) - Static method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientFactory

createAccumulator() - Method in class 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>) - Method in class org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory

createCatalogColumnStats(List<ColumnStatisticsObj>, String) - Static method in class org.apache.flink.table.catalog.hive.util.HiveStatsUtil

Create a map of Flink column stats from the given Hive column stats.

createConstantObjectInspector(String, Object) - Static method in class org.apache.flink.table.catalog.hive.util.HiveReflectionUtils

createDatabase(Database) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

createDatabase(String, CatalogDatabase, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

createDynamicTableSink(DynamicTableFactory.Context) - Method in class org.apache.flink.connectors.hive.HiveDynamicTableFactory

createDynamicTableSource(DynamicTableFactory.Context) - Method in class org.apache.flink.connectors.hive.HiveDynamicTableFactory

createEnumerator(SplitEnumeratorContext<HiveSourceSplit>) - Method in class org.apache.flink.connectors.hive.HiveSource

createFunction(Function) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

createFunction(ObjectPath, CatalogFunction, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

createFunction() - Method in class org.apache.flink.table.functions.hive.HiveFunctionWrapper

Instantiate a Hive function instance.

createFunctionDefinition(String, CatalogFunction) - Method in class org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory

createFunctionDefinitionFromFlinkFunction(String, CatalogFunction) - Method in class org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory

createFunctionDefinitionFromHiveFunction(String, String) - Method in class org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory

Create a FunctionDefinition from a Hive function's class name.

createHiveColumns(TableSchema) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

Create Hive columns from Flink TableSchema.

createHivePartition(String, String, List<String>, StorageDescriptor, Map<String, String>) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

Creates a Hive partition instance.

createInputSplits(int, List<HiveTablePartition>, JobConf) - Static method in class org.apache.flink.connectors.hive.HiveSourceFileEnumerator

createInputSplits(int) - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

createInputSplits(int, List<HiveTablePartition>, JobConf) - Static method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

createModule(Map<String, String>) - Method in class org.apache.flink.table.module.hive.HiveModuleFactory

createOrcBulkWriterFactory(Configuration, String, LogicalType[]) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Create orc BulkWriter.Factory for different hive versions.

createOrcBulkWriterFactory(Configuration, String, LogicalType[]) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

createOrcBulkWriterFactory(Configuration, String, LogicalType[]) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV200

createOutputFormat(Path) - Method in class org.apache.flink.connectors.hive.write.HiveOutputFormatFactory

createPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

createPartitionColumnStats(Partition, String, Map<String, CatalogColumnStatisticsDataBase>, String) - Static method in class org.apache.flink.table.catalog.hive.util.HiveStatsUtil

Create columnStatistics from the given Hive column stats of a hive partition.

createReader(Configuration, HiveSourceSplit) - Method in class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter

createRecordWriter(Path) - Method in class org.apache.flink.connectors.hive.write.HiveWriterFactory

Create a FileSinkOperator.RecordWriter from path.

createRowConverter() - Method in class org.apache.flink.connectors.hive.write.HiveWriterFactory

createRowDataConverter() - Method in class org.apache.flink.connectors.hive.write.HiveWriterFactory

createTable(Table) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

createTable(ObjectPath, CatalogBaseTable, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

createTableColumnStats(Table, Map<String, CatalogColumnStatisticsDataBase>, String) - Static method in class org.apache.flink.table.catalog.hive.util.HiveStatsUtil

Create columnStatistics from the given Hive column stats of a hive table.

createTableMetaStore() - Method in class org.apache.flink.connectors.hive.HiveTableMetaStoreFactory

createTableSchema(List<FieldSchema>, List<FieldSchema>, Set<String>, UniqueConstraint) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

Create a Flink's TableSchema from Hive table's columns and partition keys.

createTableSink(TableSinkFactory.Context) - Method in class org.apache.flink.connectors.hive.HiveTableFactory

createTableSource(TableSourceFactory.Context) - Method in class org.apache.flink.connectors.hive.HiveTableFactory

createTableWithConstraints(Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

createTableWithConstraints(IMetaStoreClient, Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - Method in interface 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>) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

createTableWithConstraints(IMetaStoreClient, Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV210

createTableWithConstraints(IMetaStoreClient, Table, Configuration, UniqueConstraint, List<Byte>, List<String>, List<Byte>) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

createUDAFParameterInfo(ObjectInspector[], boolean, boolean, boolean) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Creates SimpleGenericUDAFParameterInfo.

createUDAFParameterInfo(ObjectInspector[], boolean, boolean, boolean) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

createUDAFParameterInfo(ObjectInspector[], boolean, boolean, boolean) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV230

D

databaseExists(String) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

DEFAULT_DB - Static variable in class org.apache.flink.table.catalog.hive.HiveCatalog

DEFAULT_LIST_COLUMN_TYPES_SEPARATOR - Static variable in class org.apache.flink.table.catalog.hive.HiveCatalogConfig

defaultPartitionName - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

DeferredObjectAdapter - Class in org.apache.flink.table.functions.hive

Adapter from Java Object to Hive DeferredObject.

DeferredObjectAdapter(ObjectInspector, LogicalType, HiveShim) - Constructor for class org.apache.flink.table.functions.hive.DeferredObjectAdapter

deserialize(int, byte[]) - Method in class org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpointSerializer

deserialize(int, byte[]) - Method in class org.apache.flink.connectors.hive.HiveSourceSplitSerializer

deserializeValue(ClassLoader) - Method in class org.apache.flink.connectors.hive.CachedSerializedValue

deserializeValue() - Method in class org.apache.flink.connectors.hive.CachedSerializedValue

disallowChangeIsGeneric(boolean, boolean) - Static method in class org.apache.flink.table.catalog.hive.HiveCatalog

dropDatabase(String, boolean, boolean) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

dropDatabase(String, boolean, boolean, boolean) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

dropDatabase(String, boolean, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

dropFunction(String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

dropFunction(ObjectPath, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

dropPartition(String, String, List<String>, boolean) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

dropPartition(ObjectPath, CatalogPartitionSpec, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

dropTable(String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

dropTable(String, String, boolean, boolean) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

dropTable(ObjectPath, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

E

enableConstraint(byte) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

enumerateSplits(Path[], int) - Method in class org.apache.flink.connectors.hive.HiveSourceFileEnumerator

equals(Object) - Method in class org.apache.flink.connectors.hive.HiveTablePartition

equals(Object) - Method in class org.apache.flink.connectors.hive.read.HiveTableInputSplit

eval(Object...) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDTF

eval(Object...) - Method in class org.apache.flink.table.functions.hive.HiveScalarFunction

evalInternal(Object[]) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDF

evalInternal(Object[]) - Method in class org.apache.flink.table.functions.hive.HiveScalarFunction

Evaluation logical, args will be wrapped when is a single array.

evalInternal(Object[]) - Method in class org.apache.flink.table.functions.hive.HiveSimpleUDF

extractAlterTableOp(Map<String, String>) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

extractLocation(StorageDescriptor, Map<String, String>) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

extractRowFormat(StorageDescriptor, Map<String, String>) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

F

factoryIdentifier() - Method in class org.apache.flink.connectors.hive.HiveDynamicTableFactory

fetch(PartitionFetcher.Context<Partition>) - Method in class org.apache.flink.connectors.hive.read.HiveContinuousPartitionFetcher

fetchPartitions(ContinuousPartitionFetcher.Context<Partition, T>, T) - Method in class org.apache.flink.connectors.hive.read.HiveContinuousPartitionFetcher

fieldNames - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

fieldTypes - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

flinkConf - Variable in class org.apache.flink.connectors.hive.HiveTableSource

FlinkHiveException - Exception in org.apache.flink.connectors.hive

Exception used by flink's hive data connector.

FlinkHiveException(String) - Constructor for exception org.apache.flink.connectors.hive.FlinkHiveException

FlinkHiveException(Throwable) - Constructor for exception org.apache.flink.connectors.hive.FlinkHiveException

FlinkHiveException(String, Throwable) - Constructor for exception org.apache.flink.connectors.hive.FlinkHiveException

FlinkHiveUDFException - Exception in org.apache.flink.table.functions.hive

Hive UDF related exceptions in Flink.

FlinkHiveUDFException(String) - Constructor for exception org.apache.flink.table.functions.hive.FlinkHiveUDFException

FlinkHiveUDFException(Throwable) - Constructor for exception org.apache.flink.table.functions.hive.FlinkHiveUDFException

FlinkHiveUDFException(String, Throwable) - Constructor for exception org.apache.flink.table.functions.hive.FlinkHiveUDFException

fs - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

function - Variable in class org.apache.flink.table.functions.hive.HiveScalarFunction

functionExists(ObjectPath) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

G

generatePartValues(RowData) - Method in class org.apache.flink.connectors.hive.HiveRowDataPartitionComputer

generatePartValues(Row) - Method in class org.apache.flink.connectors.hive.HiveRowPartitionComputer

get() - Method in class org.apache.flink.table.functions.hive.DeferredObjectAdapter

getAccumulatorType() - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF

getAllDatabases() - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getAllPartitions(JobConf, String, ObjectPath, CatalogTable, HiveShim, List<Map<String, String>>) - Static method in class org.apache.flink.connectors.hive.util.HivePartitionUtils

Returns all HiveTablePartitions of a hive table, returns single HiveTablePartition if the hive table is not partitioned.

getAllTables(String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getBuiltInFunctionInfo(String) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Get a Hive built-in function by name.

getBuiltInFunctionInfo(String) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getBuiltInFunctionInfo(String) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV120

getChangelogMode(ChangelogMode) - Method in class org.apache.flink.connectors.hive.HiveTableSink

getChangelogMode() - Method in class org.apache.flink.connectors.hive.HiveTableSource

getClassName() - Method in class org.apache.flink.table.functions.hive.HiveFunctionWrapper

Get class name of the Hive function.

getComparablePartitionValueList() - Method in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

getConsumeOrder(String) - Static method in enum org.apache.flink.connectors.hive.ConsumeOrder

Get ConsumeOrder from consume order string.

getConsumeStartOffset() - Method in class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

getConversion(ObjectInspector, LogicalType, HiveShim) - Static method in class 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.

getCurrentReadOffset() - Method in class org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpoint

getCurrentState() - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

getDatabase(String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getDatabase(String) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getDatabases(String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getDataStream(StreamExecutionEnvironment) - Method in class org.apache.flink.connectors.hive.HiveTableSource

getDateDataTypeClass() - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Hive Date data type class was changed in Hive 3.1.0.

getDateDataTypeClass() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getDateDataTypeClass() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

getEnumeratorCheckpointSerializer() - Method in class org.apache.flink.connectors.hive.HiveSource

getFactory() - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getFieldNames(List<FieldSchema>) - Static method in class org.apache.flink.table.catalog.hive.HiveCatalog

Get field names from field schemas.

getFieldsFromDeserializer(Configuration, Table, boolean) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Get Hive table schema from deserializer.

getFieldsFromDeserializer(Configuration, Table, boolean) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getFieldsFromDeserializer(Configuration, Table, boolean) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV110

getFileStatusRecurse(Path, int, FileSystem) - Static method in class org.apache.flink.connectors.hive.util.HivePartitionUtils

getFunction(String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getFunction(ObjectPath) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getFunctionDefinition(String) - Method in class org.apache.flink.table.module.hive.HiveModule

getFunctionDefinitionFactory() - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getFunctions(String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getHadoopConfiguration(String) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

Returns a new Hadoop Configuration object using the path to the hadoop conf configured.

getHiveConf() - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getHiveDatabase(String) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getHiveMetastoreClient(HiveConf) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Create a Hive Metastore client based on the given HiveConf object.

getHiveMetastoreClient(HiveConf) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getHiveMetastoreClient(HiveConf) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV120

getHiveMetastoreClient(HiveConf) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV200

getHiveMetastoreClient(HiveConf) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV230

getHiveMetastoreClient(HiveConf) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

getHiveMetaStoreUtilsClass() - Method in interface 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() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getHiveMetaStoreUtilsClass() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

getHiveOutputFormatClass(Class) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

For a given OutputFormat class, get the corresponding HiveOutputFormat class.

getHiveOutputFormatClass(Class) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getHiveOutputFormatClass(Class) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV110

getHivePartition(Table, CatalogPartitionSpec) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getHiveRecordWriter(JobConf, Class, Class<? extends Writable>, boolean, Properties, Path) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Get Hive's FileSinkOperator.RecordWriter.

getHiveRecordWriter(JobConf, Class, Class<? extends Writable>, boolean, Properties, Path) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getHiveRecordWriter(JobConf, Class, Class<? extends Writable>, boolean, Properties, Path) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV110

getHiveResultType(Object[], DataType[]) - Method in interface org.apache.flink.table.functions.hive.HiveFunction

Get result type by arguments and argTypes.

getHiveResultType(Object[], DataType[]) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF

getHiveResultType(Object[], DataType[]) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDTF

getHiveTable(ObjectPath) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getHiveTablePartition() - Method in class org.apache.flink.connectors.hive.read.HiveSourceSplit

getHiveTablePartition() - Method in class org.apache.flink.connectors.hive.read.HiveTableInputSplit

getHiveVersion() - Static method in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

getHiveVersion() - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getHiveVersion() - Method in class org.apache.flink.table.module.hive.HiveModule

getInputSplitAssigner(HiveTableInputSplit[]) - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

getJobConf() - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

getJobConf() - Method in class org.apache.flink.connectors.hive.write.HiveWriterFactory

getLookupRuntimeProvider(LookupTableSource.LookupContext) - Method in class org.apache.flink.connectors.hive.HiveLookupTableSource

getMetaStoreUtilsClass() - Method in interface 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() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getMetaStoreUtilsClass() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

getModificationTime(Partition, T) - Method in class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

Get the partition modified time.

getNotNullColumns(Configuration, String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getNotNullColumns(IMetaStoreClient, Configuration, String, String) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Get the set of columns that have NOT NULL constraints.

getNotNullColumns(IMetaStoreClient, Configuration, String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getNotNullColumns(IMetaStoreClient, Configuration, String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

getNumFiles(List<HiveTablePartition>, JobConf) - Static method in class org.apache.flink.connectors.hive.HiveSourceFileEnumerator

getNumFiles() - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

getObjectInspector(DataType) - Static method in class org.apache.flink.table.functions.hive.conversion.HiveInspectors

Get Hive ObjectInspector for a Flink DataType.

getPartition(List<String>) - Method in class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

getPartition(String, String, List<String>) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getPartition(ObjectPath, CatalogPartitionSpec) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getPartitionColumnStatistics(String, String, List<String>, List<String>) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getPartitionSpec() - Method in class org.apache.flink.connectors.hive.HiveTablePartition

getPartitionStatistics(ObjectPath, CatalogPartitionSpec) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getPrimaryKey(String, String, byte) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getPrimaryKey(IMetaStoreClient, String, String, byte) - Method in interface 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) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getPrimaryKey(IMetaStoreClient, String, String, byte) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV210

getProducedTableSchema() - Method in class org.apache.flink.connectors.hive.HiveTableSource

getProducedType() - Method in class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter

getPvals(HiveShim, List<FieldSchema>, Map<String, String>) - Static method in class org.apache.flink.table.catalog.hive.util.HiveReflectionUtils

getResultType() - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF

getResultType() - Method in class org.apache.flink.table.functions.hive.HiveGenericUDTF

getScanRuntimeProvider(ScanTableSource.ScanContext) - Method in class org.apache.flink.connectors.hive.HiveTableSource

getSeenPartitionsSinceOffset() - Method in class org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpoint

getSinkRuntimeProvider(DynamicTableSink.Context) - Method in class org.apache.flink.connectors.hive.HiveTableSink

getSplitSerializer() - Method in class org.apache.flink.connectors.hive.HiveSource

getStatistics(BaseStatistics) - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

getStorageDescriptor() - Method in class org.apache.flink.connectors.hive.HiveTablePartition

getTable(String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getTable(ObjectPath) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getTableColumnStatistics(String, String, List<String>) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getTableColumnStatistics(ObjectPath) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getTableFactory() - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getTableMetadata(HiveShim, Table) - Static method in class org.apache.flink.table.catalog.hive.util.HiveReflectionUtils

getTablePath() - Method in class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

getTableProps() - Method in class org.apache.flink.connectors.hive.HiveTablePartition

getTableSchema() - Method in class org.apache.flink.connectors.hive.HiveTableSource

getTableStatistics(ObjectPath) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

getTimestampDataTypeClass() - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Hive Timestamp data type class was changed in Hive 3.1.0.

getTimestampDataTypeClass() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getTimestampDataTypeClass() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

getTypeInference(DataTypeFactory) - Method in class org.apache.flink.table.functions.hive.HiveScalarFunction

getTypeSerializer() - Method in class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

getUDFClass() - Method in class org.apache.flink.table.functions.hive.HiveFunctionWrapper

Get class of the Hive function.

getValue(GenericUDAFEvaluator.AggregationBuffer) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF

getVersion() - Method in class org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpointSerializer

getVersion() - Method in class org.apache.flink.connectors.hive.HiveSourceSplitSerializer

getViews(String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

getViews(IMetaStoreClient, String) - Method in interface 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) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

getViews(IMetaStoreClient, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV230

H

HadoopFileSystemFactory - Class in org.apache.flink.connectors.hive

Hive FileSystemFactory, hive need use job conf to create file system.

handleSourceEvent(int, SourceEvent) - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator

handleSplitRequest(int, String) - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator

hashCode() - Method in class org.apache.flink.connectors.hive.HiveTablePartition

hashCode() - Method in class org.apache.flink.connectors.hive.read.HiveTableInputSplit

HIVE_VERSION_V1_0_0 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V1_0_1 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V1_1_0 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V1_1_1 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V1_2_0 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V1_2_1 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V1_2_2 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_0_0 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_0_1 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_1_0 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_1_1 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_2_0 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_3_0 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_3_1 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_3_2 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_3_3 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_3_4 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_3_5 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V2_3_6 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V3_1_0 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V3_1_1 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HIVE_VERSION_V3_1_2 - Static variable in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

HiveBulkFormatAdapter - Class in org.apache.flink.connectors.hive.read

A BulkFormat implementation for HiveSource.

HiveBulkFormatAdapter(JobConfWrapper, List<String>, String[], DataType[], String, RowType, boolean) - Constructor for class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter

HiveBulkWriterFactory - Class in 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) - Constructor for class org.apache.flink.connectors.hive.write.HiveBulkWriterFactory

HiveCatalog - Class in org.apache.flink.table.catalog.hive

A catalog implementation for Hive.

HiveCatalog(String, String, String) - Constructor for class org.apache.flink.table.catalog.hive.HiveCatalog

HiveCatalog(String, String, String, String) - Constructor for class org.apache.flink.table.catalog.hive.HiveCatalog

HiveCatalog(String, String, String, String, String) - Constructor for class org.apache.flink.table.catalog.hive.HiveCatalog

HiveCatalog(String, String, HiveConf, String) - Constructor for class org.apache.flink.table.catalog.hive.HiveCatalog

HiveCatalog(String, String, HiveConf, String, boolean) - Constructor for class org.apache.flink.table.catalog.hive.HiveCatalog

HiveCatalogConfig - Class in org.apache.flink.table.catalog.hive

Configs for catalog meta-objects in HiveCatalog.

HiveCatalogConfig() - Constructor for class org.apache.flink.table.catalog.hive.HiveCatalogConfig

HiveCatalogDescriptor - Class in org.apache.flink.table.catalog.hive.descriptors

Catalog descriptor for HiveCatalog.

HiveCatalogDescriptor() - Constructor for class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor

HiveCatalogFactory - Class in org.apache.flink.table.catalog.hive.factories

Catalog factory for HiveCatalog.

HiveCatalogFactory() - Constructor for class org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory

HiveCatalogValidator - Class in org.apache.flink.table.catalog.hive.descriptors

Validator for HiveCatalogDescriptor.

HiveCatalogValidator() - Constructor for class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator

HiveCompactReaderFactory - Class in org.apache.flink.connectors.hive.read

The CompactReader.Factory to delegate hive bulk format.

HiveCompactReaderFactory(StorageDescriptor, Properties, JobConf, CatalogTable, String, RowType, boolean) - Constructor for class org.apache.flink.connectors.hive.read.HiveCompactReaderFactory

HiveConfUtils - Class in org.apache.flink.connectors.hive.util

Utils to create HiveConf, see FLINK-20913 for more information.

HiveConfUtils() - Constructor for class org.apache.flink.connectors.hive.util.HiveConfUtils

HiveContinuousPartitionFetcher<T extends Comparable<T>> - Class in org.apache.flink.connectors.hive.read

A ContinuousPartitionFetcher for hive table.

HiveContinuousPartitionFetcher() - Constructor for class org.apache.flink.connectors.hive.read.HiveContinuousPartitionFetcher

HiveContinuousPartitionFetcherContext(ObjectPath, HiveShim, JobConfWrapper, List<String>, DataType[], String[], Configuration, String) - Constructor for class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

HiveDatabaseUtil - Class in org.apache.flink.table.catalog.hive

Util methods for processing databases in HiveCatalog.

HiveDynamicTableFactory - Class in org.apache.flink.connectors.hive

A dynamic table factory implementation for Hive catalog.

HiveDynamicTableFactory(HiveConf) - Constructor for class org.apache.flink.connectors.hive.HiveDynamicTableFactory

HiveFunction - Interface in org.apache.flink.table.functions.hive

Interface for Hive simple udf, generic udf, and generic udtf.

HiveFunctionDefinitionFactory - Class in org.apache.flink.table.catalog.hive.factories

A factory to instantiate Hive UDFs as Flink UDFs.

HiveFunctionDefinitionFactory(HiveShim) - Constructor for class org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory

HiveFunctionUtil - Class in org.apache.flink.table.functions.hive.util

Util for Hive functions.

HiveFunctionUtil() - Constructor for class org.apache.flink.table.functions.hive.util.HiveFunctionUtil

HiveFunctionWrapper<UDFType> - Class in 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) - Constructor for class org.apache.flink.table.functions.hive.HiveFunctionWrapper

hiveFunctionWrapper - Variable in class org.apache.flink.table.functions.hive.HiveScalarFunction

HiveGenericUDAF - Class in org.apache.flink.table.functions.hive

An AggregateFunction implementation that calls Hive's UDAF or GenericUDAFEvaluator.

HiveGenericUDAF(HiveFunctionWrapper, HiveShim) - Constructor for class org.apache.flink.table.functions.hive.HiveGenericUDAF

HiveGenericUDAF(HiveFunctionWrapper, boolean, HiveShim) - Constructor for class org.apache.flink.table.functions.hive.HiveGenericUDAF

HiveGenericUDF - Class in org.apache.flink.table.functions.hive

A ScalarFunction implementation that calls Hive's GenericUDF.

HiveGenericUDF(HiveFunctionWrapper<GenericUDF>, HiveShim) - Constructor for class org.apache.flink.table.functions.hive.HiveGenericUDF

HiveGenericUDTF - Class in org.apache.flink.table.functions.hive

A TableFunction implementation that calls Hive's GenericUDTF.

HiveGenericUDTF(HiveFunctionWrapper<GenericUDTF>, HiveShim) - Constructor for class org.apache.flink.table.functions.hive.HiveGenericUDTF

HiveInputFormatPartitionReader - Class in org.apache.flink.connectors.hive.read

Partition reader that read records from InputFormat using given partitions.

HiveInputFormatPartitionReader(JobConf, String, ObjectPath, DataType[], String[], List<String>, int[], boolean) - Constructor for class org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader

HiveInspectors - Class in org.apache.flink.table.functions.hive.conversion

Util for any ObjectInspector related inspection and conversion of Hive data to/from Flink data.

HiveInspectors() - Constructor for class org.apache.flink.table.functions.hive.conversion.HiveInspectors

HiveLookupTableSource - Class in org.apache.flink.connectors.hive

Hive Table Source that has lookup ability.

HiveLookupTableSource(JobConf, ReadableConfig, ObjectPath, CatalogTable) - Constructor for class org.apache.flink.connectors.hive.HiveLookupTableSource

HiveMapredSplitReader - Class in org.apache.flink.connectors.hive.read

Hive SplitReader to read files using hadoop mapred RecordReader.

HiveMapredSplitReader(JobConf, List<String>, DataType[], int[], HiveTableInputSplit, HiveShim) - Constructor for class org.apache.flink.connectors.hive.read.HiveMapredSplitReader

HiveMetastoreClientFactory - Class in org.apache.flink.table.catalog.hive.client

Factory to create Hive metastore client.

HiveMetastoreClientWrapper - Class in 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) - Constructor for class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

HiveModule - Class in org.apache.flink.table.module.hive

Module to provide Hive built-in metadata.

HiveModule() - Constructor for class org.apache.flink.table.module.hive.HiveModule

HiveModule(String) - Constructor for class org.apache.flink.table.module.hive.HiveModule

HiveModuleDescriptor - Class in org.apache.flink.table.module.hive

Module descriptor for HiveModule.

HiveModuleDescriptor() - Constructor for class org.apache.flink.table.module.hive.HiveModuleDescriptor

HiveModuleDescriptor(String) - Constructor for class org.apache.flink.table.module.hive.HiveModuleDescriptor

HiveModuleDescriptorValidator - Class in org.apache.flink.table.module.hive

Validator for HiveModuleDescriptor.

HiveModuleDescriptorValidator() - Constructor for class org.apache.flink.table.module.hive.HiveModuleDescriptorValidator

HiveModuleFactory - Class in org.apache.flink.table.module.hive

Factory for HiveModule.

HiveModuleFactory() - Constructor for class org.apache.flink.table.module.hive.HiveModuleFactory

HiveObjectConversion - Interface in org.apache.flink.table.functions.hive.conversion

Interface to convert Flink object to Hive object.

HiveOptions - Class in org.apache.flink.connectors.hive

This class holds configuration constants used by hive connector.

HiveOptions() - Constructor for class org.apache.flink.connectors.hive.HiveOptions

HiveOutputFormatFactory - Class in org.apache.flink.connectors.hive.write

Hive OutputFormatFactory, use FileSinkOperator.RecordWriter to write record.

HiveOutputFormatFactory(HiveWriterFactory) - Constructor for class org.apache.flink.connectors.hive.write.HiveOutputFormatFactory

HivePartitionFetcherContextBase<P> - Class in org.apache.flink.connectors.hive.read

Base class for table partition fetcher context.

HivePartitionFetcherContextBase(ObjectPath, HiveShim, JobConfWrapper, List<String>, DataType[], String[], Configuration, String) - Constructor for class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

HivePartitionUtils - Class in org.apache.flink.connectors.hive.util

Utils to load hive partitions from HiveMetaStore.

HivePartitionUtils() - Constructor for class org.apache.flink.connectors.hive.util.HivePartitionUtils

hivePrimitiveToWritable(Object) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Converts a Hive primitive java object to corresponding Writable object.

hivePrimitiveToWritable(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

hivePrimitiveToWritable(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

HiveReflectionUtils - Class in org.apache.flink.table.catalog.hive.util

Utilities for accessing Hive class or methods via Java reflection.

HiveReflectionUtils() - Constructor for class org.apache.flink.table.catalog.hive.util.HiveReflectionUtils

HiveRowDataPartitionComputer - Class in 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[]) - Constructor for class org.apache.flink.connectors.hive.HiveRowDataPartitionComputer

HiveRowPartitionComputer - Class in org.apache.flink.connectors.hive

A RowPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.

HiveScalarFunction<UDFType> - Class in org.apache.flink.table.functions.hive

Abstract class to provide more information for Hive UDF and GenericUDF functions.

hiveShim - Variable in class org.apache.flink.connectors.hive.HiveTableSource

hiveShim - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

HiveShim - Interface in org.apache.flink.table.catalog.hive.client

A shim layer to support different versions of Hive.

HiveShimLoader - Class in org.apache.flink.table.catalog.hive.client

A loader to load HiveShim.

HiveShimV100 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 1.0.0.

HiveShimV100() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV100

HiveShimV101 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 1.0.1.

HiveShimV101() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV101

HiveShimV110 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 1.1.0.

HiveShimV110() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV110

HiveShimV111 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 1.1.1.

HiveShimV111() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV111

HiveShimV120 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 1.2.0.

HiveShimV120() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV120

HiveShimV121 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 1.2.1.

HiveShimV121() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV121

HiveShimV122 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 1.2.2.

HiveShimV122() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV122

HiveShimV200 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.0.0.

HiveShimV200() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV200

HiveShimV201 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.0.1.

HiveShimV201() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV201

HiveShimV210 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.1.0.

HiveShimV210() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV210

HiveShimV211 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.1.1.

HiveShimV211() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV211

HiveShimV220 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.2.0.

HiveShimV220() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV220

HiveShimV230 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.3.0.

HiveShimV230() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV230

HiveShimV231 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.3.1.

HiveShimV231() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV231

HiveShimV232 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.3.2.

HiveShimV232() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV232

HiveShimV233 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.3.3.

HiveShimV233() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV233

HiveShimV234 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.3.4.

HiveShimV234() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV234

HiveShimV235 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.3.5.

HiveShimV235() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV235

HiveShimV236 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 2.3.6.

HiveShimV236() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV236

HiveShimV310 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 3.1.0.

HiveShimV310() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV310

HiveShimV311 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 3.1.1.

HiveShimV311() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV311

HiveShimV312 - Class in org.apache.flink.table.catalog.hive.client

Shim for Hive version 3.1.2.

HiveShimV312() - Constructor for class org.apache.flink.table.catalog.hive.client.HiveShimV312

HiveSimpleUDF - Class in org.apache.flink.table.functions.hive

A ScalarFunction implementation that calls Hive's UDF.

HiveSimpleUDF(HiveFunctionWrapper<UDF>, HiveShim) - Constructor for class org.apache.flink.table.functions.hive.HiveSimpleUDF

hiveSitePath(String) - Method in class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor

HiveSource - Class in org.apache.flink.connectors.hive

A unified data source that reads a hive table.

HiveSource.HiveSourceBuilder - Class in org.apache.flink.connectors.hive

Builder to build HiveSource instances.

HiveSourceFileEnumerator - Class in org.apache.flink.connectors.hive

A FileEnumerator implementation for hive source, which generates splits based on HiveTablePartitions.

HiveSourceFileEnumerator(List<HiveTablePartition>, JobConf) - Constructor for class org.apache.flink.connectors.hive.HiveSourceFileEnumerator

HiveSourceFileEnumerator.Provider - Class in org.apache.flink.connectors.hive

A factory to create HiveSourceFileEnumerator.

HiveSourceSplit - Class in org.apache.flink.connectors.hive.read

A wrapper class that wraps info needed for a file input split.

HiveSourceSplit(FileSplit, HiveTablePartition, CheckpointedPosition) - Constructor for class org.apache.flink.connectors.hive.read.HiveSourceSplit

HiveSourceSplit(String, Path, long, long, String[], CheckpointedPosition, HiveTablePartition) - Constructor for class org.apache.flink.connectors.hive.read.HiveSourceSplit

HiveSourceSplitSerializer - Class in org.apache.flink.connectors.hive

SerDe for HiveSourceSplit.

HiveStatsUtil - Class in org.apache.flink.table.catalog.hive.util

Utils for stats of HiveCatalog.

HiveTableFactory - Class in org.apache.flink.connectors.hive

A table factory implementation for Hive catalog.

HiveTableFactory() - Constructor for class org.apache.flink.connectors.hive.HiveTableFactory

HiveTableFileInputFormat - Class in org.apache.flink.connectors.hive.read

A FileInputFormat that wraps a HiveTableInputFormat.

HiveTableFileInputFormat(HiveTableInputFormat, HiveTablePartition) - Constructor for class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

HiveTableInputFormat - Class in org.apache.flink.connectors.hive.read

The HiveTableInputFormat are inspired by the HCatInputFormat and HadoopInputFormatBase.

HiveTableInputFormat(JobConf, List<String>, DataType[], String[], int[], Long, String, boolean, List<HiveTablePartition>) - Constructor for class org.apache.flink.connectors.hive.read.HiveTableInputFormat

HiveTableInputSplit - Class in org.apache.flink.connectors.hive.read

An wrapper class that wraps info needed for a hadoop input split.

HiveTableInputSplit(int, InputSplit, JobConf, HiveTablePartition) - Constructor for class org.apache.flink.connectors.hive.read.HiveTableInputSplit

HiveTableMetaStoreFactory - Class in org.apache.flink.connectors.hive

Hive TableMetaStoreFactory, use HiveMetastoreClientWrapper to communicate with hive meta store.

HiveTablePartition - Class in org.apache.flink.connectors.hive

A class that describes a partition of a Hive table.

HiveTablePartition(StorageDescriptor, Properties) - Constructor for class org.apache.flink.connectors.hive.HiveTablePartition

HiveTablePartition(StorageDescriptor, Map<String, Object>, Properties) - Constructor for class org.apache.flink.connectors.hive.HiveTablePartition

hiveTablePartition - Variable in class org.apache.flink.connectors.hive.read.HiveSourceSplit

hiveTablePartition - Variable in class org.apache.flink.connectors.hive.read.HiveTableInputSplit

HiveTableSink - Class in org.apache.flink.connectors.hive

Table sink to write to Hive tables.

HiveTableSink(ReadableConfig, JobConf, ObjectIdentifier, CatalogTable) - Constructor for class org.apache.flink.connectors.hive.HiveTableSink

HiveTableSource - Class in org.apache.flink.connectors.hive

A TableSource implementation to read data from Hive tables.

HiveTableSource(JobConf, ReadableConfig, ObjectPath, CatalogTable) - Constructor for class org.apache.flink.connectors.hive.HiveTableSource

HiveTableSource.HiveContinuousPartitionFetcherContext<T extends Comparable<T>> - Class in org.apache.flink.connectors.hive

PartitionFetcher.Context for ContinuousPartitionFetcher.

HiveTableUtil - Class in org.apache.flink.table.catalog.hive.util

Utils to for Hive-backed table.

HiveTypeUtil - Class in org.apache.flink.table.catalog.hive.util

Utils to convert data types between Flink and Hive.

HiveTypeUtil.HivePrimitiveCategory - Enum in org.apache.flink.table.catalog.hive.util

INTERVAL are not available in older versions.

HiveVectorizedOrcSplitReader - Class in org.apache.flink.connectors.hive.read

Orc SplitReader to read files using OrcColumnarRowSplitReader.

HiveVectorizedOrcSplitReader(String, JobConf, String[], DataType[], int[], HiveTableInputSplit) - Constructor for class org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader

HiveVectorizedParquetSplitReader - Class in org.apache.flink.connectors.hive.read

Orc SplitReader to read files using ParquetColumnarRowSplitReader.

HiveVectorizedParquetSplitReader(String, JobConf, String[], DataType[], int[], HiveTableInputSplit) - Constructor for class org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader

hiveVersion - Variable in class org.apache.flink.connectors.hive.HiveTableSource

hiveVersion(String) - Method in class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor

HiveWriterFactory - Class in org.apache.flink.connectors.hive.write

Factory for creating FileSinkOperator.RecordWriter and converters for writing.

HiveWriterFactory(JobConf, Class, SerDeInfo, TableSchema, String[], Properties, HiveShim, boolean) - Constructor for class org.apache.flink.connectors.hive.write.HiveWriterFactory

I

IdentityConversion - Class in org.apache.flink.table.functions.hive.conversion

Conversion that return the same object.

inferReturnType() - Method in class org.apache.flink.table.functions.hive.HiveGenericUDF

inferReturnType() - Method in class org.apache.flink.table.functions.hive.HiveScalarFunction

Infer return type of this function call.

inferReturnType() - Method in class org.apache.flink.table.functions.hive.HiveSimpleUDF

initiateTableFromProperties(Table, Map<String, String>, HiveConf) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

Extract DDL semantics from properties and use it to initiate the table.

INSTANCE - Static variable in class org.apache.flink.connectors.hive.HiveSourceSplitSerializer

INSTANCE - Static variable in class org.apache.flink.table.functions.hive.conversion.IdentityConversion

instantiateHiveTable(ObjectPath, CatalogBaseTable, HiveConf) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

invokeMethod(Class, Object, String, Class[], Object[]) - Static method in class org.apache.flink.table.catalog.hive.util.HiveReflectionUtils

isDateStats(ColumnStatisticsData) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Whether a Hive ColumnStatisticsData is for DATE columns.

isDateStats(ColumnStatisticsData) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

isDateStats(ColumnStatisticsData) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV120

isDeterministic() - Method in class org.apache.flink.table.functions.hive.HiveScalarFunction

isEmbeddedMetastore(HiveConf) - Static method in class org.apache.flink.table.catalog.hive.HiveCatalog

isGenericForCreate(Map<String, String>) - Static method in class org.apache.flink.table.catalog.hive.HiveCatalog

isGenericForGet(Map<String, String>) - Static method in class org.apache.flink.table.catalog.hive.HiveCatalog

isSingleBoxedArray(DataType[]) - Static method in class org.apache.flink.table.functions.hive.util.HiveFunctionUtil

isSplittable() - Method in class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter

isStreamingSource() - Method in class org.apache.flink.connectors.hive.HiveTableSource

J

jobConf - Variable in class org.apache.flink.connectors.hive.HiveTableSource

JobConfWrapper - Class in org.apache.flink.connectors.hive

Wrap JobConf to a serializable class.

JobConfWrapper(JobConf) - Constructor for class org.apache.flink.connectors.hive.JobConfWrapper

K

key - Variable in class org.apache.flink.connectors.hive.read.HiveMapredSplitReader

L

listBuiltInFunctions() - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

List names of all built-in functions.

listBuiltInFunctions() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

listBuiltInFunctions() - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV120

listDatabases() - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

listFunctions(String) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

listFunctions() - Method in class org.apache.flink.table.module.hive.HiveModule

listPartitionNames(String, String, short) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

listPartitionNames(String, String, List<String>, short) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

listPartitions() - Method in class org.apache.flink.connectors.hive.HiveTableSource

listPartitions(String, String, List<String>, short) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

listPartitions(String, String, short) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

listPartitions(ObjectPath) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

listPartitions(ObjectPath, CatalogPartitionSpec) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

listPartitionsByFilter(ObjectPath, List<Expression>) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

listPartitionSpecsByFilter(String, String, String, short) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

listTables(String) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

listViews(String) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

loadHiveShim(String) - Static method in class org.apache.flink.table.catalog.hive.client.HiveShimLoader

M

makePartitionFilter(int, List<String>, List<Expression>, HiveShim) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

Generates a filter string for partition columns from the given filter expressions.

maskFlinkProperties(Map<String, String>) - Static method in class 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>) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF

metaStoreClient - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

MODULE_HIVE_VERSION - Static variable in class org.apache.flink.table.module.hive.HiveModuleDescriptorValidator

MODULE_TYPE_HIVE - Static variable in class org.apache.flink.table.module.hive.HiveModuleDescriptorValidator

N

nextRecord(RowData) - Method in class org.apache.flink.connectors.hive.read.HiveMapredSplitReader

nextRecord(RowData) - Method in class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

nextRecord(RowData) - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

nextRecord(RowData) - Method in class org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader

nextRecord(RowData) - Method in class org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader

nextRecord(RowData) - Method in interface org.apache.flink.connectors.hive.read.SplitReader

Reads the next record from the input.

O

open(List<HiveTablePartition>) - Method in class org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader

open() - Method in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

open(FileInputSplit) - Method in class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

open(HiveTableInputSplit) - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

open() - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

open(FunctionContext) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF

open(FunctionContext) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDTF

open(FunctionContext) - Method in class org.apache.flink.table.functions.hive.HiveScalarFunction

openInputFormat() - Method in class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

openInternal() - Method in class org.apache.flink.table.functions.hive.HiveGenericUDF

openInternal() - Method in class org.apache.flink.table.functions.hive.HiveScalarFunction

See UserDefinedFunction.open(FunctionContext).

openInternal() - Method in class org.apache.flink.table.functions.hive.HiveSimpleUDF

optionalOptions() - Method in class org.apache.flink.connectors.hive.HiveDynamicTableFactory

org.apache.flink.connectors.hive - package org.apache.flink.connectors.hive

org.apache.flink.connectors.hive.read - package org.apache.flink.connectors.hive.read

org.apache.flink.connectors.hive.util - package org.apache.flink.connectors.hive.util

org.apache.flink.connectors.hive.write - package org.apache.flink.connectors.hive.write

org.apache.flink.table.catalog.hive - package org.apache.flink.table.catalog.hive

org.apache.flink.table.catalog.hive.client - package org.apache.flink.table.catalog.hive.client

org.apache.flink.table.catalog.hive.descriptors - package org.apache.flink.table.catalog.hive.descriptors

org.apache.flink.table.catalog.hive.factories - package org.apache.flink.table.catalog.hive.factories

org.apache.flink.table.catalog.hive.util - package org.apache.flink.table.catalog.hive.util

org.apache.flink.table.functions.hive - package org.apache.flink.table.functions.hive

org.apache.flink.table.functions.hive.conversion - package org.apache.flink.table.functions.hive.conversion

org.apache.flink.table.functions.hive.util - package org.apache.flink.table.functions.hive.util

org.apache.flink.table.module.hive - package org.apache.flink.table.module.hive

P

parsePositiveIntStat(Map<String, String>, String) - Static method in class org.apache.flink.table.catalog.hive.util.HiveStatsUtil

parsePositiveLongStat(Map<String, String>, String) - Static method in class org.apache.flink.table.catalog.hive.util.HiveStatsUtil

PARTITION_LOCATION - Static variable in class org.apache.flink.table.catalog.hive.HiveCatalogConfig

partitionExists(ObjectPath, CatalogPartitionSpec) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

partitionKeys - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

partitionSpecToValues(Map<String, String>, List<String>) - Static method in class org.apache.flink.connectors.hive.util.HivePartitionUtils

prepare(int) - Method in class org.apache.flink.table.functions.hive.DeferredObjectAdapter

projectedFields - Variable in class org.apache.flink.connectors.hive.HiveTableSource

Provider(List<HiveTablePartition>, JobConfWrapper) - Constructor for class org.apache.flink.connectors.hive.HiveSourceFileEnumerator.Provider

R

reachedEnd() - Method in class org.apache.flink.connectors.hive.read.HiveMapredSplitReader

reachedEnd() - Method in class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

reachedEnd() - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

reachedEnd() - Method in class org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader

reachedEnd() - Method in class org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader

reachedEnd() - Method in interface org.apache.flink.connectors.hive.read.SplitReader

Method used to check if the end of the input is reached.

read(RowData) - Method in class org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader

reader - Variable in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

relyConstraint(byte) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

renamePartition(String, String, List<String>, Partition) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

renameTable(ObjectPath, String, boolean) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

reopen(HiveTableInputSplit, Long) - Method in class org.apache.flink.connectors.hive.read.HiveTableInputFormat

requiredContext() - Method in class org.apache.flink.connectors.hive.HiveTableFactory

requiredContext() - Method in class org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory

requiredContext() - Method in class org.apache.flink.table.module.hive.HiveModuleFactory

requiredOptions() - Method in class org.apache.flink.connectors.hive.HiveDynamicTableFactory

requireEnableConstraint(byte) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

requireRelyConstraint(byte) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

requiresPartitionGrouping(boolean) - Method in class org.apache.flink.connectors.hive.HiveTableSink

requireValidateConstraint(byte) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

restoreEnumerator(SplitEnumeratorContext<HiveSourceSplit>, PendingSplitsCheckpoint<HiveSourceSplit>) - Method in class org.apache.flink.connectors.hive.HiveSource

restorePartitionValueFromType(HiveShim, String, DataType) - Static method in class org.apache.flink.connectors.hive.util.HivePartitionUtils

restoreReader(Configuration, HiveSourceSplit) - Method in class org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter

returnInspector - Variable in class org.apache.flink.table.functions.hive.HiveScalarFunction

S

seekToRow(long, RowData) - Method in class org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader

seekToRow(long, RowData) - Method in class org.apache.flink.connectors.hive.read.HiveVectorizedParquetSplitReader

seekToRow(long, RowData) - Method in interface org.apache.flink.connectors.hive.read.SplitReader

Seek to a particular row number.

serialize(PendingSplitsCheckpoint<HiveSourceSplit>) - Method in class org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpointSerializer

serialize(HiveSourceSplit) - Method in class org.apache.flink.connectors.hive.HiveSourceSplitSerializer

serialVersionUID - Static variable in class org.apache.flink.table.functions.hive.HiveFunctionWrapper

set(Object) - Method in class org.apache.flink.table.functions.hive.DeferredObjectAdapter

setArgumentTypesAndConstants(Object[], DataType[]) - Method in interface org.apache.flink.table.functions.hive.HiveFunction

Set arguments and argTypes for Function instance.

setArgumentTypesAndConstants(Object[], DataType[]) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDAF

setArgumentTypesAndConstants(Object[], DataType[]) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDTF

setCollector(Collector) - Method in class org.apache.flink.table.functions.hive.HiveGenericUDTF

setDefaultStorageFormat(StorageDescriptor, HiveConf) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

setFetcher(ContinuousPartitionFetcher<Partition, ?>) - Method in class org.apache.flink.connectors.hive.HiveSource.HiveSourceBuilder

setFetcherContext(HiveTableSource.HiveContinuousPartitionFetcherContext<?>) - Method in class org.apache.flink.connectors.hive.HiveSource.HiveSourceBuilder

setRuntimeContext(RuntimeContext) - Method in class org.apache.flink.connectors.hive.read.HiveTableFileInputFormat

setStorageFormat(StorageDescriptor, String, HiveConf) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

snapshotState() - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator

SplitReader - Interface in org.apache.flink.connectors.hive.read

Split reader to read record from files.

start() - Method in class org.apache.flink.connectors.hive.ContinuousHiveSplitEnumerator

supportedProperties() - Method in class org.apache.flink.connectors.hive.HiveTableFactory

supportedProperties() - Method in class org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory

supportedProperties() - Method in class org.apache.flink.table.module.hive.HiveModuleFactory

supportsNestedProjection() - Method in class org.apache.flink.connectors.hive.HiveTableSource

T

TABLE_EXEC_HIVE_FALLBACK_MAPRED_READER - Static variable in class org.apache.flink.connectors.hive.HiveOptions

TABLE_EXEC_HIVE_FALLBACK_MAPRED_WRITER - Static variable in class org.apache.flink.connectors.hive.HiveOptions

TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM - Static variable in class org.apache.flink.connectors.hive.HiveOptions

TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM_MAX - Static variable in class org.apache.flink.connectors.hive.HiveOptions

tableExists(String, String) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

tableExists(ObjectPath) - Method in class org.apache.flink.table.catalog.hive.HiveCatalog

tableLocation - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

tablePath - Variable in class org.apache.flink.connectors.hive.HiveTableSource

tablePath - Variable in class org.apache.flink.connectors.hive.read.HiveInputFormatPartitionReader

tablePath - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

tableProps - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

tableSd - Variable in class org.apache.flink.connectors.hive.read.HivePartitionFetcherContextBase

toCatalogProperties() - Method in class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogDescriptor

toFlinkDate(Object) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Converts a hive date instance to LocalDate which is expected by DataFormatConverter.

toFlinkDate(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

toFlinkDate(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

toFlinkDateColStats(ColumnStatisticsData) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Generate Flink CatalogColumnStatisticsDataDate from Hive ColumnStatisticsData for DATE columns.

toFlinkDateColStats(ColumnStatisticsData) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

toFlinkDateColStats(ColumnStatisticsData) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV120

toFlinkObject(ObjectInspector, Object, HiveShim) - Static method in class org.apache.flink.table.functions.hive.conversion.HiveInspectors

Converts a Hive object to Flink object with an ObjectInspector.

toFlinkTimestamp(Object) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Converts a hive timestamp instance to LocalDateTime which is expected by DataFormatConverter.

toFlinkTimestamp(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

toFlinkTimestamp(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

toFlinkType(ObjectInspector) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTypeUtil

Convert a Hive ObjectInspector to a Flink data type.

toFlinkType(TypeInfo) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTypeUtil

Convert Hive data type to a Flink data type.

toHiveDate(Object) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Converts a Flink date instance to what's expected by Hive.

toHiveDate(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

toHiveDate(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

toHiveDateColStats(CatalogColumnStatisticsDataDate) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Generate Hive ColumnStatisticsData from Flink CatalogColumnStatisticsDataDate for DATE columns.

toHiveDateColStats(CatalogColumnStatisticsDataDate) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

toHiveDateColStats(CatalogColumnStatisticsDataDate) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV120

toHiveObject(Object) - Method in interface org.apache.flink.table.functions.hive.conversion.HiveObjectConversion

toHiveObject(Object) - Method in class org.apache.flink.table.functions.hive.conversion.IdentityConversion

toHiveObject(Object) - Method in class org.apache.flink.table.functions.hive.conversion.WritableHiveObjectConversion

toHiveTablePartition(Partition) - Method in class org.apache.flink.connectors.hive.HiveTableSource.HiveContinuousPartitionFetcherContext

Convert partition to HiveTablePartition.

toHiveTablePartition(List<String>, String[], DataType[], HiveShim, Properties, String, Partition) - Static method in class org.apache.flink.connectors.hive.util.HivePartitionUtils

toHiveTimestamp(Object) - Method in interface org.apache.flink.table.catalog.hive.client.HiveShim

Converts a Flink timestamp instance to what's expected by Hive.

toHiveTimestamp(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV100

toHiveTimestamp(Object) - Method in class org.apache.flink.table.catalog.hive.client.HiveShimV310

toHiveTypeInfo(DataType, boolean) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTypeUtil

Convert Flink DataType to Hive TypeInfo.

toInspectors(HiveShim, Object[], DataType[]) - Static method in class org.apache.flink.table.functions.hive.conversion.HiveInspectors

Get an array of ObjectInspector from the give array of args and their types.

toMapRedSplit() - Method in class org.apache.flink.connectors.hive.read.HiveSourceSplit

toModuleProperties() - Method in class org.apache.flink.table.module.hive.HiveModuleDescriptor

toString() - Method in enum org.apache.flink.connectors.hive.ConsumeOrder

toString() - Method in class org.apache.flink.connectors.hive.HiveTablePartition

toString() - Method in class org.apache.flink.connectors.hive.read.HiveSourceSplit

toString() - Method in class org.apache.flink.connectors.hive.read.HiveTableInputSplit

U

updatePartitionColumnStatistics(ColumnStatistics) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

updateTableColumnStatistics(ColumnStatistics) - Method in class org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

updateWithCheckpointedPosition(CheckpointedPosition) - Method in class org.apache.flink.connectors.hive.read.HiveSourceSplit

V

validate(DescriptorProperties) - Method in class org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator

validate(DescriptorProperties) - Method in class org.apache.flink.table.module.hive.HiveModuleDescriptorValidator

validateConstraint(byte) - Static method in class org.apache.flink.table.catalog.hive.util.HiveTableUtil

value - Variable in class org.apache.flink.connectors.hive.read.HiveMapredSplitReader

valueOf(String) - Static method in enum org.apache.flink.connectors.hive.ConsumeOrder

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.table.catalog.hive.util.HiveTypeUtil.HivePrimitiveCategory

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.connectors.hive.ConsumeOrder

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.table.catalog.hive.util.HiveTypeUtil.HivePrimitiveCategory

Returns an array containing the constants of this enum type, in the order they are declared.

W

WritableHiveObjectConversion - Class in org.apache.flink.table.functions.hive.conversion

A HiveObjectConversion that converts Flink objects to Hive Writable objects.

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