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()

      } catch (Exception e) {


        if( partitionAdded ) {
          try {
            //baseCommitter.cleanupJob failed, try to clean up the metastore
            client.dropPartition(tableInfo.getDatabaseName(),
                    tableInfo.getTableName(), values);
          } catch(Exception te) {
            //Keep cause as the original exception
            throw new HowlException(ErrorType.ERROR_PUBLISHING_PARTITION, e);
          }

View Full Code Here

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

      assertEquals(1, parts.size());
      Partition insertedPart = parts.get(0);
      assertEquals(tbl.getSd().getLocation() + Path.SEPARATOR + partitionLocation, 
          insertedPart.getSd().getLocation());


      client.dropPartition(dbName, tableName, insertedPart.getValues());


      // add without location specified


      AddPartitionDesc addPartition = new AddPartitionDesc(dbName, tableName, part1, null);
      Task<DDLWork> task = TaskFactory.get(new DDLWork(addPartition), hiveConf);

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.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(ErrorType.ERROR_PUBLISHING_PARTITION, e);

View Full Code Here

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

    client.close();


    // user with ALL on DB should be able to drop partition
    client = context.getMetaStoreClient(USER1_1);
    tbl1 = client.getTable(dbName, tabName1);
    client.dropPartition(dbName, tabName1, partVals1, true);
    client.close();


    // user with ALL on Table should be able to drop partition
    client = context.getMetaStoreClient(USER2_1);
    tbl1 = client.getTable(dbName, tabName1);

View Full Code Here

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

    client.close();


    // user with ALL on Table should be able to drop partition
    client = context.getMetaStoreClient(USER2_1);
    tbl1 = client.getTable(dbName, tabName1);
    client.dropPartition(dbName, tabName1, partVals2, true);
    client.close();


    // user without ALL on DB or Table should NOT be able to drop partition
    client = context.getMetaStoreClient(USER3_1);
    try {

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(ErrorType.ERROR_PUBLISHING_PARTITION, e);

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

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.