HBase-クライアントAPI
この章では、実行に使用されるHBase用のJavaクライアントAPIについて説明します。 CRUDHBaseテーブルでの操作。HBaseはJavaで記述されており、Java NativeAPIを備えています。したがって、データ操作言語(DML)へのプログラムによるアクセスを提供します。
クラスHBase構成
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() このインスタンスで使用されるConfigurationオブジェクトを返します。 |
6 | TableName getName() このテーブルのテーブル名インスタンスを返します。 |
7 | HTableDescriptor getTableDescriptor() このテーブルのテーブル記述子を返します。 |
8 | byte[] getTableName() このテーブルの名前を返します。 |
9 | void put(Put put) この方法を使用すると、テーブルにデータを挿入できます。 |
クラスプット
このクラスは、単一行のPut操作を実行するために使用されます。それはに属しますorg.apache.hadoop.hbase.client パッケージ。
コンストラクター
S.No. | コンストラクターと説明 |
---|---|
1 | Put(byte[] row) このコンストラクターを使用して、指定した行のPut操作を作成できます。 |
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操作を実行するために使用されます。このクラスはに属します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オブジェクトをインスタンス化します。このクラスはに属しますorg.apache.hadoop.hbase.client パッケージ。
コンストラクタ
S.No. | コンストラクターと説明 |
---|---|
1 | Delete(byte[] row) 指定された行の削除操作を作成します。 |
2 | Delete(byte[] rowArray, int rowOffset, int rowLength) 指定された行とタイムスタンプの削除操作を作成します。 |
3 | Delete(byte[] rowArray, int rowOffset, int rowLength, long ts) 指定された行とタイムスタンプの削除操作を作成します。 |
4 | Delete(byte[] row, long timestamp) 指定された行とタイムスタンプの削除操作を作成します。 |
メソッド
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) 指定されたタイムスタンプ以下のタイムスタンプを持つ指定されたファミリのすべての列を削除します。 |
クラス結果
このクラスは、GetクエリまたはScanクエリの単一行の結果を取得するために使用されます。
コンストラクター
S.No. | コンストラクター |
---|---|
1 | Result() このコンストラクターを使用すると、KeyValueペイロードのない空の結果を作成できます。raw Cells()を呼び出すとnullを返します。 |
メソッド
S.No. | メソッドと説明 |
---|---|
1 | byte[] getValue(byte[] family, byte[] qualifier) このメソッドは、指定された列の最新バージョンを取得するために使用されます。 |
2 | byte[] getRow() このメソッドは、この結果が作成された行に対応する行キーを取得するために使用されます。 |