Uses of Class
org.apache.flink.connectors.hive.HiveTablePartition

Packages that use HiveTablePartition

Package	Description
org.apache.flink.connectors.hive
org.apache.flink.connectors.hive.read
org.apache.flink.connectors.hive.util

Uses of HiveTablePartition in org.apache.flink.connectors.hive

Methods in org.apache.flink.connectors.hive that return HiveTablePartition

Modifier and Type	Method and Description
HiveTablePartition	HiveTableSource.HiveContinuousPartitionFetcherContext.toHiveTablePartition(org.apache.hadoop.hive.metastore.api.Partition partition) Convert partition to HiveTablePartition.

Method parameters in org.apache.flink.connectors.hive with type arguments of type HiveTablePartition

Modifier and Type	Method and Description
static List<HiveSourceSplit>	HiveSourceFileEnumerator.createInputSplits(int minNumSplits, List<HiveTablePartition> partitions, org.apache.hadoop.mapred.JobConf jobConf)
static int	HiveSourceFileEnumerator.getNumFiles(List<HiveTablePartition> partitions, org.apache.hadoop.mapred.JobConf jobConf)

Constructor parameters in org.apache.flink.connectors.hive with type arguments of type HiveTablePartition

Constructor and Description
HiveSourceFileEnumerator(List<HiveTablePartition> partitions, org.apache.hadoop.mapred.JobConf jobConf)
Provider(List<HiveTablePartition> partitions, JobConfWrapper jobConfWrapper)

Uses of HiveTablePartition in org.apache.flink.connectors.hive.read

Fields in org.apache.flink.connectors.hive.read declared as HiveTablePartition

Modifier and Type	Field and Description
protected HiveTablePartition	HiveTableInputSplit.hiveTablePartition
protected HiveTablePartition	HiveSourceSplit.hiveTablePartition

Methods in org.apache.flink.connectors.hive.read that return HiveTablePartition

Modifier and Type	Method and Description
HiveTablePartition	HiveTableInputSplit.getHiveTablePartition()
HiveTablePartition	HiveSourceSplit.getHiveTablePartition()

Method parameters in org.apache.flink.connectors.hive.read with type arguments of type HiveTablePartition

Modifier and Type	Method and Description
static HiveTableInputSplit[]	HiveTableInputFormat.createInputSplits(int minNumSplits, List<HiveTablePartition> partitions, org.apache.hadoop.mapred.JobConf jobConf)
void	HiveInputFormatPartitionReader.open(List<HiveTablePartition> partitions)

Constructors in org.apache.flink.connectors.hive.read with parameters of type HiveTablePartition

Constructor and Description
HiveSourceSplit(org.apache.hadoop.mapred.FileSplit fileSplit, HiveTablePartition hiveTablePartition, org.apache.flink.connector.file.src.util.CheckpointedPosition readerPosition)
HiveSourceSplit(String id, org.apache.flink.core.fs.Path filePath, long offset, long length, String[] hostnames, org.apache.flink.connector.file.src.util.CheckpointedPosition readerPosition, HiveTablePartition hiveTablePartition)
HiveTableFileInputFormat(HiveTableInputFormat inputFormat, HiveTablePartition hiveTablePartition)
HiveTableInputSplit(int splitNumber, org.apache.hadoop.mapred.InputSplit hInputSplit, org.apache.hadoop.mapred.JobConf jobconf, HiveTablePartition hiveTablePartition)

Constructor parameters in org.apache.flink.connectors.hive.read with type arguments of type HiveTablePartition

Constructor and Description
HiveTableInputFormat(org.apache.hadoop.mapred.JobConf jobConf, List<String> partitionKeys, org.apache.flink.table.types.DataType[] fieldTypes, String[] fieldNames, int[] projectedFields, Long limit, String hiveVersion, boolean useMapRedReader, List<HiveTablePartition> partitions)

Uses of HiveTablePartition in org.apache.flink.connectors.hive.util

Methods in org.apache.flink.connectors.hive.util that return HiveTablePartition

Modifier and Type	Method and Description
static HiveTablePartition	HivePartitionUtils.toHiveTablePartition(List<String> partitionKeys, String[] fieldNames, org.apache.flink.table.types.DataType[] fieldTypes, HiveShim shim, Properties tableProps, String defaultPartitionName, org.apache.hadoop.hive.metastore.api.Partition partition)

Methods in org.apache.flink.connectors.hive.util that return types with arguments of type HiveTablePartition

Modifier and Type	Method and Description
static List<HiveTablePartition>	HivePartitionUtils.getAllPartitions(org.apache.hadoop.mapred.JobConf jobConf, String hiveVersion, org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogTable catalogTable, HiveShim hiveShim, List<Map<String,String>> remainingPartitions) Returns all HiveTablePartitions of a hive table, returns single HiveTablePartition if the hive table is not partitioned.