如何在java中实现hbase接口
答案:1 悬赏:0 手机版
解决时间 2021-03-06 17:01
- 提问者网友:做自己de王妃
- 2021-03-06 07:46
如何在java中实现hbase接口
最佳答案
- 五星知识达人网友:轻雾山林
- 2021-03-06 09:08
使用maven+idea进行管理
maven
log4j log4j 1.2.17
org.apache.hbase hbase-shaded-client 1.2.3 追答代码如下:package hbase; import java.io.IOException; import java.util.List; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.CellUtil; import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.MasterNotRunningException; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.ZooKeeperConnectionException; import org.apache.hadoop.hbase.client.*; import org.apache.hadoop.hbase.util.Bytes; public class HbaseDemo { static Connection connection =null; static{ Configuration hbaseConfiguration = HBaseConfiguration.create(); hbaseConfiguration.set("hbase.zookeeper.property.clientPort", "2181"); hbaseConfiguration.set("hbase.zookeeper.quorum", "192.168.199.6,192.168.199.7,192.168.199.8"); try { connection = ConnectionFactory.createConnection(hbaseConfiguration); } catch (IOException e) { e.printStackTrace(); } } public static void CreateTable(String tablename,String columnFamily) throws MasterNotRunningException, ZooKeeperConnectionException, IOException{ Admin admin = connection.getAdmin(); TableName tableName =TableName.valueOf(tablename); HTableDescriptor tableDesc = new HTableDescriptor(tableName); tableDesc.addFamily(new HColumnDescriptor(columnFamily)); admin.createTable(tableDesc); System.out.println(tablename+"表已经成功创建!"); } public static void PutData(String tableName,String row,String columnFamily,String column,String data) throws IOException{ TableName tableName1 = TableName.valueOf(tableName); Table table = connection.getTa
maven
我要举报
如以上问答信息为低俗、色情、不良、暴力、侵权、涉及违法等信息,可以点下面链接进行举报!
大家都在看
推荐资讯