unit-testing - 如何模拟 hbase 连接

Question

我需要为单元测试模拟一个 HBase。特别是，我的程序需要连接到 HBase。我该怎么做？我只是使用了 HbaseTestingUtility.getConnection()。但显然，它不起作用。谢谢！

标签： unit-testingmockinghbase

Answer 1

这就是我与 HBaseTestingUtil 类（版本 2.0.2）建立连接的方式：

import org.apache.hadoop.hbase.HBaseTestingUtility

val utility = new HBaseTestingUtiliy
utility.startMiniCluster() // defaults to 1 master and 1 region server
val connection = utility.getConnection()

如果您需要添加一些特定的配置（例如安全设置），您可以将 hbase-site.xml 添加到您的资源中。