142.4. HBase プロデューサー
前述のように、camel は HBase のプロデューサーエンドポイントを提供します。これにより、camel ルートを使用して HBase からデータを保存、削除、取得、またはクエリーできます。
hbase://table[?options]
ここで、table はテーブル名です。
サポートされている演算は次のとおりです。
- Put
- Get
- Delete
- スキャン
142.4.1. サポートされている URI オプション
HBase コンポーネントは、以下に示す 3 個のオプションをサポートしています。
名前 | 説明 | デフォルト | タイプ |
---|---|---|---|
configuration (advanced) | 共有設定を使用するには | 設定 | |
poolMaxSize (Common) | HTable プール内のテーブルごとに保持する参照の最大数。デフォルト値は 10 です。 | 10 | int |
resolveProperty Placeholders (advanced) | 起動時にコンポーネントがプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。 | true | boolean |
HBase エンドポイントは、URI 構文を使用して設定されます。
hbase:tableName
パスおよびクエリーパラメーターを使用します。
142.4.2. パスパラメーター (1 個のパラメーター):
名前 | 説明 | デフォルト | タイプ |
---|---|---|---|
tableName | 必須 テーブルの名前 | String |
142.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) | コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは 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 オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | ExceptionHandler | |
exchangePattern (consumer) | コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。 | ExchangePattern | |
maxResults (producer) | スキャンする行の最大数。 | 100 | int |
synchronous (advanced) | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるかどうかを設定します (サポートされている場合)。 | false | boolean |