HBase教學 » HBase用戶端API

HBase用戶端API

本章介紹用於對HBase表上執行CRUD操作的HBase Java用戶端API。 HBase是用Java編寫的，並具有Java原生API。因此，它提供了程式設計存取資料操縱語言(DML)。

HBaseConfiguration類

新增 HBase 的組態到組態檔案。這個類屬於org.apache.hadoop.hbase包。

方法及說明

S.No. 方法及說明
1

static org.apache.hadoop.conf.Configuration create()

此方法建立使用HBase的資源組態

HTable類

HTable表示HBase表中HBase的內部類。它用於實現單個HBase表進行通訊。這個類屬於org.apache.hadoop.hbase.client類。

建構函式

S.No. 建構函式
1

HTable()
2

HTable(TableName tableName, ClusterConnection connection, ExecutorService pool)

使用此構造方法，可以建立一個物件來存取HBase表。

方法及說明

S.No. 建構函式
1

void close()

釋放HTable的所有資源
2

void delete(Delete delete)

刪除指定的單元格/行
3

boolean exists(Get get)

使用這個方法，可以測試列的存在，在表中，由Get指定獲取。
4

Result get(Get get)

檢索來自一個給定的行某些單元格。
5

org.apache.hadoop.conf.Configuration getConfiguration()

返回此範例的組態物件。
6

TableName getName()

返回此表的表名稱範例。
7

HTableDescriptor getTableDescriptor()

返回此表的表描述符。
8

byte[] getTableName()

返回此表的名稱。
9

void put(Put put)

使用此方法，可以將資料插入到表中。

Put類

此類用於為單個行執行PUT操作。它屬於org.apache.hadoop.hbase.client包。

建構函式

S.No. 建構函式和描述
1

Put(byte[] row)

使用此構造方法，可以建立一個將操作指定行。
2

Put(byte[] rowArray, int rowOffset, int rowLength)

使用此構造方法，可以使傳入的行鍵的副本，以保持到本地。
3

Put(byte[] rowArray, int rowOffset, int rowLength, long ts)

使用此構造方法，可以使傳入的行鍵的副本，以保持到本地。
4

Put(byte[] row, long ts)

使用此構造方法，我們可以建立一個Put操作指定行，用一個給定的時間戳。

方法

S.No. 方法及描述
1

Put add(byte[] family, byte[] qualifier, byte[] value)

新增指定的列和值到 Put 操作。
2

Put add(byte[] family, byte[] qualifier, long ts, byte[] value)

新增指定的列和值，使用指定的時間戳作為其版本到Put操作。
3

Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value)

新增指定的列和值，使用指定的時間戳作為其版本到Put操作。
4

Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value)

新增指定的列和值，使用指定的時間戳作為其版本到Put操作。

Get類

此類用於對單行執行get操作。這個類屬於org.apache.hadoop.hbase.client包。

建構函式

S.No. 建構函式和描述
1

Get(byte[] row)

使用此構造方法，可以為指定行建立一個Get操作。
2 Get(Get get)

方法

S.No. 建構函式和描述
1

Get addColumn(byte[] family, byte[] qualifier)

檢索來自特定列家族使用指定限定符
2

Get addFamily(byte[] family)

檢索從指定系列中的所有列。

Delete類

這個類用於對單行執行刪除操作。要刪除整行，範例化一個Delete物件用於刪除行。這個類屬於org.apache.hadoop.hbase.client包。

建構函式

S.No. 構造方法和描述
1

Delete(byte[] row)

建立一個指定行的Delete操作。
2

Delete(byte[] rowArray, int rowOffset, int rowLength)

建立一個指定行和時間戳的Delete操作。
3

Delete(byte[] rowArray, int rowOffset, int rowLength, long ts)

建立一個指定行和時間戳的Delete操作。
4

Delete(byte[] row, long timestamp)

建立一個指定行和時間戳的Delete操作。

方法

S.No. 構造方法和描述
1

Delete addColumn(byte[] family, byte[] qualifier)

刪除指定列的最新版本。
2

Delete addColumns(byte[] family, byte[] qualifier, long timestamp)

刪除所有版本具有時間戳小於或等於指定的時間戳的指定列。
3

Delete addFamily(byte[] family)

刪除指定的所有列族的所有版本。
4

Delete addFamily(byte[] family, long timestamp)

刪除指定列具有時間戳小於或等於指定的時間戳的列族。

Result類

這個類是用來獲取Get或掃描查詢的單行結果。

建構函式

S.No. 建構函式
1

Result()

使用此構造方法，可以建立無Key Value的有效負載空的結果;如果呼叫Cells()返回null。

方法

S.No. 方法及描述
1

byte[] getValue(byte[] family, byte[] qualifier)

此方法用於獲取指定列的最新版本
2

byte[] getRow()

此方法用於檢索對應於從結果中建立行的行鍵。