(亲测)Hbase安装（傻瓜式安装） |
您所在的位置：网站首页 › vmware添加到path有什么用 › (亲测)Hbase安装（傻瓜式安装） |
(亲测)Hbase安装（傻瓜式安装）
|
Hbase安装
一、 安装Hadoop对应版本的Hbase二、伪分布式模式配置三、HBase java API 编程实践
一、 安装Hadoop对应版本的Hbase
查看各个对应稳定版本
如果已经引入过PATH请在export PATH这行追加/usr/local/hbase/bin，这里的“：”是分隔符。如下图：
启动hbase cd /usr/local/hbase bin/start-hbase.sh
 创建java Project HBaseExample 在“JRE”选项卡中选中第2项“Use a project specific JRE”，然后点击界面底部的“Next”按钮。   在弹出的界面中（如下图所示），用鼠标点击“Libraries”选项卡，然后，点击界面右侧的“Add External JARs…”按钮。  在弹出的“JAR Selection”界面中（如下图所示），进入到“/usr/local/hbase/lib”目录，选中该目录下的所有jar文件（注意，不要选中client-facing-thirdparty、ruby、shaded-clients和zkcli这四个目录），然后，点击界面底部的“OK”按钮。  然后，在“JAR Selection”界面中（如下图所示），点击进入到“client-facing-thirdparty”目录下。  然后，再点击界面（如下图所示）底部的“Finish”按钮。   在代码窗口中（如下图所示），ExampleForHBase.java代码内容输入。
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
public class ExampleForHBase {
public static Configuration configuration;
public static Connection connection;
public static Admin admin;
public static void main(String[] args)throws IOException{
init();
createTable("student",new String[]{"score"});
insertData("student","zhangsan","score","English","69");
insertData("student","zhangsan","score","Math","86");
insertData("student","zhangsan","score","Computer","77");
getData("student", "zhangsan", "score","English");
close();
}
public static void init(){
configuration = HBaseConfiguration.create();
configuration.set("hbase.rootdir","hdfs://localhost:9000/hbase");
try{
connection = ConnectionFactory.createConnection(configuration);
admin = connection.getAdmin();
}catch (IOException e){
e.printStackTrace();
}
}
public static void close(){
try{
if(admin != null){
admin.close();
}
if(null != connection){
connection.close();
}
}catch (IOException e){
e.printStackTrace();
}
}
public static void createTable(String myTableName,String[] colFamily) throws IOException {
TableName tableName = TableName.valueOf(myTableName);
if(admin.tableExists(tableName)){
System.out.println("talbe is exists!");
}else {
TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(tableName);
for(String str:colFamily){
ColumnFamilyDescriptor family =
ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(str)).build();
tableDescriptor.setColumnFamily(family);
}
admin.createTable(tableDescriptor.build());
}
}
public static void insertData(String tableName,String rowKey,String colFamily,String col,String val) throws IOException {
Table table = connection.getTable(TableName.valueOf(tableName));
Put put = new Put(rowKey.getBytes());
put.addColumn(colFamily.getBytes(),col.getBytes(), val.getBytes());
table.put(put);
table.close();
}
public static void getData(String tableName,String rowKey,String colFamily, String col)throws IOException{
Table table = connection.getTable(TableName.valueOf(tableName));
Get get = new Get(rowKey.getBytes());
get.addColumn(colFamily.getBytes(),col.getBytes());
Result result = table.get(get);
System.out.println(new String(result.getValue(colFamily.getBytes(),col==null?null:col.getBytes())));
table.close();
}
}
在开始运行程序之前，需要启动HDFS和HBase。 然后，如下图所示，点击界面中的运行图标右侧的“倒三角”，在弹出的菜单中选择“Run As”，再在弹出的菜单中点击“1 Java Application”，开始运行程序。程序运行成功以后，如下图所示，会在运行结果中出现“69”。  这时，可以到HBase Shell交互式环境中，使用如下命令查看student表是否创建成功：
list
|
绿色√代表兼容版本 Hbase官方下载地址: http://archive.apache.org/dist/hbase/.
编辑完成后，再执行source命令使上述配置在当前终端立即生效，命令如下：
3. 配置/usr/local/hbase/conf/hbase-site.xml 用命令vi打开并编辑hbase-site.xml，命令如下：
hbase.rootdir指定HBase的存储目录；hbase.cluster.distributed设置集群处于分布式模式. 另外，上面配置文件中，hbase.unsafe.stream.capability.enforce这个属性的设置，是为了避免出现启动错误 4. 接下来测试运行HBase。 启动hadoop
5. 进入shell界面：
6. 停止HBase运行,命令如下
【本文地址】
今日新闻 |
推荐新闻 |