検索

143.4. HBase プロデューサー

download PDF

前述のように、camel は HBase のプロデューサーエンドポイントを提供します。これにより、camel ルートを使用して HBase からデータを保存、削除、取得、またはクエリーできます。

hbase://table[?options]

ここで、table はテーブル名です。

サポートされている演算は次のとおりです。

  • Put
  • Get
  • Delete
  • スキャン

143.4.1. サポートされている URI オプション

HBase コンポーネントは、以下に示す 3 個のオプションをサポートしています。

名前説明デフォルトタイプ

configuration (advanced)

共有設定を使用するには

 

設定

poolMaxSize (Common)

HTable プール内のテーブルごとに保持する参照の最大数。デフォルト値は 10 です。

10

int

resolveProperty Placeholders (advanced)

起動時にコンポーネントがプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。

true

boolean

HBase エンドポイントは、URI 構文を使用して設定されます。

hbase:tableName

パスおよびクエリーパラメーターを使用します。

143.4.2. パスパラメーター (1 個のパラメーター):

名前説明デフォルトタイプ

tableName

必須 テーブルの名前

 

String

143.4.3. クエリーパラメーター (16 個のパラメーター):

名前説明デフォルトタイプ

cellMappingStrategyFactory (common)

セルのマッピングを担当するカスタム CellMappingStrategyFactory を使用する場合。

 

CellMappingStrategy ファクトリー

filters (common)

使用するフィルターのリスト。

 

List

mappingStrategyClassName (common)

カスタムマッピング戦略の実装のクラス名。

 

String

mappingStrategyName (common)

Camel メッセージを HBase 列にマッピングするために使用するストラテジー。サポートされている値: ヘッダーまたはボディー。

 

String

rowMapping (common)

キー/値を Map から HBaseRow にマップします。次のキーがサポートされています: rowId - 行の ID。行は通常、エクスチェンジごとに変更されるため、これは使用が制限されています。rowType - 行 ID を変換するタイプ。サポートされている操作: CamelHBaseScan。family - 列ファミリー。複数の列を参照するための数値接尾辞をサポートします。qualifier - 列修飾子。複数の列を参照するための数値接尾辞をサポートします。値 - 値。複数の列を参照するための数値接尾辞をサポートします。valueType - 値の型。複数の列を参照するための数値接尾辞をサポートします。サポートされている操作: CamelHBaseGet、および CamelHBaseScan。

 

Map

rowModel (common)

各行をモデル化する方法を記述する org.apache.camel.component.hbase.model.HBaseRow のインスタンス

 

HBaseRow

userGroupInformation (common)

kerberos の使用など、HBase と通信するための特権を定義します。

 

UserGroupInformation

bridgeErrorHandler (consumer)

consumer の Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、consumer が受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、consumer は org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

false

boolean

maxMessagesPerPoll (consumer)

各ポーリングのポーリング制限としてメッセージの最大数を取得します。デフォルトは無制限ですが、0 または負の数を使用して無制限として無効にします。

 

int

operation (consumer)

実行する HBase 操作

 

String

remove (consumer)

オプションが true の場合、Camel HBase コンシューマーは処理する行を削除します。

true

boolean

removeHandler (consumer)

行が削除されるときに実行されるカスタム HBaseRemoveHandler を使用するには。

 

HBaseRemoveHandler

exceptionHandler (consumer)

コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、consumer は例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

 

ExceptionHandler

exchangePattern (consumer)

コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。

 

ExchangePattern

maxResults (producer)

スキャンする行の最大数。

100

int

synchronous (advanced)

同期処理を厳密に使用するか、Camel が非同期処理を使用できるかどうかを設定します (サポートされている場合)。

false

boolean

Red Hat logoGithubRedditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

© 2024 Red Hat, Inc.