我想在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传递主代码吗?
暂无答案!
目前还没有任何答案,快来回答吧!