hbasetestinguility hbase-site.xml

jqjz2hbq  于 2021-06-07  发布在  Hbase
关注(0)|答案(0)|浏览(219)

我想在java中测试apachebeam应用程序时使用hbasetestinguility。在我的主代码中,我使用hbase-site.xml连接到hbase,如下所示

Configuration conf = HBaseConfiguration.create();
conf.addResource(new Path(options.getHbsxml()));
HBaseAdmin.checkHBaseAvailable(conf);

在我的junit中,我可以使用下面的代码创建hbase hbasetestinguility。

private HBaseTestingUtility hBaseTestingUtility = new HBaseTestingUtility();
private byte[] hbsqlty = Bytes.toBytes("hbsqlty");
private byte[] mbrqlty = Bytes.toBytes("mbrqlty");
private HTable hTable;

@Before
public void before() throws Exception {
    System.out.println("start mini cluster before first test started");
    hBaseTestingUtility.startMiniCluster();
    System.out.println("create table");
    hBaseTestingUtility.createTable(hbsqlty, mbrqlty);

我想为这个hbasetestinguility创建一个hbase xml并将其传递给主代码。请任何人从hbasetestinguility包中建议我们可以让hbase-site.xml传递主代码吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题