版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/sunrising_hill/article/details/79355967
package hbase import org.apache.hadoop.conf.Configuration import org.apache.hadoop.hbase.{HBaseConfiguration, TableName} import org.apache.hadoop.hbase.client.{Connection, ConnectionFactory} /** * Created by ytc2007 on 2018/2/23. */ object HbaseTable { var tableName: String = "test" def main(args: Array[String]): Unit = { truncateUserRelationTable() } def truncateUserRelationTable() : Unit = { var connection = getHBaseConnection() var admin = connection.getAdmin if (admin.isTableEnabled(TableName.valueOf(tableName))) { admin.disableTable(TableName.valueOf(tableName)) } if (admin.isTableDisabled(TableName.valueOf(tableName))) { admin.truncateTable(TableName.valueOf(tableName), true) } if (admin.isTableDisabled(TableName.valueOf(tableName))) { admin.enableTable(TableName.valueOf(tableName)) } connection.close() } def getHBaseConnection() : Connection = { var configuration: Configuration = null var connection: Connection = null if (configuration == null) { configuration = HBaseConfiguration.create() configuration.set("hbase.zookeeper.quorum", "hm.hbase.com") } connection = ConnectionFactory.createConnection(configuration); connection } }