设为首页 加入收藏

TOP

Eclipse远程访问HBase
2019-04-14 13:48:34 】 浏览:8
Tags:Eclipse 远程 访问 HBase

注意:实践过程中并不需要winutils.exe.

HBase安装请参考:https://blog.csdn.net/xiaof22a/article/details/80213064

1. 打开Eclipse, 新建工程HBase

2. 将%HBASE_HOME%\lib文件下的所有lib文件添加到 HBase的dependencies中:


3. 测试代码:

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.HBaseAdmin;

public class Test {
	public static Configuration conf = null;

	public static void main(String[] args) throws Exception {

		conf = HBaseConfiguration.create();
		conf.set("hbase.zookeeper.quorum", "master");// 使用eclipse时必须添加这个,否则无法定位
		conf.set("hbase.zookeeper.property.clientPort", "2181");
		HBaseAdmin admin = new HBaseAdmin(conf);// 新建一个数据库管理员//新api
		String[] familys=new String[] {"cf1"};
		String tableName="blog";
		if (admin.tableExists(tableName)) {
			System.out.println("table already exists!");
		} else {
			HTableDescriptor tableDesc = new HTableDescriptor(tableName);
			for (int i = 0; i < familys.length; i++) {
				tableDesc.addFamily(new HColumnDescriptor(familys[i]));
			}
			admin.createTable(tableDesc);
			System.out.println("create table " + tableName + " ok.");
		}

	}
}

输出结果:



编程开发网
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇hbase自带的测试工具Performancee.. 下一篇hbase读数据之client

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

array(4) { ["type"]=> int(8) ["message"]=> string(24) "Undefined variable: jobs" ["file"]=> string(32) "/mnt/wp/cppentry/do/bencandy.php" ["line"]=> int(214) }