@see 67.1.1. API as of HBase 1.0.0
@see 67.1.1. API as of HBase 1.0.0_detail

網(wǎng)站建設(shè)哪家好，找創(chuàng)新互聯(lián)公司！專注于網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、微信小程序、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了哈巴河免費(fèi)建站歡迎大家使用！

It’s been cleaned up and users are returned Interfaces to work against rather than particular types.
In HBase 1.0, obtain a Connection object from ConnectionFactory and thereafter, get from it instances of Table, Admin, and RegionLocator on an as-need basis.
When done, close the obtained instances.

舊的API已被清理，用戶使用接口，而不是特定的類來(lái)操作API。
在HBase 1.0中，從_ConnectionFactory獲取一個(gè)Connection對(duì)象，然后根據(jù)需要從Table，Admin 和 RegionLocator_中獲取實(shí)例。完成后關(guān)閉。

Finally, be sure to cleanup your Connection instance before exiting.
Connections are heavyweight objects but thread-safe so you can create one for your application and keep the instance around.

最后，確保在退出之前 清理Connection 實(shí)例。
Connection 是 重量級(jí)的對(duì)象，但線程安全，所以你可以為你的應(yīng)用程序創(chuàng)建一個(gè)，并保持實(shí)例。

Table, Admin and RegionLocator instances are lightweight.
Create as you go and then let go as soon as you are done by closing them.
See the Client Package Javadoc Description for example usage of the new HBase 1.0 API.

Table，Admin 和 RegionLocator 實(shí)例是 輕量級(jí)的。
隨時(shí)創(chuàng)建，然后一旦完成就放手關(guān)閉它們。
查看客戶端軟件包Javadoc說(shuō)明，了解新的HBase 1.0 API的使用范例。

To administer HBase, create and drop tables, list and alter tables, use Admin.
Once created, table access is via an instance of Table.
You add content to a table a row at a time.

要管理HBase，create和delete表，list和alter表，請(qǐng)使用 Admin(DDL)。
表一旦創(chuàng)建，訪問(wèn)表： Table(DML)實(shí)例。
一次將加入一行內(nèi)容添加到表。

To insert, create an instance of a Put object.
Specify value, target column and optionally a timestamp.
Commit your update using Table.put(Put).

要插入，創(chuàng)建一個(gè)Put對(duì)象的實(shí)例。指定值、目標(biāo)列、可選時(shí)間戳。
使用 _Table.put(Put)_提交更新。

To fetch your inserted value, use Get.
The Get can be specified to be broad -- get all on a particular row -- or narrow; i.e. return only a single cell value.
After creating an instance of Get, invoke Table.get(Get).

要獲取您插入的值，請(qǐng)使用Get。
Get可以被指定為寬泛的 - 獲取一個(gè)行的所有內(nèi)容 - 或可以縮小內(nèi)容范圍;
即只返回一個(gè)單元值。創(chuàng)建一個(gè)Get的實(shí)例后，調(diào)用 Table.get(Get)。

Use Scan to set up a scanner -- a Cursor- like access.
After creating and configuring your Scan instance, call Table.getScanner(Scan) and then invoke next on the returned object.
Both Table.get(Get) and Table.getScanner(Scan) return a Result.

使用Scan 設(shè)置Scanner - 類似游標(biāo)的訪問(wèn)。
創(chuàng)建并配置Scan實(shí)例后，調(diào)用 Table.getScanner（Scan），然后在返回的對(duì)象上調(diào)用next。
_Table.get（Get）和 Table.getScanner（Scan） 都返回 Result_。

Use Delete to remove content.
You can remove individual cells or entire families, etc.
Pass it to Table.delete(Delete) to execute.

使用 Delete 刪除內(nèi)容。
你可以刪除獨(dú)個(gè)單元格或整個(gè)列族.
將 Delete 傳遞給 Table.delete（Delete） 來(lái)執(zhí)行。

Puts, Gets and Deletes take out a lock on the target row for the duration of their operation.
Concurrent modifications to a single row are serialized.
Gets and scans run concurrently without interference of the row locks and are guaranteed to not to return half written rows.

Put、Get 和 Delete，會(huì)在操作期間對(duì)目標(biāo)行取到 鎖。
并行修改某一行是序列化的(一個(gè)一個(gè)來(lái))。
Get 和 Scan 并發(fā)運(yùn)行 沒(méi)有鎖的干擾，并保證不返回一半的數(shù)據(jù)(返回半行數(shù)據(jù)就尷尬了)。

Client code accessing a cluster finds the cluster by querying ZooKeeper.
This means that the ZooKeeper quorum to use must be on the client CLASSPATH.
Usually this means make sure the client can find your hbase-site.xml.

訪問(wèn)群集的客戶端代碼通過(guò)查詢ZooKeeper來(lái)查找群集。
這意味著要使用的ZooKeeper仲裁必須位于客戶端CLASSPATH上。
通常這意味著確?？蛻舳丝梢哉业侥愕膆base-site.xml。

package com.niewj.util;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
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.Get;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;

// Put, Get ,Scan 針對(duì)一個(gè)hbase表.  API 基于HBase 1.0.
public class MyLittleHBaseClient {
    public static void main(String[] args) throws IOException {

        // 庫(kù)里已經(jīng)有，可以通過(guò)hbase shell 創(chuàng)建：create 'zoo_htable_1', 'cf1'
        String tableNameString = "zoo_htable_1"; 

        Configuration config = HBaseConfiguration.create();

        // 從zk配置加載hbase信息
        config.set("hbase.zookeeper.quorum", "master.14.niewj.spark,slave1.146.niewj.spark,slave2.207.niewj.spark");
        config.set("hbase.zookeeper.property.clientPort", "2181");
        config.set("zookeeper.znode.parent", "/hbase");

        // 1. 接下來(lái)，您需要連接到群集。 創(chuàng)建一個(gè)。 當(dāng)它完成后， 關(guān)閉它。
        // 2. try / finally是確保它被關(guān)閉的一個(gè)好方法(或使用jdk7，try-with-resources)
        // 3. Connection是重量級(jí)的。創(chuàng)建一個(gè)并保持它。
        // 4. 從Connection中，可取Table實(shí)例以訪問(wèn)Tables，管理集群的Admin實(shí)例以及RegionLocator，以查找集群上的區(qū)域。
        // 5. 與Connections相反，Table，Admin和RegionLocator實(shí)例是輕量級(jí)的; 根據(jù)需要?jiǎng)?chuàng)建，然后在完成后關(guān)閉。
        Connection connection = ConnectionFactory.createConnection(config);
        try {

            // 1. 下面實(shí)例化一個(gè)Table對(duì)象，它將您連接到“zoo_htable_1”表（TableName.valueOf將String轉(zhuǎn)換為TableName實(shí)例）。
            // 2. 當(dāng)它完成后，關(guān)閉它（應(yīng)該開始一個(gè)嘗試/終于在這個(gè)創(chuàng)建后，所以它被關(guān)閉的肯定
            Table table = connection.getTable(TableName.valueOf(tableNameString));
            try {

                // 1. 要添加到行中，請(qǐng)使用Put。 Put構(gòu)造函數(shù)將要插入的行的名稱作為字節(jié)數(shù)組。
                // 在HBase中，Bytes類具有將各種java類型轉(zhuǎn)換為字節(jié)數(shù)組的實(shí)用工具。
                // 在下面，我們將字符串“myLittleRow”轉(zhuǎn)換成一個(gè)字節(jié)數(shù)組作為我們更新的rowkey。
                // 一旦你有了一個(gè)Put實(shí)例，你可以設(shè)置行上更新的column的名稱，使用的時(shí)間戳等: 如果沒(méi)有時(shí)間戳，服務(wù)器將當(dāng)前時(shí)間用于編輯。
                Put p = new Put(Bytes.toBytes("rk_100001"));

                // 在“rk_100001”行設(shè)置要更新的值，請(qǐng)指定單元格的列族、列名和值。
                // 該列族必須已經(jīng)存在。列明可以是任何東西。 所有值必須為字節(jié)數(shù)組，因?yàn)閔base全部是關(guān)于字節(jié)數(shù)組的。
                // 讓我們假裝表myLittleHBaseTable是用 cf1 系列創(chuàng)建的
                p.addColumn(Bytes.toBytes("cf1"), Bytes.toBytes("uname"), Bytes.toBytes("喬布斯"));

                // 所有更新在Put實(shí)例中，提交它使用 HTable#put 推送到hbase
                table.put(p);

                // 現(xiàn)在，檢索剛剛寫入的數(shù)據(jù)。 返回的值是Result實(shí)例。 結(jié)果是一個(gè)hbase返回最可口形式的對(duì)象
                Get g = new Get(Bytes.toBytes("rk_100001"));
                Result r = table.get(g);
                byte[] value = r.getValue(Bytes.toBytes("cf1"), Bytes.toBytes("uname"));

                // 將字節(jié)值轉(zhuǎn)換，返回插入的實(shí)際值
                String valueStr = Bytes.toString(value);
                System.out.println("\t GET: " + valueStr);

                // 有時(shí)候，你不知道你要找的那一行. 在本例中，您使用了一個(gè)Scanner。為表內(nèi)容提供類似指針的接口。 設(shè)置 Scanner, 就像組裝 Put 和 Get一樣創(chuàng)建一個(gè)Scan. 用column names裝飾.
                Scan s = new Scan();
                s.addColumn(Bytes.toBytes("cf1"), Bytes.toBytes("uname"));
                ResultScanner scanner = table.getScanner(s);
                try {
                    // Scanners 返回 Result 實(shí)例. 迭代結(jié)果方法一：
                    for (Result result = scanner.next(); result != null; result = scanner.next()) {
                        // 打印出查得的 columns內(nèi)容
                        System.out.println("Found row: " + result);
                    }

                    // 另一種方法是使用foreach循環(huán)。scanner是iterable
                    // for (Result rr : scanner) {
                    //   System.out.println("Found row: " + rr);
                    // }
                } finally {
                    // 確保使用完后關(guān)閉 scanners! 所以放入finally:
                    scanner.close();
                }

                // 關(guān)閉table、關(guān)閉connection
            } finally {
                if (table != null) {
                    table.close();
                }
            }
        } finally {
            connection.close();
        }
    }
}