136.2.2. クエリーパラメーター（38 パラメーター）:

connectOnStartup (common)

プロデューサー/コンシューマーの開始時に HDFS ファイルシステムに接続するかどうか。false の場合、接続はオンデマンドで作成されます。45 x 20 秒の再配信がハードコーディングされているため、で接続を確立するのに最大 15 分かかることがあります。このオプションを false に設定すると、アプリケーションの起動が可能になり、最大 15 分間ブロックされません。

true

boolean

fileSystemType (common)

代わりに HDFS を使用せず、ローカルの java.io.File を使用しない場合は、LOCAL に設定します。

HDFS

HdfsFileSystemType

fileType (common)

使用するファイルタイプ。詳細は、さまざまなファイルタイプについてのドキュメントを参照してください。

NORMAL_FILE

HdfsFileType

keyType (common)

シーケンスファイルまたはマップファイルの場合のキーのタイプ。

NULL

WritableType

owner (common)

ファイルの所有者は、コンシューマーがファイルを取得するには、この所有者と一致する必要があります。そうでない場合は、ファイルはスキップされます。

文字列

valueType (common)

シーケンスファイルまたはマップファイルの場合のキーのタイプ

BYTES

WritableType

bridgeErrorHandler (consumer)

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

false

boolean

パターン （コンシューマー）

ディレクトリーのスキャンに使用されるパターン

*

文字列

sendEmptyMessageWhenIdle (consumer)

ポーリングコンシューマーがファイルをポーリングしなかった場合、このオプションを有効にして、代わりに空のメッセージ (ボディーなし) を送信できます。

false

boolean

exceptionHandler (consumer)

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

ExceptionHandler

exchangePattern (consumer)

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

ExchangePattern

pollStrategy (consumer)

プラグ可能な org.apache.camel.PollingConsumerPollingStrategy を使用すると、エクスチェンジが作成され、Camel でルーティングされる前に、通常はポーリング操作中に発生するエラー処理を制御するカスタム実装が提供できます。

PollingConsumerPoll Strategy

append （プロデューサー）

既存ファイルに追加します。すべての HDFS ファイルシステムが append オプションをサポートしているわけではないことに注意してください。

false

boolean

上書き （プロデューサー）

同じ名前の既存ファイルを上書きするかどうか。

true

boolean

Blocksize （詳細）

HDFS ブロックのサイズ

67108864

Long

bufferSize (advanced)

HDFS によって使用されるバッファーサイズ

4096

int

checkIdleInterval (advanced)

アイドルチェッカーのバックグラウンドタスクを実行する頻度（ミリ秒単位）。このオプションは、Splitter ストラテジーが IDLE の場合にのみ使用されます。

500

int

chunkSize (advanced)

通常ファイルを読み取ると、チャンクごとにメッセージを生成するチャンクに分割されます。

4096

int

compressionCodec (advanced)

使用する圧縮コーデック

DEFAULT

HdfsCompressionCodec

compressionType (advanced)

使用する圧縮タイプ（デフォルトは使用されていない）。

NONE

CompressionType

openedSuffix (advanced)

ファイルを読み取り/書き込み用に開くと、書き込みフェーズでファイルを読み込まないように、この接尾辞が付いたファイルの名前が変更されます。

開く

文字列

readSuffix (advanced)

ファイルが読み取られると、再度読み取られないように、この接尾辞が付いたファイルの名前が変更されます。

read

文字列

レプリケーション （詳細）

HDFS レプリケーションファクター

3

short

splitStrategy (advanced)

現在のバージョンでは、追加モードでファイルを開くことは、非常に信頼性がないために無効にされます。したがって、現時点では新しいファイルの作成のみが可能です。Camel HDFS エンドポイントは、この問題を解決しようとします。スプリットストラテジーオプションが定義されている場合、hdfs パスはディレクトリーとして使用され、設定済みの UuidGenerator を使用してファイルが作成されます。分割条件が満たされるたびに、新しいファイルが作成されます。splitStrategy オプションは、SplitStrategy=ST:value,ST:value…​ という構文で文字列として定義されます。ここで、splitStrategy=ST:value,ST:value,…​

文字列

同期 （詳細）

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

false

boolean

backoffErrorThreshold (scheduler)

backoffMultipler が開始する前に発生する必要がある後続のエラーポーリング (エラーによって失敗した) の数。

int

backoffIdleThreshold (scheduler)

backoffMultipler が開始する前に発生する必要がある後続のアイドルポーリングの数。

int

backoffMultiplier (scheduler)

後続のアイドル状態/エラーが連続して発生した場合に、スケジュールされたポーリングコンシューマーのバックオフを許可します。乗数は、実際に次の試行が行われる前にスキップされるポーリングの数です。このオプションが使用されている場合は、backoffIdleThreshold や backoffErrorThreshold も設定する必要があります。

int

遅延 （スケジューラー）

次のポーリングまでの時間 (ミリ秒単位)。また、60 秒（60 秒）、5m30s（5 分と 30 秒）、および 1h（1 時間）などの単位を使用して時間の値を指定することもできます。

500

Long

greedy (scheduler)

greedy が有効で、以前の実行が 1 つ以上のメッセージをポーリングした場合、ScheduledPollConsumer は即座に再度実行されます。

false

boolean

initialDelay (scheduler)

最初のポーリングが開始されるまでの時間 (ミリ秒単位)。また、60 秒（60 秒）、5m30s（5 分と 30 秒）、および 1h（1 時間）などの単位を使用して時間の値を指定することもできます。

1000

Long

runLoggingLevel (scheduler)

コンシューマーはポーリング時に開始/完了のログ行を記録します。このオプションを使用すると、ログレベルを設定できます。

TRACE

LoggingLevel

scheduledExecutorService (scheduler)

コンシューマーに使用するカスタム/共有スレッドプールを設定できます。デフォルトでは、各コンシューマーに独自の単一スレッドのスレッドプールがあります。

ScheduledExecutor Service

scheduler (scheduler)

camel-spring または camel-quartz2 コンポーネントからの cron スケジューラーを使用するには、以下を実行します。

none

ScheduledPollConsumer Scheduler

schedulerProperties (scheduler)

カスタムスケジューラーまたは Quartz2、Spring ベースのスケジューラーを使用する場合に追加のプロパティーを設定します。

マップ

startScheduler (scheduler)

スケジューラーを自動起動するかどうか。

true

boolean

timeUnit (scheduler)

initialDelay および delay オプションの時間単位。

ミリ秒

TimeUnit

useFixedDelay (scheduler)

固定遅延または固定レートを使用するかどうかを制御します。詳細は、JDK の ScheduledExecutorService を参照してください。

true

boolean