我对hbase开发非常陌生。我正在跟踪链接。我使用的是hbase-1.1.2版本。当我使用示例代码时,会收到警告。有几种方法已被弃用(例如,new hbaseadmin(conf);)我看到了hbaseadmin类,它有3个构造函数。三个构造函数中有两个被弃用。只有一个构造函数接受“clusterconnection”作为参数。我不知道我是按照正确的链接玩hbase。请提供一个使用最新hbase库的示例。?我以独立模式运行hbase。
mu0hgdu01#
下面是我的hbase 2.0示例:
Configuration hBaseConfig = HBaseConfiguration.create(); hBaseConfig.set("hbase.zookeeper.quorum", "192.168.x.xxx"); hBaseConfig.set("hbase.zookeeper.property.clientPort", "2181"); HBaseAdmin.available(hBaseConfig); Connection connection = ConnectionFactory.createConnection(hBaseConfig); TableName table1 = TableName.valueOf("test"); Table table = connection.getTable(table1); CellBuilder cb = CellBuilderFactory.create(CellBuilderType.SHALLOW_COPY); cb.setRow(Bytes.toBytes("row2")); cb.setFamily(Bytes.toBytes("cf1")); cb.setQualifier("qualifier1".getBytes()); cb.setValue(Bytes.toBytes("cell_data2")); cb.setType(Type.Put); Cell cell = cb.build(); Put p = new Put(Bytes.toBytes("row2")); p.add(cell); table.put(p); connection.close();
我在spring boot 2.0应用程序gradle dependencies中编写了上述演示,如下所示:
dependencies { compile('org.springframework.boot:spring-boot-starter-data-rest') compile('org.springframework.boot:spring-boot-starter-web') compile ('org.apache.hbase:hbase:2.0.0') compile ('org.apache.hbase:hbase-client:2.0.0'){ exclude group :'log4j',module:'log4j' exclude group :'org.slf4j',module:'slf4j-log4j12' exclude group: 'javax.servlet', module: 'servlet-api' } compile('org.springframework.boot:spring-boot-configuration-processor') providedRuntime('org.springframework.boot:spring-boot-starter-tomcat') testCompile('org.springframework.boot:spring-boot-starter-test') }
xu3bshqb2#
这应该会有帮助
HConnection connection; HTableInterface hTableInterface = null; Configuration hBaseConfig = HBaseConfiguration.create(); hBaseConfig.setInt("timeout", 120000); //zookeeper quorum, basic info needed to proceed hBaseConfig.set("hbase.zookeeper.quorum","host1, host2, host3"); hBaseConfig.set("hbase.zookeeper.property.clientPort", "2181"); hBaseConfig.set("zookeeper.znode.parent", "/hbase-unsecure"); connection = HConnectionManager.createConnection(hBaseConfig); hTableInterface = connection.getTable(TableName.valueOf("amarTest")); try { Put put = new Put(Bytes.toBytes("999")); put.add(Bytes.toBytes("cf"),Bytes.toBytes("name"), Bytes.toBytes("amar")); hTableInterface.put(put); System.out.println("done"); } catch (Exception e) { e.printStackTrace(); } finally { hTableInterface.close(); connection.close(); }
2条答案
按热度按时间mu0hgdu01#
下面是我的hbase 2.0示例:
我在spring boot 2.0应用程序gradle dependencies中编写了上述演示,如下所示:
xu3bshqb2#
这应该会有帮助