2. 程式人生 > >hbase 基本開發-插入表

hbase 基本開發-插入表

阿新 • • 發佈：2018-06-26
AS 其中 jar 0.10 window spa ogr image sse

創建maven項目

pom.xml文件內容: 3個依賴包 hbase-client hadoop-hdfs jdk.tools


<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>mjj.hbase</groupId>

<artifactId>test-10</artifactId>

<version>0.0.1-SNAPSHOT</version>

<dependencies>

<dependency>

<groupId>org.apache.hbase</groupId>

<artifactId>hbase-client</artifactId>

<version>2.0.0</version>

</dependency>

<dependency>

<groupId>org.apache.hadoop</groupId>

<artifactId>hadoop-hdfs</artifactId>

<version>2.8.0</version>

</dependency>

<dependency>

<groupId>jdk.tools</groupId>

<artifactId>jdk.tools</artifactId>

<version>1.8</version>

<scope>system</scope>

<systemPath>C:\Program Files\Java\jdk1.8.0_151\lib\tools.jar</systemPath>

</dependency>

</dependencies>

</project>


連接hbase的兩種方法:

配置法

1 在main文件夾下，建立resources文件夾，在resources文件夾下建立hbase文件，hbase文件夾下放hbase-site.xml配置文件(主要用到裏面的zookeeper配置信息)

技術分享圖片

配置文件主要內容如下:

hbase-site.xml

<property>

<name>hbase.zookeeper.quorum</name>

<value>192.168.50.1071</value>

</property>

<property>

<name>hbase.zookeeper.property.clientPort</name>

<value>2181</value>

</property>


代碼:

package myHbase;


import java.io.IOException;


import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.Cell;

import org.apache.hadoop.hbase.Cell.Type;

import org.apache.hadoop.hbase.CellBuilder;

import org.apache.hadoop.hbase.CellBuilderFactory;

import org.apache.hadoop.hbase.CellBuilderType;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.hbase.client.Connection;

import org.apache.hadoop.hbase.client.ConnectionFactory;

import org.apache.hadoop.hbase.client.HBaseAdmin;

import org.apache.hadoop.hbase.client.Put;

import org.apache.hadoop.hbase.client.Table;

import org.apache.hadoop.hbase.util.Bytes;


public class SimpleTest {


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

// TODO Auto-generated method stub

Configuration hBaseConfig = HBaseConfiguration.create();

HBaseAdmin.available(hBaseConfig);

Connection connection = ConnectionFactory.createConnection(hBaseConfig);


TableName table1 = TableName.valueOf("test");

Table table = connection.getTable(table1);


CellBuilder cb = CellBuilderFactory.create(CellBuilderType.SHALLOW_COPY);

cb.setRow(Bytes.toBytes("row3"));

cb.setFamily(Bytes.toBytes("cf"));

cb.setQualifier("qualifier1".getBytes());

cb.setValue(Bytes.toBytes("mjj2"));

cb.setType(Type.Put);

Cell cell = cb.build();


Put p = new Put(Bytes.toBytes("row3"));

p.add(cell);

table.put(p);


connection.close();

}


}


配置不正確報錯（zookeeper的連接丟失）:

Exception in thread "main" org.apache.hadoop.hbase.MasterNotRunningException: org.apache.hadoop.hbase.MasterNotRunningException: java.io.IOException: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /hbase/master


代碼裏設定zookeeper：

package myHbase;


import java.io.IOException;


import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.Cell;

import org.apache.hadoop.hbase.Cell.Type;

import org.apache.hadoop.hbase.CellBuilder;

import org.apache.hadoop.hbase.CellBuilderFactory;

import org.apache.hadoop.hbase.CellBuilderType;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.hbase.client.Connection;

import org.apache.hadoop.hbase.client.ConnectionFactory;

import org.apache.hadoop.hbase.client.HBaseAdmin;

import org.apache.hadoop.hbase.client.Put;

import org.apache.hadoop.hbase.client.Table;

import org.apache.hadoop.hbase.util.Bytes;


public class SimpleTest {


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

// TODO Auto-generated method stub

Configuration hBaseConfig = HBaseConfiguration.create();

hBaseConfig.set("hbase.zookeeper.quorum", "192.168.50.107");

hBaseConfig.set("hbase.zookeeper.property.clientPort", "2181");

HBaseAdmin.available(hBaseConfig);

Connection connection = ConnectionFactory.createConnection(hBaseConfig);


TableName table1 = TableName.valueOf("test");

Table table = connection.getTable(table1);


CellBuilder cb = CellBuilderFactory.create(CellBuilderType.SHALLOW_COPY);

cb.setRow(Bytes.toBytes("row3"));

cb.setFamily(Bytes.toBytes("cf"));

cb.setQualifier("qualifier1".getBytes());

cb.setValue(Bytes.toBytes("mjj2"));

cb.setType(Type.Put);

Cell cell = cb.build();


Put p = new Put(Bytes.toBytes("row3"));

p.add(cell);

table.put(p);


connection.close();

}


}


重要: windows上一定要配置/etc/hosts. 添加一條 192.168.50.107 rhel -------其中rhel 為 hbase機子的主機名。原因未知。

否則報錯:

Exception in thread "main" org.apache.hadoop.hbase.MasterNotRunningException: org.apache.hadoop.hbase.MasterNotRunningException: java.net.UnknownHostException: can not resolve rhel,16000,1530027948780



hbase 基本開發-插入表

相關推薦

hbase 基本開發-插入表

AS 其中 jar 0.10 window spa ogr image sse 創建maven項目pom.xml文件內容: 3個依賴包 hbase-client hadoop-hdfs jdk.tools<project xmlns="http://mave

hbase總結：插入資料的表名不存在或和建立的表名不一致

異常情況一： public static void main(String[] args) { try { QueryRunner qr = MyDbutils.getQueryRunner(); String sql = "SELECT * FROM O

HDFS的快照原理和Hbase基於快照的表修復

才會 vertical 根據 註意 efault 失敗 機制 soft hot 前一篇文章《HDFS和Hbase誤刪數據恢復》主要講了hdfs的回收站機制和Hbase的刪除策略。根據hbase的刪除策略進行hbase的數據表恢復。本文主要介紹了hdfs的快照原理和根據快照進

bootstrap-table的一些基本使用及表內編輯的實現

視圖 time lis toggle ber true 請求 cache ng- 最近工作需要接觸了bootstrap-table 所以研究了一下，並做了筆記，紅色位置要特別註意 前端主要使用了 jquery bootstrap-table bootstrap-edit

hbase 基本架構

family left 維護 增刪改 article b2c 實時監控 src 發現 （轉自：http://blog.csdn.net/woshiwanxin102213/article/details/17584043） 一、hbase 基本架構 Hbase基本組件說明

需要了解的一些基本開發知識

spf 變量的作用域 span 普通 避免 內部函數 5% stat 程序 static static修飾變量 1.static 修飾的函數和變量只有當前文件能有訪問 2.static 修飾的變量：有兩種變量存儲在靜態存儲區，全局變量和static變量。而存儲在靜態數據區的

Hbase基本語句用法

常用命令 hbase 使用hbase shell命令進入hbase：[[email protected]~]# hbase shell SLF4J: Class path contains multiple SLF4Jbindings. SLF4J: Found binding in[jar

python開發mysql:表關系&單表簡單查詢

for 查詢 comment modify tween upd price odi nbsp 一 一對多，多對一 1 1.1 建立多對一 ，一對多的關系需要註意 2 先建立被關聯的表，被關聯的字段必須保證時唯一的 3 在創建關聯的表，關聯的字

Spark訪問與HBase關聯的Hive表

刪除 sql 也會 影響 ron ble lec lang nbsp 知識點1：創建關聯Hbase的Hive表 知識點2：Spark訪問Hive 知識點3：Spark訪問與Hbase關聯的Hive表 知識點1：創建關聯Hbase的Hive表 兩種方式創建，內部表和外部表

雙向鏈表的基本運算 --線性表

image lib 前驅 col 查找 data 插入 let 指定位置 C語言實現雙向鏈表的插入、刪除、查找運算 1 #include <stdio.h> 2 #include <stdlib.h> 3 #include <

HBase流量限制和表負載均衡剖析

hba https 均衡 des 間接 ges log4j hmaster 內容 1.概述 　　在HBase-1.1.0之前，HBase集群中資源都是全量的。用戶、表這些都是沒有限制的，看似完美實則隱患較大。今天，筆者就給大家剖析一下HBase的流量限制和表的負載均衡。

mysql數據庫基本操作（表結構）

man hmm from 字符 my.cnf show blob 名詞 rst 裝包啟服務後會自動生成相關的配置文件 首次運行時會自動生成 root 初始秘密初始密碼在服務日誌文件中查找 grep -i password /var/log/mysql.log 進去mys

熟悉HBase基本操作

添加 和數 關系型 ase 數據 tab nbsp table hadoop 1. 以下關系型數據庫中的表和數據，要求將其轉換為適合於HBase存儲的表並插入數據： 學生表（Student）（不包括最後一列） 學號（S_No） 姓名（S_Name） 性別（S

聊聊Spring boot2.X開發環境搭建和基本開發

nat profile c中 ddb 被占用 bae nor 可能 占用 對Spring Boot的開發環境進行搭建，並對它的特點做進一步的了解，才能更好地對Spring Boot有更深入的介紹。但是無論如何都需要先來搭建Spring Boot的工程。搭建Spring Bo

主機管理+堡壘機系統開發：表結構設計

bsp http __str__ ipaddress color user del splay group 一、創建django項目和app web 二、主機表 1、主機表代碼： """存儲所有主機""" hostname = models.CharFi

向mysql插入表中的中文顯示為亂碼或問號的解決方法，親測有用！！

重新啟動 重新 安裝 進入 今天 ext database 技術 arc 　　今天在做ssh的博客項目時發現mysql數據庫中的中文顯示為問號，網上查閱了很多資料，都不是很全，所以我總結一下，供大家參考和自己復習。 　　1.我的計算機配置： windows系統（linux沒

HBase基本儲存原理

HBase基本儲存原理： HMaster HMaster沒有單點問題，HBase中可以啟動多個HMaster，通過Zookeeper的Master Election機制保證總有一個Master執行，HMaster在功能上主要負責Table和Region的管理工作： 1.管理使用者對Tab

無廢話--Mac OS, VS Code 搭建c/c++基本開發環境

無廢話，直接上步驟。 1） 安裝 xcode。 開啟App Store，搜尋xcode，進行下載安裝。 2）執行命令： xcode-select --install 安裝命令列工具。 3）安裝VS Code code.visualstudio.com/

三大基本排序---插入，選擇，冒泡

插入排序( 穩定排序，時間複雜度為O(n^2) ) 一堆數字，從左向右依次遍歷，從第二個元素開始，與左邊的一個元素相比較，插入合適的位置，然後繼續遍歷第三個元素，與左邊兩個元素比較並插入，然後遍歷第四個，第五個... ...，一直到整個陣列排序完成，示例圖及程式碼如下:   &nb

JDBC插入表中一個數據返回其自增主鍵

Connection connection = JDBCUtils.getConnection(); //獲取一個連結 String sql ="insert into book values (null ,?)"; //資料庫book表中只有一個id自增跟書名欄位 PreparedSta