Examples of PreDropPartitionEvent

org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent


      try {
        ms.openTransaction();
        part = ms.getPartition(db_name, tbl_name, part_vals);
        tbl = get_table(db_name, tbl_name);
        firePreEvent(new PreDropPartitionEvent(tbl, part, deleteData, this));


        if (part == null) {
          throw new NoSuchObjectException("Partition doesn't exist. "
              + part_vals);
        }

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent


      try {
        ms.openTransaction();
        part = ms.getPartition(db_name, tbl_name, part_vals);
        tbl = get_table(db_name, tbl_name);
        firePreEvent(new PreDropPartitionEvent(tbl, part, deleteData, this));


        if (part == null) {
          throw new NoSuchObjectException("Partition doesn't exist. "
              + part_vals);
        }

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent

          if (!ignoreProtection && !MetaStoreUtils.canDropPartition(tbl, part)) {
            throw new MetaException("Table " + tbl.getTableName()
                + " Partition " + part + " is protected from being dropped");
          }


          firePreEvent(new PreDropPartitionEvent(tbl, part, deleteData, this));
          if (colNames != null) {
            partNames.add(FileUtils.makePartName(colNames, part.getValues()));
          }
          // Preserve the old behavior of failing when we cannot write, even w/o deleteData,
          // and even if the table is external. That might not make any sense.

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent

    DropPartitionEvent dropPart = (DropPartitionEvent)notifyList.get(listSize - 1);
    assert dropPart.getStatus();
    validateDropPartition(part, dropPart.getPartition());
    validateTableInDropPartition(tbl, dropPart.getTable());


    PreDropPartitionEvent preDropPart = (PreDropPartitionEvent)preNotifyList.get(listSize - 1);
    validateDropPartition(part, preDropPart.getPartition());


    driver.run("drop table " + tblName);
    listSize++;
    assertEquals(notifyList.size(), listSize);
    assertEquals(preNotifyList.size(), listSize);

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent


      try {
        ms.openTransaction();
        part = ms.getPartition(db_name, tbl_name, part_vals);


        firePreEvent(new PreDropPartitionEvent(part, this));


        if (part == null) {
          throw new NoSuchObjectException("Partition doesn't exist. "
              + part_vals);
        }

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent

        ms.openTransaction();
        part = ms.getPartition(db_name, tbl_name, part_vals);


        try {
          for(MetaStorePreEventListener listener : preListeners){
            listener.onEvent(new PreDropPartitionEvent(part, this));
          }
        } catch (InvalidOperationException e) {
          throw new MetaException(e.getMessage());
        }

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent


      try {
        ms.openTransaction();
        part = ms.getPartition(db_name, tbl_name, part_vals);
        tbl = get_table(db_name, tbl_name);
        firePreEvent(new PreDropPartitionEvent(tbl, part, deleteData, this));


        if (part == null) {
          throw new NoSuchObjectException("Partition doesn't exist. "
              + part_vals);
        }

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent

          if (!ignoreProtection && !MetaStoreUtils.canDropPartition(tbl, part)) {
            throw new MetaException("Table " + tbl.getTableName()
                + " Partition " + part + " is protected from being dropped");
          }


          firePreEvent(new PreDropPartitionEvent(tbl, part, deleteData, this));
          if (colNames != null) {
            partNames.add(FileUtils.makePartName(colNames, part.getValues()));
          }
          // Preserve the old behavior of failing when we cannot write, even w/o deleteData,
          // and even if the table is external. That might not make any sense.

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent

        prePartMarkEvent.getPartitionName());


    driver.run(String.format("alter table %s drop partition (b='2011')", tblName));
    listSize++;
    assertEquals(notifyList.size(), listSize);
    PreDropPartitionEvent preDropPart = (PreDropPartitionEvent) preNotifyList.get(preNotifyList
        .size() - 1);


    DropPartitionEvent dropPart = (DropPartitionEvent)notifyList.get(listSize - 1);
    assert dropPart.getStatus();
    validateDropPartition(part, dropPart.getPartition());
    validateTableInDropPartition(tbl, dropPart.getTable());


    validateDropPartition(part, preDropPart.getPartition());
    validateTableInDropPartition(tbl, preDropPart.getTable());


    driver.run("drop table " + tblName);
    listSize++;
    assertEquals(notifyList.size(), listSize);
    PreDropTableEvent preDropTbl = (PreDropTableEvent)preNotifyList.get(preNotifyList.size() - 1);

View Full Code Here

Examples of org.apache.hadoop.hive.metastore.events.PreDropPartitionEvent


      try {
        ms.openTransaction();
        part = ms.getPartition(db_name, tbl_name, part_vals);
        tbl = get_table_core(db_name, tbl_name);
        firePreEvent(new PreDropPartitionEvent(tbl, part, deleteData, this));


        if (part == null) {
          throw new NoSuchObjectException("Partition doesn't exist. "
              + part_vals);
        }

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.