Examples of org.apache.hadoop.hbase.client.Admin.disableTable()

Class org.apache.hadoop.hbase.client.Admin

Examples of org.apache.hadoop.hbase.client.Admin.disableTable()

org.apache.hadoop.hbase.client.Admin.disableTable()
Disable table and wait on completion. May timeout eventually. Use {@link #disableTableAsync(org.apache.hadoop.hbase.TableName)} and{@link #isTableDisabled(org.apache.hadoop.hbase.TableName)} instead. The table has to be inenabled state for it to be disabled. @param tableName @throws IOException There could be couple types of IOException TableNotFoundException means thetable doesn't exist. TableNotEnabledException means the table isn't in enabled state.

      } finally {
        if (table != null) {
          table.close();
        }
        // delete the table
        admin.disableTable(tableName);
        admin.deleteTable(tableName);
      }
    }
  }

View Full Code Here


      FileSystem fs = HFileSystem.get(conf);
      Admin admin = new HBaseAdmin(conf);


      if (admin.tableExists(tableName)) {
        admin.disableTable(tableName);
        admin.deleteTable(tableName);
      }


      if (fs.exists(p)) {
        fs.delete(p, true);

View Full Code Here


    // and load the table
    UTIL.loadRegion(region, TEST_FAM);


    // shutdown the table so we can manipulate the files
    admin.disableTable(TABLE_NAME);


    FileSystem fs = UTIL.getTestFileSystem();


    // now attempt to depose the region
    Path rootDir = region.getRegionFileSystem().getTableDir().getParent();

View Full Code Here

  @Before
  public void setUp() throws Exception {
    Admin admin = util.getHBaseAdmin();
    if (admin.tableExists(tableName)) {
      if (admin.isTableEnabled(tableName)) {
        admin.disableTable(tableName);
      }
      admin.deleteTable(tableName);
    }
    util.createTable(tableName, new byte[][] {dummy, test});
  }

View Full Code Here

        TableName.valueOf("testTableExists");
    assertFalse(MetaTableAccessor.tableExists(connection, name));
    UTIL.createTable(name, HConstants.CATALOG_FAMILY);
    assertTrue(MetaTableAccessor.tableExists(connection, name));
    Admin admin = UTIL.getHBaseAdmin();
    admin.disableTable(name);
    admin.deleteTable(name);
    assertFalse(MetaTableAccessor.tableExists(connection, name));
    assertTrue(MetaTableAccessor.tableExists(connection,
      TableName.META_TABLE_NAME));
  }

View Full Code Here

    // Create a table with one family
    HTableDescriptor baseHtd = new HTableDescriptor(TABLE_NAME);
    HColumnDescriptor hcd = new HColumnDescriptor(FAMILY);
    baseHtd.addFamily(hcd);
    admin.createTable(baseHtd);
    admin.disableTable(TABLE_NAME);
    try {
      // Verify the column descriptor
      verifyHColumnDescriptor(1, TABLE_NAME, FAMILY);
    } finally {
      admin.deleteTable(TABLE_NAME);

View Full Code Here

    HTableDescriptor baseHtd = new HTableDescriptor(TABLE_NAME);
    HColumnDescriptor hcd = new HColumnDescriptor(FAMILY);
    hcd.setMaxVersions(TEST_UTIL.getConfiguration().getInt("hbase.column.max.version", 1));
    baseHtd.addFamily(hcd);
    admin.createTable(baseHtd);
    admin.disableTable(TABLE_NAME);
    try {
      // Verify the column descriptor
      verifyHColumnDescriptor(3, TABLE_NAME, FAMILY);
    } finally {
      admin.deleteTable(TABLE_NAME);

View Full Code Here

        new HColumnDescriptor(FAMILY, 5, HColumnDescriptor.DEFAULT_COMPRESSION,
            HColumnDescriptor.DEFAULT_IN_MEMORY, HColumnDescriptor.DEFAULT_BLOCKCACHE,
            HColumnDescriptor.DEFAULT_TTL, HColumnDescriptor.DEFAULT_BLOOMFILTER);
    baseHtd.addFamily(hcd);
    admin.createTable(baseHtd);
    admin.disableTable(TABLE_NAME);
    try {
      // Verify the column descriptor
      verifyHColumnDescriptor(5, TABLE_NAME, FAMILY);


    } finally {

View Full Code Here

      List<HRegionInfo> originalTableRegions =
        MetaTableAccessor.getTableRegions(connection, desc.getTableName());
      LOG.info("originalTableRegions size=" + originalTableRegions.size() +
        "; " + originalTableRegions);
      Admin admin = new HBaseAdmin(c);
      admin.disableTable(desc.getTableName());
      HMerge.merge(c, FileSystem.get(c), desc.getTableName());
      List<HRegionInfo> postMergeTableRegions =
        MetaTableAccessor.getTableRegions(connection, desc.getTableName());
      LOG.info("postMergeTableRegions size=" + postMergeTableRegions.size() +
        "; " + postMergeTableRegions);

View Full Code Here

      } finally {
        if (table != null) {
          table.close();
        }
        // delete the table
        admin.disableTable(tableName);
        admin.deleteTable(tableName);
      }
    }
  }

View Full Code Here

0 1 2 3 4 5 6 7 8

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.