FancyKing

使用Java操作HBase-第4关:删除表

Mar 21st, 2020
134
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.52 KB | None | 0 0
  1. package step4;
  2.  
  3. import java.io.IOException;
  4. import org.apache.hadoop.conf.Configuration;
  5. import org.apache.hadoop.hbase.HBaseConfiguration;
  6. import org.apache.hadoop.hbase.HColumnDescriptor;
  7. import org.apache.hadoop.hbase.HTableDescriptor;
  8. import org.apache.hadoop.hbase.TableName;
  9. import org.apache.hadoop.hbase.client.Admin;
  10. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
  11. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
  12. import org.apache.hadoop.hbase.client.Connection;
  13. import org.apache.hadoop.hbase.client.ConnectionFactory;
  14. import org.apache.hadoop.hbase.client.Get;
  15. import org.apache.hadoop.hbase.client.Put;
  16. import org.apache.hadoop.hbase.client.Result;
  17. import org.apache.hadoop.hbase.client.ResultScanner;
  18. import org.apache.hadoop.hbase.client.Scan;
  19. import org.apache.hadoop.hbase.client.Table;
  20. import org.apache.hadoop.hbase.client.TableDescriptor;
  21. import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
  22. import org.apache.hadoop.hbase.util.Bytes;
  23.  
  24. /**
  25.  * @author FancyKing
  26.  */
  27. public class Task {
  28.    
  29.    
  30.     public void deleteTable()throws Exception{
  31.         /********* Begin *********/
  32.         Configuration config = HBaseConfiguration.create();
  33.         Connection connection = ConnectionFactory.createConnection(config);
  34.         TableName tableName = TableName.valueOf("t_step4");
  35.         // Table table = connection.getTable(tableName);
  36.         Admin admin = connection.getAdmin();
  37.         admin.disableTable(tableName);
  38.         admin.deleteTable(tableName);
  39.        
  40.        
  41.         /********* End *********/
  42.     }
  43. }
Add Comment
Please, Sign In to add comment