List of dropPartition() Examples

Examples of dropPartition()

org.apache.hadoop.hive.metastore.HiveMetaStoreClient.dropPartition()
@param tbl_name @param db_name @param part_vals @return true or false @throws NoSuchObjectException @throws MetaException @throws TException @see org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore.Iface#drop_partition(java.lang.String,java.lang.String,java.util.List,boolean)
org.apache.hadoop.hive.ql.metadata.Hive.dropPartition()

Examples of org.apache.hadoop.hive.metastore.HiveMetaStoreClient.dropPartition()

      if (partitionsAdded.size() > 0) {
        try {
          // baseCommitter.cleanupJob failed, try to clean up the
          // metastore
          for (Partition p : partitionsAdded) {
            client.dropPartition(tableInfo.getDatabaseName(),
                tableInfo.getTableName(), p.getValues());
          }
        } catch (Exception te) {
          // Keep cause as the original exception
          throw new HCatException(

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.HiveMetaStoreClient.dropPartition()

      if (partitionsAdded.size() > 0) {
        try {
          // baseCommitter.cleanupJob failed, try to clean up the
          // metastore
          for (Partition p : partitionsAdded) {
            client.dropPartition(tableInfo.getDatabaseName(),
                tableInfo.getTableName(), p.getValues());
          }
        } catch (Exception te) {
          // Keep cause as the original exception
          throw new HCatException(

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.HiveMetaStoreClient.dropPartition()

            if (partitionsAdded.size() > 0) {
                try {
                    // baseCommitter.cleanupJob failed, try to clean up the
                    // metastore
                    for (Partition p : partitionsAdded) {
                        client.dropPartition(tableInfo.getDatabaseName(),
                                tableInfo.getTableName(), p.getValues());
                    }
                } catch (Exception te) {
                    // Keep cause as the original exception
                    throw new HCatException(

View Full Code Here

Examples of org.apache.hadoop.hive.ql.metadata.Hive.dropPartition()

            }
          }
          // drop all existing partitions from the list
          for (Partition partition : parts) {
            console.printInfo("Dropping the partition " + partition.getName());
            db.dropPartition(MetaStoreUtils.DEFAULT_DATABASE_NAME, 
                dropTbl.getTableName(), 
                partition.getValues(), 
                true); //drop data for the partition
          }
        }

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.