Modifier and Type | Method and Description |
---|---|
Partition |
HiveMetaStore.HMSHandler.add_partition_with_environment_context(Partition part,
EnvironmentContext envContext) |
Partition |
IMetaStoreClient.add_partition(Partition partition)
Add a partition to the table.
|
Partition |
HiveMetaStoreClient.add_partition(Partition new_part) |
Partition |
HiveMetaStore.HMSHandler.add_partition(Partition part) |
Partition |
HiveMetaStoreClient.add_partition(Partition new_part,
EnvironmentContext envContext) |
Partition |
HiveAlterHandler.alterPartition(RawStore msdb,
Warehouse wh,
String dbname,
String name,
List<String> part_vals,
Partition new_part) |
Partition |
AlterHandler.alterPartition(RawStore msdb,
Warehouse wh,
String dbname,
String name,
List<String> part_vals,
Partition new_part)
handles alter partition
|
Partition |
HiveMetaStore.HMSHandler.append_partition_by_name_with_environment_context(String db_name,
String tbl_name,
String part_name,
EnvironmentContext env_context) |
Partition |
HiveMetaStore.HMSHandler.append_partition_by_name(String db_name,
String tbl_name,
String part_name) |
Partition |
HiveMetaStore.HMSHandler.append_partition_with_environment_context(String dbName,
String tableName,
List<String> part_vals,
EnvironmentContext envContext) |
Partition |
HiveMetaStore.HMSHandler.append_partition(String dbName,
String tableName,
List<String> part_vals) |
Partition |
IMetaStoreClient.appendPartition(String tableName,
String dbName,
List<String> partVals) |
Partition |
HiveMetaStoreClient.appendPartition(String db_name,
String table_name,
List<String> part_vals) |
Partition |
HiveMetaStoreClient.appendPartition(String db_name,
String table_name,
List<String> part_vals,
EnvironmentContext envContext) |
Partition |
IMetaStoreClient.appendPartition(String tableName,
String dbName,
String name) |
Partition |
HiveMetaStoreClient.appendPartition(String dbName,
String tableName,
String partName) |
Partition |
HiveMetaStoreClient.appendPartition(String dbName,
String tableName,
String partName,
EnvironmentContext envContext) |
Partition |
HiveMetaStoreClient.appendPartitionByName(String dbName,
String tableName,
String partName) |
Partition |
HiveMetaStoreClient.appendPartitionByName(String dbName,
String tableName,
String partName,
EnvironmentContext envContext) |
Partition |
IMetaStoreClient.exchange_partition(Map<String,String> partitionSpecs,
String sourceDb,
String sourceTable,
String destdb,
String destTableName) |
Partition |
HiveMetaStoreClient.exchange_partition(Map<String,String> partitionSpecs,
String sourceDb,
String sourceTable,
String destDb,
String destinationTableName)
Exchange the partition between two tables
|
Partition |
HiveMetaStore.HMSHandler.exchange_partition(Map<String,String> partitionSpecs,
String sourceDbName,
String sourceTableName,
String destDbName,
String destTableName) |
Partition |
MetaStoreFilterHook.filterPartition(Partition partition)
filter to given partition object if applicable
|
Partition |
DefaultMetaStoreFilterHookImpl.filterPartition(Partition partition) |
Partition |
HiveMetaStore.HMSHandler.get_partition_by_name(String db_name,
String tbl_name,
String part_name) |
Partition |
HiveMetaStore.HMSHandler.get_partition_with_auth(String db_name,
String tbl_name,
List<String> part_vals,
String user_name,
List<String> group_names) |
Partition |
HiveMetaStore.HMSHandler.get_partition(String db_name,
String tbl_name,
List<String> part_vals) |
Partition |
RawStore.getPartition(String dbName,
String tableName,
List<String> part_vals) |
Partition |
ObjectStore.getPartition(String dbName,
String tableName,
List<String> part_vals) |
Partition |
IMetaStoreClient.getPartition(String tblName,
String dbName,
List<String> partVals) |
Partition |
HiveMetaStoreClient.getPartition(String db_name,
String tbl_name,
List<String> part_vals) |
Partition |
IMetaStoreClient.getPartition(String dbName,
String tblName,
String name) |
Partition |
HiveMetaStoreClient.getPartition(String db,
String tableName,
String partName) |
Partition |
RawStore.getPartitionWithAuth(String dbName,
String tblName,
List<String> partVals,
String user_name,
List<String> group_names) |
Partition |
ObjectStore.getPartitionWithAuth(String dbName,
String tblName,
List<String> partVals,
String user_name,
List<String> group_names) |
Partition |
IMetaStoreClient.getPartitionWithAuthInfo(String dbName,
String tableName,
List<String> pvals,
String userName,
List<String> groupNames) |
Partition |
HiveMetaStoreClient.getPartitionWithAuthInfo(String db_name,
String tbl_name,
List<String> part_vals,
String user_name,
List<String> group_names) |
Modifier and Type | Method and Description |
---|---|
List<Partition> |
IMetaStoreClient.add_partitions(List<Partition> partitions,
boolean ifNotExists,
boolean needResults)
Add partitions to the table.
|
List<Partition> |
HiveMetaStoreClient.add_partitions(List<Partition> parts,
boolean ifNotExists,
boolean needResults) |
List<Partition> |
HiveAlterHandler.alterPartitions(RawStore msdb,
Warehouse wh,
String dbname,
String name,
List<Partition> new_parts) |
List<Partition> |
AlterHandler.alterPartitions(RawStore msdb,
Warehouse wh,
String dbname,
String name,
List<Partition> new_part)
handles alter partitions
|
List<Partition> |
IMetaStoreClient.dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
boolean deleteData,
boolean ignoreProtection,
boolean ifExists) |
List<Partition> |
HiveMetaStoreClient.dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
boolean deleteData,
boolean ignoreProtection,
boolean ifExists) |
List<Partition> |
IMetaStoreClient.dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
boolean deleteData,
boolean ignoreProtection,
boolean ifExists,
boolean needResults) |
List<Partition> |
HiveMetaStoreClient.dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
boolean deleteData,
boolean ignoreProtection,
boolean ifExists,
boolean needResult) |
List<Partition> |
IMetaStoreClient.dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
PartitionDropOptions options)
Generalization of dropPartitions(),
|
List<Partition> |
HiveMetaStoreClient.dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
PartitionDropOptions options) |
List<Partition> |
MetaStoreFilterHook.filterPartitions(List<Partition> partitionList)
Filter given list of partitions
|
List<Partition> |
DefaultMetaStoreFilterHookImpl.filterPartitions(List<Partition> partitionList) |
List<Partition> |
HiveMetaStore.HMSHandler.get_partitions_by_filter(String dbName,
String tblName,
String filter,
short maxParts) |
List<Partition> |
HiveMetaStore.HMSHandler.get_partitions_by_names(String dbName,
String tblName,
List<String> partNames) |
List<Partition> |
HiveMetaStore.HMSHandler.get_partitions_ps_with_auth(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts,
String userName,
List<String> groupNames) |
List<Partition> |
HiveMetaStore.HMSHandler.get_partitions_ps(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts) |
List<Partition> |
HiveMetaStore.HMSHandler.get_partitions_with_auth(String dbName,
String tblName,
short maxParts,
String userName,
List<String> groupNames) |
List<Partition> |
HiveMetaStore.HMSHandler.get_partitions(String db_name,
String tbl_name,
short max_parts) |
List<Partition> |
RawStore.getPartitions(String dbName,
String tableName,
int max) |
List<Partition> |
ObjectStore.getPartitions(String dbName,
String tableName,
int maxParts) |
List<Partition> |
RawStore.getPartitionsByFilter(String dbName,
String tblName,
String filter,
short maxParts) |
List<Partition> |
ObjectStore.getPartitionsByFilter(String dbName,
String tblName,
String filter,
short maxParts) |
protected List<Partition> |
ObjectStore.getPartitionsByFilterInternal(String dbName,
String tblName,
String filter,
short maxParts,
boolean allowSql,
boolean allowJdo) |
List<Partition> |
RawStore.getPartitionsByNames(String dbName,
String tblName,
List<String> partNames) |
List<Partition> |
ObjectStore.getPartitionsByNames(String dbName,
String tblName,
List<String> partNames) |
List<Partition> |
IMetaStoreClient.getPartitionsByNames(String db_name,
String tbl_name,
List<String> part_names)
Get partitions by a list of partition names.
|
List<Partition> |
HiveMetaStoreClient.getPartitionsByNames(String db_name,
String tbl_name,
List<String> part_names) |
protected List<Partition> |
ObjectStore.getPartitionsByNamesInternal(String dbName,
String tblName,
List<String> partNames,
boolean allowSql,
boolean allowJdo) |
protected List<Partition> |
ObjectStore.getPartitionsInternal(String dbName,
String tblName,
int maxParts,
boolean allowSql,
boolean allowJdo) |
List<Partition> |
RawStore.getPartitionsWithAuth(String dbName,
String tblName,
short maxParts,
String userName,
List<String> groupNames) |
List<Partition> |
ObjectStore.getPartitionsWithAuth(String dbName,
String tblName,
short max,
String userName,
List<String> groupNames) |
List<Partition> |
IMetaStoreClient.listPartitions(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts) |
List<Partition> |
HiveMetaStoreClient.listPartitions(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts) |
List<Partition> |
IMetaStoreClient.listPartitions(String db_name,
String tbl_name,
short max_parts) |
List<Partition> |
HiveMetaStoreClient.listPartitions(String db_name,
String tbl_name,
short max_parts) |
List<Partition> |
IMetaStoreClient.listPartitionsByFilter(String db_name,
String tbl_name,
String filter,
short max_parts)
Get list of partitions matching specified filter
|
List<Partition> |
HiveMetaStoreClient.listPartitionsByFilter(String db_name,
String tbl_name,
String filter,
short max_parts)
Get list of partitions matching specified filter
|
List<Partition> |
RawStore.listPartitionsPsWithAuth(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts,
String userName,
List<String> groupNames)
Lists partitions that match a given partial specification and sets their auth privileges.
|
List<Partition> |
ObjectStore.listPartitionsPsWithAuth(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts,
String userName,
List<String> groupNames) |
List<Partition> |
IMetaStoreClient.listPartitionsWithAuthInfo(String dbName,
String tableName,
List<String> partialPvals,
short s,
String userName,
List<String> groupNames) |
List<Partition> |
HiveMetaStoreClient.listPartitionsWithAuthInfo(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts,
String user_name,
List<String> group_names) |
List<Partition> |
IMetaStoreClient.listPartitionsWithAuthInfo(String dbName,
String tableName,
short s,
String userName,
List<String> groupNames) |
List<Partition> |
HiveMetaStoreClient.listPartitionsWithAuthInfo(String db_name,
String tbl_name,
short max_parts,
String user_name,
List<String> group_names) |
Modifier and Type | Method and Description |
---|---|
Partition |
HiveMetaStore.HMSHandler.add_partition_with_environment_context(Partition part,
EnvironmentContext envContext) |
Partition |
IMetaStoreClient.add_partition(Partition partition)
Add a partition to the table.
|
Partition |
HiveMetaStoreClient.add_partition(Partition new_part) |
Partition |
HiveMetaStore.HMSHandler.add_partition(Partition part) |
Partition |
HiveMetaStoreClient.add_partition(Partition new_part,
EnvironmentContext envContext) |
boolean |
RawStore.addPartition(Partition part) |
boolean |
ObjectStore.addPartition(Partition part) |
void |
HiveMetaStore.HMSHandler.alter_partition_with_environment_context(String dbName,
String tableName,
Partition newPartition,
EnvironmentContext envContext) |
void |
IMetaStoreClient.alter_partition(String dbName,
String tblName,
Partition newPart)
updates a partition to new partition
|
void |
HiveMetaStoreClient.alter_partition(String dbName,
String tblName,
Partition newPart) |
void |
HiveMetaStore.HMSHandler.alter_partition(String db_name,
String tbl_name,
Partition new_part) |
Partition |
HiveAlterHandler.alterPartition(RawStore msdb,
Warehouse wh,
String dbname,
String name,
List<String> part_vals,
Partition new_part) |
Partition |
AlterHandler.alterPartition(RawStore msdb,
Warehouse wh,
String dbname,
String name,
List<String> part_vals,
Partition new_part)
handles alter partition
|
void |
RawStore.alterPartition(String db_name,
String tbl_name,
List<String> part_vals,
Partition new_part) |
void |
ObjectStore.alterPartition(String dbname,
String name,
List<String> part_vals,
Partition newPart) |
static boolean |
MetaStoreUtils.canDropPartition(Table table,
Partition partition) |
Partition |
MetaStoreFilterHook.filterPartition(Partition partition)
filter to given partition object if applicable
|
Partition |
DefaultMetaStoreFilterHookImpl.filterPartition(Partition partition) |
static int |
MetaStoreUtils.getArchivingLevel(Partition part) |
static Deserializer |
MetaStoreUtils.getDeserializer(org.apache.hadoop.conf.Configuration conf,
Partition part,
Table table)
getDeserializer
Get the Deserializer for a partition.
|
static org.apache.hadoop.fs.Path |
MetaStoreUtils.getOriginalLocation(Partition part) |
static Properties |
MetaStoreUtils.getPartitionMetadata(Partition partition,
Table table) |
static ProtectMode |
MetaStoreUtils.getProtectMode(Partition partition) |
static String |
Warehouse.getQualifiedName(Partition partition) |
static Properties |
MetaStoreUtils.getSchema(Partition part,
Table table) |
static boolean |
MetaStoreUtils.isArchived(Partition part) |
void |
HiveMetaStore.HMSHandler.rename_partition(String db_name,
String tbl_name,
List<String> part_vals,
Partition new_part) |
void |
IMetaStoreClient.renamePartition(String dbname,
String name,
List<String> part_vals,
Partition newPart)
rename a partition to a new partition
|
void |
HiveMetaStoreClient.renamePartition(String dbname,
String name,
List<String> part_vals,
Partition newPart) |
static boolean |
MetaStoreUtils.requireCalStats(org.apache.hadoop.conf.Configuration hiveConf,
Partition oldPart,
Partition newPart,
Table tbl) |
static boolean |
MetaStoreUtils.updatePartitionStatsFast(Partition part,
Warehouse wh) |
static boolean |
MetaStoreUtils.updatePartitionStatsFast(Partition part,
Warehouse wh,
boolean madeDir) |
static boolean |
MetaStoreUtils.updatePartitionStatsFast(Partition part,
Warehouse wh,
boolean madeDir,
boolean forceRecompute)
Updates the numFiles and totalSize parameters for the passed Partition by querying
the warehouse if the passed Partition does not already have values for these parameters.
|
Modifier and Type | Method and Description |
---|---|
int |
IMetaStoreClient.add_partitions(List<Partition> partitions)
Add partitions to the table.
|
int |
HiveMetaStoreClient.add_partitions(List<Partition> new_parts) |
int |
HiveMetaStore.HMSHandler.add_partitions(List<Partition> parts) |
List<Partition> |
IMetaStoreClient.add_partitions(List<Partition> partitions,
boolean ifNotExists,
boolean needResults)
Add partitions to the table.
|
List<Partition> |
HiveMetaStoreClient.add_partitions(List<Partition> parts,
boolean ifNotExists,
boolean needResults) |
boolean |
RawStore.addPartitions(String dbName,
String tblName,
List<Partition> parts) |
boolean |
ObjectStore.addPartitions(String dbName,
String tblName,
List<Partition> parts) |
void |
IMetaStoreClient.alter_partitions(String dbName,
String tblName,
List<Partition> newParts)
updates a list of partitions
|
void |
HiveMetaStoreClient.alter_partitions(String dbName,
String tblName,
List<Partition> newParts) |
void |
HiveMetaStore.HMSHandler.alter_partitions(String db_name,
String tbl_name,
List<Partition> new_parts) |
List<Partition> |
HiveAlterHandler.alterPartitions(RawStore msdb,
Warehouse wh,
String dbname,
String name,
List<Partition> new_parts) |
List<Partition> |
AlterHandler.alterPartitions(RawStore msdb,
Warehouse wh,
String dbname,
String name,
List<Partition> new_part)
handles alter partitions
|
void |
RawStore.alterPartitions(String db_name,
String tbl_name,
List<List<String>> part_vals_list,
List<Partition> new_parts) |
void |
ObjectStore.alterPartitions(String dbname,
String name,
List<List<String>> part_vals,
List<Partition> newParts) |
List<Partition> |
MetaStoreFilterHook.filterPartitions(List<Partition> partitionList)
Filter given list of partitions
|
List<Partition> |
DefaultMetaStoreFilterHookImpl.filterPartitions(List<Partition> partitionList) |
boolean |
RawStore.getPartitionsByExpr(String dbName,
String tblName,
byte[] expr,
String defaultPartitionName,
short maxParts,
List<Partition> result) |
boolean |
ObjectStore.getPartitionsByExpr(String dbName,
String tblName,
byte[] expr,
String defaultPartitionName,
short maxParts,
List<Partition> result) |
protected boolean |
ObjectStore.getPartitionsByExprInternal(String dbName,
String tblName,
byte[] expr,
String defaultPartitionName,
short maxParts,
List<Partition> result,
boolean allowSql,
boolean allowJdo) |
boolean |
IMetaStoreClient.listPartitionsByExpr(String db_name,
String tbl_name,
byte[] expr,
String default_partition_name,
short max_parts,
List<Partition> result)
Get list of partitions matching specified serialized expression
|
boolean |
HiveMetaStoreClient.listPartitionsByExpr(String db_name,
String tbl_name,
byte[] expr,
String default_partition_name,
short max_parts,
List<Partition> result) |
Modifier and Type | Method and Description |
---|---|
Partition |
ThriftHiveMetastore.Iface.add_partition_with_environment_context(Partition new_part,
EnvironmentContext environment_context) |
Partition |
ThriftHiveMetastore.Client.add_partition_with_environment_context(Partition new_part,
EnvironmentContext environment_context) |
Partition |
ThriftHiveMetastore.Iface.add_partition(Partition new_part) |
Partition |
ThriftHiveMetastore.Client.add_partition(Partition new_part) |
Partition |
ThriftHiveMetastore.Iface.append_partition_by_name_with_environment_context(String db_name,
String tbl_name,
String part_name,
EnvironmentContext environment_context) |
Partition |
ThriftHiveMetastore.Client.append_partition_by_name_with_environment_context(String db_name,
String tbl_name,
String part_name,
EnvironmentContext environment_context) |
Partition |
ThriftHiveMetastore.Iface.append_partition_by_name(String db_name,
String tbl_name,
String part_name) |
Partition |
ThriftHiveMetastore.Client.append_partition_by_name(String db_name,
String tbl_name,
String part_name) |
Partition |
ThriftHiveMetastore.Iface.append_partition_with_environment_context(String db_name,
String tbl_name,
List<String> part_vals,
EnvironmentContext environment_context) |
Partition |
ThriftHiveMetastore.Client.append_partition_with_environment_context(String db_name,
String tbl_name,
List<String> part_vals,
EnvironmentContext environment_context) |
Partition |
ThriftHiveMetastore.Iface.append_partition(String db_name,
String tbl_name,
List<String> part_vals) |
Partition |
ThriftHiveMetastore.Client.append_partition(String db_name,
String tbl_name,
List<String> part_vals) |
Partition |
Partition.deepCopy() |
Partition |
ThriftHiveMetastore.Iface.exchange_partition(Map<String,String> partitionSpecs,
String source_db,
String source_table_name,
String dest_db,
String dest_table_name) |
Partition |
ThriftHiveMetastore.Client.exchange_partition(Map<String,String> partitionSpecs,
String source_db,
String source_table_name,
String dest_db,
String dest_table_name) |
Partition |
ThriftHiveMetastore.Iface.get_partition_by_name(String db_name,
String tbl_name,
String part_name) |
Partition |
ThriftHiveMetastore.Client.get_partition_by_name(String db_name,
String tbl_name,
String part_name) |
Partition |
ThriftHiveMetastore.Iface.get_partition_with_auth(String db_name,
String tbl_name,
List<String> part_vals,
String user_name,
List<String> group_names) |
Partition |
ThriftHiveMetastore.Client.get_partition_with_auth(String db_name,
String tbl_name,
List<String> part_vals,
String user_name,
List<String> group_names) |
Partition |
ThriftHiveMetastore.Iface.get_partition(String db_name,
String tbl_name,
List<String> part_vals) |
Partition |
ThriftHiveMetastore.Client.get_partition(String db_name,
String tbl_name,
List<String> part_vals) |
Partition |
ThriftHiveMetastore.add_partition_args.getNew_part() |
Partition |
ThriftHiveMetastore.add_partition_with_environment_context_args.getNew_part() |
Partition |
ThriftHiveMetastore.alter_partition_args.getNew_part() |
Partition |
ThriftHiveMetastore.alter_partition_with_environment_context_args.getNew_part() |
Partition |
ThriftHiveMetastore.rename_partition_args.getNew_part() |
Partition |
ThriftHiveMetastore.AsyncClient.add_partition_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.add_partition_with_environment_context_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.append_partition_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.append_partition_with_environment_context_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.append_partition_by_name_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.append_partition_by_name_with_environment_context_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.get_partition_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.exchange_partition_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.get_partition_with_auth_call.getResult() |
Partition |
ThriftHiveMetastore.AsyncClient.get_partition_by_name_call.getResult() |
Partition |
ThriftHiveMetastore.add_partition_result.getSuccess() |
Partition |
ThriftHiveMetastore.add_partition_with_environment_context_result.getSuccess() |
Partition |
ThriftHiveMetastore.append_partition_result.getSuccess() |
Partition |
ThriftHiveMetastore.append_partition_with_environment_context_result.getSuccess() |
Partition |
ThriftHiveMetastore.append_partition_by_name_result.getSuccess() |
Partition |
ThriftHiveMetastore.append_partition_by_name_with_environment_context_result.getSuccess() |
Partition |
ThriftHiveMetastore.get_partition_result.getSuccess() |
Partition |
ThriftHiveMetastore.exchange_partition_result.getSuccess() |
Partition |
ThriftHiveMetastore.get_partition_with_auth_result.getSuccess() |
Partition |
ThriftHiveMetastore.get_partition_by_name_result.getSuccess() |
Partition |
ThriftHiveMetastore.Client.recv_add_partition_with_environment_context() |
Partition |
ThriftHiveMetastore.Client.recv_add_partition() |
Partition |
ThriftHiveMetastore.Client.recv_append_partition_by_name_with_environment_context() |
Partition |
ThriftHiveMetastore.Client.recv_append_partition_by_name() |
Partition |
ThriftHiveMetastore.Client.recv_append_partition_with_environment_context() |
Partition |
ThriftHiveMetastore.Client.recv_append_partition() |
Partition |
ThriftHiveMetastore.Client.recv_exchange_partition() |
Partition |
ThriftHiveMetastore.Client.recv_get_partition_by_name() |
Partition |
ThriftHiveMetastore.Client.recv_get_partition_with_auth() |
Partition |
ThriftHiveMetastore.Client.recv_get_partition() |
Modifier and Type | Method and Description |
---|---|
List<Partition> |
ThriftHiveMetastore.Iface.get_partitions_by_filter(String db_name,
String tbl_name,
String filter,
short max_parts) |
List<Partition> |
ThriftHiveMetastore.Client.get_partitions_by_filter(String db_name,
String tbl_name,
String filter,
short max_parts) |
List<Partition> |
ThriftHiveMetastore.Iface.get_partitions_by_names(String db_name,
String tbl_name,
List<String> names) |
List<Partition> |
ThriftHiveMetastore.Client.get_partitions_by_names(String db_name,
String tbl_name,
List<String> names) |
List<Partition> |
ThriftHiveMetastore.Iface.get_partitions_ps_with_auth(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts,
String user_name,
List<String> group_names) |
List<Partition> |
ThriftHiveMetastore.Client.get_partitions_ps_with_auth(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts,
String user_name,
List<String> group_names) |
List<Partition> |
ThriftHiveMetastore.Iface.get_partitions_ps(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts) |
List<Partition> |
ThriftHiveMetastore.Client.get_partitions_ps(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts) |
List<Partition> |
ThriftHiveMetastore.Iface.get_partitions_with_auth(String db_name,
String tbl_name,
short max_parts,
String user_name,
List<String> group_names) |
List<Partition> |
ThriftHiveMetastore.Client.get_partitions_with_auth(String db_name,
String tbl_name,
short max_parts,
String user_name,
List<String> group_names) |
List<Partition> |
ThriftHiveMetastore.Iface.get_partitions(String db_name,
String tbl_name,
short max_parts) |
List<Partition> |
ThriftHiveMetastore.Client.get_partitions(String db_name,
String tbl_name,
short max_parts) |
List<Partition> |
ThriftHiveMetastore.add_partitions_args.getNew_parts() |
List<Partition> |
ThriftHiveMetastore.alter_partitions_args.getNew_parts() |
Iterator<Partition> |
ThriftHiveMetastore.add_partitions_args.getNew_partsIterator() |
Iterator<Partition> |
ThriftHiveMetastore.alter_partitions_args.getNew_partsIterator() |
List<Partition> |
PartitionsByExprResult.getPartitions() |
List<Partition> |
PartitionListComposingSpec.getPartitions() |
List<Partition> |
DropPartitionsResult.getPartitions() |
List<Partition> |
AddPartitionsResult.getPartitions() |
Iterator<Partition> |
PartitionsByExprResult.getPartitionsIterator() |
Iterator<Partition> |
PartitionListComposingSpec.getPartitionsIterator() |
Iterator<Partition> |
DropPartitionsResult.getPartitionsIterator() |
Iterator<Partition> |
AddPartitionsResult.getPartitionsIterator() |
List<Partition> |
AddPartitionsRequest.getParts() |
Iterator<Partition> |
AddPartitionsRequest.getPartsIterator() |
List<Partition> |
ThriftHiveMetastore.AsyncClient.get_partitions_call.getResult() |
List<Partition> |
ThriftHiveMetastore.AsyncClient.get_partitions_with_auth_call.getResult() |
List<Partition> |
ThriftHiveMetastore.AsyncClient.get_partitions_ps_call.getResult() |
List<Partition> |
ThriftHiveMetastore.AsyncClient.get_partitions_ps_with_auth_call.getResult() |
List<Partition> |
ThriftHiveMetastore.AsyncClient.get_partitions_by_filter_call.getResult() |
List<Partition> |
ThriftHiveMetastore.AsyncClient.get_partitions_by_names_call.getResult() |
List<Partition> |
ThriftHiveMetastore.get_partitions_result.getSuccess() |
List<Partition> |
ThriftHiveMetastore.get_partitions_with_auth_result.getSuccess() |
List<Partition> |
ThriftHiveMetastore.get_partitions_ps_result.getSuccess() |
List<Partition> |
ThriftHiveMetastore.get_partitions_ps_with_auth_result.getSuccess() |
List<Partition> |
ThriftHiveMetastore.get_partitions_by_filter_result.getSuccess() |
List<Partition> |
ThriftHiveMetastore.get_partitions_by_names_result.getSuccess() |
Iterator<Partition> |
ThriftHiveMetastore.get_partitions_result.getSuccessIterator() |
Iterator<Partition> |
ThriftHiveMetastore.get_partitions_with_auth_result.getSuccessIterator() |
Iterator<Partition> |
ThriftHiveMetastore.get_partitions_ps_result.getSuccessIterator() |
Iterator<Partition> |
ThriftHiveMetastore.get_partitions_ps_with_auth_result.getSuccessIterator() |
Iterator<Partition> |
ThriftHiveMetastore.get_partitions_by_filter_result.getSuccessIterator() |
Iterator<Partition> |
ThriftHiveMetastore.get_partitions_by_names_result.getSuccessIterator() |
List<Partition> |
ThriftHiveMetastore.Client.recv_get_partitions_by_filter() |
List<Partition> |
ThriftHiveMetastore.Client.recv_get_partitions_by_names() |
List<Partition> |
ThriftHiveMetastore.Client.recv_get_partitions_ps_with_auth() |
List<Partition> |
ThriftHiveMetastore.Client.recv_get_partitions_ps() |
List<Partition> |
ThriftHiveMetastore.Client.recv_get_partitions_with_auth() |
List<Partition> |
ThriftHiveMetastore.Client.recv_get_partitions() |
Modifier and Type | Method and Description |
---|---|
Partition |
ThriftHiveMetastore.Iface.add_partition_with_environment_context(Partition new_part,
EnvironmentContext environment_context) |
Partition |
ThriftHiveMetastore.Client.add_partition_with_environment_context(Partition new_part,
EnvironmentContext environment_context) |
void |
ThriftHiveMetastore.AsyncIface.add_partition_with_environment_context(Partition new_part,
EnvironmentContext environment_context,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.add_partition_with_environment_context_call> resultHandler) |
void |
ThriftHiveMetastore.AsyncClient.add_partition_with_environment_context(Partition new_part,
EnvironmentContext environment_context,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.add_partition_with_environment_context_call> resultHandler) |
Partition |
ThriftHiveMetastore.Iface.add_partition(Partition new_part) |
Partition |
ThriftHiveMetastore.Client.add_partition(Partition new_part) |
void |
ThriftHiveMetastore.AsyncIface.add_partition(Partition new_part,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.add_partition_call> resultHandler) |
void |
ThriftHiveMetastore.AsyncClient.add_partition(Partition new_part,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.add_partition_call> resultHandler) |
void |
ThriftHiveMetastore.add_partitions_args.addToNew_parts(Partition elem) |
void |
ThriftHiveMetastore.alter_partitions_args.addToNew_parts(Partition elem) |
void |
PartitionsByExprResult.addToPartitions(Partition elem) |
void |
PartitionListComposingSpec.addToPartitions(Partition elem) |
void |
DropPartitionsResult.addToPartitions(Partition elem) |
void |
AddPartitionsResult.addToPartitions(Partition elem) |
void |
AddPartitionsRequest.addToParts(Partition elem) |
void |
ThriftHiveMetastore.get_partitions_result.addToSuccess(Partition elem) |
void |
ThriftHiveMetastore.get_partitions_with_auth_result.addToSuccess(Partition elem) |
void |
ThriftHiveMetastore.get_partitions_ps_result.addToSuccess(Partition elem) |
void |
ThriftHiveMetastore.get_partitions_ps_with_auth_result.addToSuccess(Partition elem) |
void |
ThriftHiveMetastore.get_partitions_by_filter_result.addToSuccess(Partition elem) |
void |
ThriftHiveMetastore.get_partitions_by_names_result.addToSuccess(Partition elem) |
void |
ThriftHiveMetastore.Iface.alter_partition_with_environment_context(String db_name,
String tbl_name,
Partition new_part,
EnvironmentContext environment_context) |
void |
ThriftHiveMetastore.Client.alter_partition_with_environment_context(String db_name,
String tbl_name,
Partition new_part,
EnvironmentContext environment_context) |
void |
ThriftHiveMetastore.AsyncIface.alter_partition_with_environment_context(String db_name,
String tbl_name,
Partition new_part,
EnvironmentContext environment_context,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.alter_partition_with_environment_context_call> resultHandler) |
void |
ThriftHiveMetastore.AsyncClient.alter_partition_with_environment_context(String db_name,
String tbl_name,
Partition new_part,
EnvironmentContext environment_context,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.alter_partition_with_environment_context_call> resultHandler) |
void |
ThriftHiveMetastore.Iface.alter_partition(String db_name,
String tbl_name,
Partition new_part) |
void |
ThriftHiveMetastore.Client.alter_partition(String db_name,
String tbl_name,
Partition new_part) |
void |
ThriftHiveMetastore.AsyncIface.alter_partition(String db_name,
String tbl_name,
Partition new_part,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.alter_partition_call> resultHandler) |
void |
ThriftHiveMetastore.AsyncClient.alter_partition(String db_name,
String tbl_name,
Partition new_part,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.alter_partition_call> resultHandler) |
int |
Partition.compareTo(Partition other) |
boolean |
Partition.equals(Partition that) |
void |
ThriftHiveMetastore.Iface.rename_partition(String db_name,
String tbl_name,
List<String> part_vals,
Partition new_part) |
void |
ThriftHiveMetastore.Client.rename_partition(String db_name,
String tbl_name,
List<String> part_vals,
Partition new_part) |
void |
ThriftHiveMetastore.AsyncIface.rename_partition(String db_name,
String tbl_name,
List<String> part_vals,
Partition new_part,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.rename_partition_call> resultHandler) |
void |
ThriftHiveMetastore.AsyncClient.rename_partition(String db_name,
String tbl_name,
List<String> part_vals,
Partition new_part,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.rename_partition_call> resultHandler) |
void |
ThriftHiveMetastore.Client.send_add_partition_with_environment_context(Partition new_part,
EnvironmentContext environment_context) |
void |
ThriftHiveMetastore.Client.send_add_partition(Partition new_part) |
void |
ThriftHiveMetastore.Client.send_alter_partition_with_environment_context(String db_name,
String tbl_name,
Partition new_part,
EnvironmentContext environment_context) |
void |
ThriftHiveMetastore.Client.send_alter_partition(String db_name,
String tbl_name,
Partition new_part) |
void |
ThriftHiveMetastore.Client.send_rename_partition(String db_name,
String tbl_name,
List<String> part_vals,
Partition new_part) |
void |
ThriftHiveMetastore.add_partition_args.setNew_part(Partition new_part) |
void |
ThriftHiveMetastore.add_partition_with_environment_context_args.setNew_part(Partition new_part) |
void |
ThriftHiveMetastore.alter_partition_args.setNew_part(Partition new_part) |
void |
ThriftHiveMetastore.alter_partition_with_environment_context_args.setNew_part(Partition new_part) |
void |
ThriftHiveMetastore.rename_partition_args.setNew_part(Partition new_part) |
void |
ThriftHiveMetastore.add_partition_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.add_partition_with_environment_context_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.append_partition_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.append_partition_with_environment_context_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.append_partition_by_name_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.append_partition_by_name_with_environment_context_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.get_partition_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.exchange_partition_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.get_partition_with_auth_result.setSuccess(Partition success) |
void |
ThriftHiveMetastore.get_partition_by_name_result.setSuccess(Partition success) |
Modifier and Type | Method and Description |
---|---|
int |
ThriftHiveMetastore.Iface.add_partitions(List<Partition> new_parts) |
int |
ThriftHiveMetastore.Client.add_partitions(List<Partition> new_parts) |
void |
ThriftHiveMetastore.AsyncIface.add_partitions(List<Partition> new_parts,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.add_partitions_call> resultHandler) |
void |
ThriftHiveMetastore.AsyncClient.add_partitions(List<Partition> new_parts,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.add_partitions_call> resultHandler) |
void |
ThriftHiveMetastore.Iface.alter_partitions(String db_name,
String tbl_name,
List<Partition> new_parts) |
void |
ThriftHiveMetastore.Client.alter_partitions(String db_name,
String tbl_name,
List<Partition> new_parts) |
void |
ThriftHiveMetastore.AsyncIface.alter_partitions(String db_name,
String tbl_name,
List<Partition> new_parts,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.alter_partitions_call> resultHandler) |
void |
ThriftHiveMetastore.AsyncClient.alter_partitions(String db_name,
String tbl_name,
List<Partition> new_parts,
org.apache.thrift.async.AsyncMethodCallback<ThriftHiveMetastore.AsyncClient.alter_partitions_call> resultHandler) |
void |
ThriftHiveMetastore.Client.send_add_partitions(List<Partition> new_parts) |
void |
ThriftHiveMetastore.Client.send_alter_partitions(String db_name,
String tbl_name,
List<Partition> new_parts) |
void |
ThriftHiveMetastore.add_partitions_args.setNew_parts(List<Partition> new_parts) |
void |
ThriftHiveMetastore.alter_partitions_args.setNew_parts(List<Partition> new_parts) |
void |
PartitionsByExprResult.setPartitions(List<Partition> partitions) |
void |
PartitionListComposingSpec.setPartitions(List<Partition> partitions) |
void |
DropPartitionsResult.setPartitions(List<Partition> partitions) |
void |
AddPartitionsResult.setPartitions(List<Partition> partitions) |
void |
AddPartitionsRequest.setParts(List<Partition> parts) |
void |
ThriftHiveMetastore.get_partitions_result.setSuccess(List<Partition> success) |
void |
ThriftHiveMetastore.get_partitions_with_auth_result.setSuccess(List<Partition> success) |
void |
ThriftHiveMetastore.get_partitions_ps_result.setSuccess(List<Partition> success) |
void |
ThriftHiveMetastore.get_partitions_ps_with_auth_result.setSuccess(List<Partition> success) |
void |
ThriftHiveMetastore.get_partitions_by_filter_result.setSuccess(List<Partition> success) |
void |
ThriftHiveMetastore.get_partitions_by_names_result.setSuccess(List<Partition> success) |
Modifier and Type | Method and Description |
---|---|
Partition |
PreAlterPartitionEvent.getNewPartition() |
Partition |
AlterPartitionEvent.getNewPartition() |
Partition |
AlterPartitionEvent.getOldPartition() |
Modifier and Type | Method and Description |
---|---|
Iterator<Partition> |
PreDropPartitionEvent.getPartitionIterator() |
Iterator<Partition> |
PreAddPartitionEvent.getPartitionIterator() |
Iterator<Partition> |
DropPartitionEvent.getPartitionIterator() |
Iterator<Partition> |
AddPartitionEvent.getPartitionIterator() |
List<Partition> |
PreAddPartitionEvent.getPartitions() |
Constructor and Description |
---|
AddPartitionEvent(Table table,
Partition partition,
boolean status,
HiveMetaStore.HMSHandler handler) |
AlterPartitionEvent(Partition oldPart,
Partition newPart,
Table table,
boolean status,
HiveMetaStore.HMSHandler handler) |
DropPartitionEvent(Table table,
Partition partition,
boolean status,
boolean deleteData,
HiveMetaStore.HMSHandler handler) |
PreAddPartitionEvent(Table table,
Partition partition,
HiveMetaStore.HMSHandler handler) |
PreAlterPartitionEvent(String dbName,
String tableName,
List<String> oldPartVals,
Partition newPart,
HiveMetaStore.HMSHandler handler) |
PreDropPartitionEvent(Table table,
Partition partition,
boolean deleteData,
HiveMetaStore.HMSHandler handler) |
Constructor and Description |
---|
AddPartitionEvent(Table table,
List<Partition> partitions,
boolean status,
HiveMetaStore.HMSHandler handler) |
PreAddPartitionEvent(Table table,
List<Partition> partitions,
HiveMetaStore.HMSHandler handler) |
Modifier and Type | Method and Description |
---|---|
Partition |
PartitionSpecWithSharedSDProxy.Iterator.getCurrent() |
Partition |
PartitionSpecProxy.PartitionIterator.getCurrent()
Getter for the Partition "pointed to" by the iterator.
|
Partition |
PartitionSpecProxy.SimplePartitionWrapperIterator.getCurrent() |
Partition |
PartitionListComposingSpecProxy.Iterator.getCurrent() |
Partition |
CompositePartitionSpecProxy.Iterator.getCurrent() |
Partition |
PartitionSpecWithSharedSDProxy.Iterator.next() |
Partition |
PartitionSpecProxy.SimplePartitionWrapperIterator.next() |
Partition |
PartitionListComposingSpecProxy.Iterator.next() |
Partition |
CompositePartitionSpecProxy.Iterator.next() |
Constructor and Description |
---|
PartitionSpecProxy.SimplePartitionWrapperIterator(Partition partition) |
Modifier and Type | Method and Description |
---|---|
Partition |
LineageInfo.DataContainer.getPartition() |
Constructor and Description |
---|
LineageInfo.DataContainer(Table tab,
Partition part)
Constructor for a partitioned tables partition.
|
Modifier and Type | Method and Description |
---|---|
static Partition |
Partition.createMetaPartitionObject(Table tbl,
Map<String,String> partSpec,
org.apache.hadoop.fs.Path location) |
Partition |
Partition.getTPartition()
Should be only used by serialization.
|
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,String> |
Table.createSpec(Partition tp)
Creates a partition name -> value spec map object
|
protected void |
Partition.initialize(Table table,
Partition tPartition)
Initializes this object with the given variables
|
void |
Partition.setTPartition(Partition partition)
Should be only used by serialization.
|
Constructor and Description |
---|
Partition(Table tbl,
Partition tp) |
Modifier and Type | Method and Description |
---|---|
Iterable<Partition> |
EximUtil.ReadMetaData.getPartitions() |
Constructor and Description |
---|
EximUtil.ReadMetaData(Table table,
Iterable<Partition> partitions,
ReplicationSpec replicationSpec) |
Modifier and Type | Field and Description |
---|---|
protected List<Partition> |
MoveWork.movedParts
List of inserted partitions
|
Constructor and Description |
---|
AuthorizationPreEventListener.PartitionWrapper(Partition mapiPart,
PreEventContext context) |
AuthorizationPreEventListener.PartitionWrapper(Table table,
Partition mapiPart) |
Modifier and Type | Method and Description |
---|---|
void |
HarOutputCommitterPostProcessor.exec(org.apache.hadoop.mapreduce.JobContext context,
Partition partition,
org.apache.hadoop.fs.Path partPath) |
Modifier and Type | Method and Description |
---|---|
abstract AlterPartitionMessage |
MessageFactory.buildAlterPartitionMessage(Table table,
Partition before,
Partition after)
Factory method for building AlterPartitionMessage
|
Modifier and Type | Method and Description |
---|---|
abstract AddPartitionMessage |
MessageFactory.buildAddPartitionMessage(Table table,
Iterator<Partition> partitions)
Factory method for AddPartitionMessage.
|
abstract DropPartitionMessage |
MessageFactory.buildDropPartitionMessage(Table table,
Iterator<Partition> partitions)
Factory method for DropPartitionMessage.
|
Modifier and Type | Method and Description |
---|---|
AlterPartitionMessage |
JSONMessageFactory.buildAlterPartitionMessage(Table table,
Partition before,
Partition after) |
Modifier and Type | Method and Description |
---|---|
AddPartitionMessage |
JSONMessageFactory.buildAddPartitionMessage(Table table,
Iterator<Partition> partitionsIterator) |
DropPartitionMessage |
JSONMessageFactory.buildDropPartitionMessage(Table table,
Iterator<Partition> partitions) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.