public class HbaseTemplate extends HbaseAccessor implements HbaseOperations
| コンストラクターと説明 |
|---|
HbaseTemplate() |
HbaseTemplate(org.apache.hadoop.conf.Configuration configuration) |
| 修飾子と型 | メソッドと説明 |
|---|---|
org.springframework.dao.DataAccessException | convertHbaseAccessException(java.lang.Exception ex) |
void | delete(java.lang.String tableName, java.lang.String rowName, java.lang.String familyName) 指定されたテーブルとファミリ内の単一の修飾子を削除します。 |
void | delete(java.lang.String tableName, java.lang.String rowName, java.lang.String familyName, java.lang.String qualifier) 指定されたテーブル内の単一のセルを削除します。 |
<T> T | execute(java.lang.String tableName, TableCallback<T> action) 指定されたテーブル処理リソース管理に対して指定されたアクションを実行します。 |
<T> T | find(java.lang.String tableName, org.apache.hadoop.hbase.client.Scan scan, ResultsExtractor<T> action) 指定された Scan オブジェクトを使用してターゲットテーブルをスキャンします。 |
<T> java.util.List<T> | find(java.lang.String tableName, org.apache.hadoop.hbase.client.Scan scan, RowMapper<T> action) 指定された Scan オブジェクトを使用してターゲットテーブルをスキャンします。 |
<T> T | find(java.lang.String tableName, java.lang.String family, ResultsExtractor<T> action) 指定されたファミリを使用して、ターゲットテーブルをスキャンします。 |
<T> java.util.List<T> | find(java.lang.String tableName, java.lang.String family, RowMapper<T> action) 指定された列ファミリを使用して、ターゲットテーブルをスキャンします。 |
<T> T | find(java.lang.String tableName, java.lang.String family, java.lang.String qualifier, ResultsExtractor<T> action) 指定された列ファミリと修飾子を使用して、ターゲットテーブルをスキャンします。 |
<T> java.util.List<T> | find(java.lang.String tableName, java.lang.String family, java.lang.String qualifier, RowMapper<T> action) 指定された列ファミリを使用して、ターゲットテーブルをスキャンします。 |
<T> T | get(java.lang.String tableName, java.lang.String rowName, RowMapper<T> mapper) 指定されたテーブルから個々の行を取得します。 |
<T> T | get(java.lang.String tableName, java.lang.String rowName, java.lang.String familyName, RowMapper<T> mapper) 指定されたテーブルから個々の行を取得します。 |
<T> T | get(java.lang.String tableName, java.lang.String rowName, java.lang.String familyName, java.lang.String qualifier, RowMapper<T> mapper) 指定されたテーブルから個々の行を取得します。 |
void | put(java.lang.String tableName, java.lang.String rowName, java.lang.String familyName, java.lang.String qualifier, byte[] value) 指定されたテーブルに単一の値を入力します。 |
void | setAutoFlush(boolean autoFlush) 自動フラッシュを設定します。 |
afterPropertiesSet, getCharset, getConfiguration, getTableFactory, setConfiguration, setEncoding, setTableFactorypublic HbaseTemplate()
public HbaseTemplate(org.apache.hadoop.conf.Configuration configuration)
public <T> T execute(java.lang.String tableName,
TableCallback<T> action)HbaseOperationsアクションオブジェクトによってスローされたアプリケーション例外は、呼び出し元に伝播されます (チェック解除のみ可能)。結果オブジェクト (通常はドメインオブジェクトまたはドメインオブジェクトのコレクション) を返すことができます。
HbaseOperations 内の execute T - アクションタイプ tableName - ターゲットテーブル action - アクションを指定するコールバックオブジェクト public org.springframework.dao.DataAccessException convertHbaseAccessException(java.lang.Exception ex)
public <T> T find(java.lang.String tableName,
java.lang.String family,
ResultsExtractor<T> action)HbaseOperationsHbaseOperations 内の find T - アクションタイプ tableName - ターゲットテーブル family - 列ファミリー action - スキャナの結果を処理するアクション public <T> T find(java.lang.String tableName,
java.lang.String family,
java.lang.String qualifier,
ResultsExtractor<T> action)HbaseOperationsHbaseOperations 内の find T - アクションタイプ tableName - ターゲットテーブル family - 列ファミリー qualifier - 列修飾子 action - スキャナの結果を処理するアクション public <T> T find(java.lang.String tableName,
org.apache.hadoop.hbase.client.Scan scan,
ResultsExtractor<T> action)HbaseOperationsScan オブジェクトを使用してターゲットテーブルをスキャンします。スキャンプロセスを最大限に制御するのに適しています。コンテンツは指定されたアクションによって処理され、通常はドメインオブジェクトまたはドメインオブジェクトのコレクションが返されます。HbaseOperations 内の find T - アクションタイプ tableName - ターゲットテーブル scan - テーブルスキャナ action - スキャナの結果を処理するアクション public <T> java.util.List<T> find(java.lang.String tableName,
java.lang.String family,
RowMapper<T> action)HbaseOperationsHbaseOperations 内の find T - アクションタイプ tableName - ターゲットテーブル family - 列ファミリー action - スキャナの結果を処理する行マッパー public <T> java.util.List<T> find(java.lang.String tableName,
java.lang.String family,
java.lang.String qualifier,
RowMapper<T> action)HbaseOperationsHbaseOperations 内の find T - アクションタイプ tableName - ターゲットテーブル family - 列ファミリー qualifier - 列修飾子 action - スキャナの結果を処理する行マッパー public <T> java.util.List<T> find(java.lang.String tableName,
org.apache.hadoop.hbase.client.Scan scan,
RowMapper<T> action)HbaseOperationsScan オブジェクトを使用してターゲットテーブルをスキャンします。スキャンプロセスを最大限に制御するのに適しています。コンテンツは指定されたアクションによって行ごとに処理され、ドメインオブジェクトのリストが返されます。HbaseOperations 内の find T - アクションタイプ tableName - ターゲットテーブル scan - テーブルスキャナ action - スキャナの結果を処理する行マッパー public <T> T get(java.lang.String tableName,
java.lang.String rowName,
RowMapper<T> mapper)HbaseOperationsHbaseOperations 内の get T - マッパー型 tableName - ターゲットテーブル rowName - 行名 mapper - 行マッパー public <T> T get(java.lang.String tableName,
java.lang.String rowName,
java.lang.String familyName,
RowMapper<T> mapper)HbaseOperationsHbaseOperations 内の get T - マッパー型 tableName - ターゲットテーブル rowName - 行名 familyName - 列ファミリー mapper - 行マッパー public <T> T get(java.lang.String tableName,
java.lang.String rowName,
java.lang.String familyName,
java.lang.String qualifier,
RowMapper<T> mapper)HbaseOperationsHbaseOperations 内の get T - マッパー型 tableName - ターゲットテーブル rowName - 行名 familyName - 家族 qualifier - 列修飾子 mapper - 行マッパー public void put(java.lang.String tableName,
java.lang.String rowName,
java.lang.String familyName,
java.lang.String qualifier,
byte[] value)HbaseOperationsHbaseOperations 内の put tableName - ターゲットテーブル rowName - 行名 familyName - 家族 qualifier - 列修飾子 value - 格納するデータ値のバイト配列 public void delete(java.lang.String tableName,
java.lang.String rowName,
java.lang.String familyName)HbaseOperationsHbaseOperations 内の delete tableName - ターゲットテーブル rowName - 行名 familyName - 家族 public void delete(java.lang.String tableName,
java.lang.String rowName,
java.lang.String familyName,
java.lang.String qualifier)HbaseOperationsHbaseOperations 内の delete tableName - ターゲットテーブル rowName - 行名 familyName - 家族 qualifier - 列修飾子 public void setAutoFlush(boolean autoFlush)
autoFlush - 設定する autoFlush。