144.2. オプション

hostName

使用するために 必要な HDFS ホスト

String

port

使用する HDFS ポート

8020

int

path

必須 使用するディレクトリーパス

String

connectOnStartup (common)

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

true

boolean

fileSystemType (common)

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

HDFS

HdfsFileSystemType

fileType (common)

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

NORMAL_FILE

HdfsFileType

keyType (common)

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

NULL

WritableType

owner (common)

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

String

valueType (common)

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

BYTES

WritableType

bridgeErrorHandler (consumer)

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

false

boolean

delay (consumer)

ディレクトリースキャンの間隔 (ミリ秒)。

1000

long

initialDelay (consumer)

コンシューマーの場合、ディレクトリーのスキャンを開始するまでに待機する時間 (ミリ秒)。

long

pattern (consumer)

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

*

String

sendEmptyMessageWhenIdle (consumer)

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

false

boolean

exceptionHandler (consumer)

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

ExceptionHandler

exchangePattern (consumer)

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

ExchangePattern

pollStrategy (consumer)

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

PollingConsumerPoll Strategy

append (producer)

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

false

boolean

overwrite (producer)

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

true

boolean

blockSize (advanced)

HDFS ブロックのサイズ

67108864

long

bufferSize (advanced)

HDFS が使用するバッファーサイズ

4096

int

checkIdleInterval (advanced)

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

500

int

chunkSize (advanced)

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

4096

int

compressionCodec (advanced)

使用する圧縮コーデック

DEFAULT

HdfsCompressionCodec

compressionType (advanced)

使用する圧縮タイプ (デフォルトでは使用されていません)

NONE

CompressionType

openedSuffix (advanced)

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

opened

String

readSuffix (advanced)

ファイルが読み取られると、この接尾辞を使用して名前が変更され、再度読み取られることがなくなります。

read

String

replication (advanced)

HDFS レプリケーション係数

3

short

splitStrategy (advanced)

現在のバージョンの Hadoop では、ファイルを追加モードで開くことは信頼性が低いため無効になっています。そのため、現時点では、新しいファイルを作成することしかできません。Camel HDFS エンドポイントは、この問題を次のように解決しようとします。分割戦略オプションが定義されている場合、hdfs パスがディレクトリーとして使用され、設定された UuidGenerator を使用してファイルが作成されます。分割条件が満たされるたびに、新しいファイルが作成されます。splitStrategy オプションは、構文の文字列 splitStrategy=ST:value,ST:value として定義されます。ここで、ST は次のいずれかになります: BYTES: 書き込まれたバイト数が値を超えると、新しいファイルが作成され、古いファイルは閉じられます。MESSAGES: 書き込まれたメッセージ数が value を超えると、新しいファイルが作成され、古いファイルは閉じられます。IDLE: 最後の value ミリ秒間に書き込みが行われなかった場合、新しいファイルが作成され、古いファイルは閉じられます。

String

synchronous (advanced)

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

false

boolean

backoffErrorThreshold (scheduler)

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

int

backoffIdleThreshold (scheduler)

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

int

backoffMultiplier (scheduler)

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

int

greedy (scheduler)

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

false

boolean

runLoggingLevel (scheduler)

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

TRACE

LoggingLevel

scheduledExecutorService (scheduler)

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

ScheduledExecutor Service

scheduler (scheduler)

camel-spring または camel-quartz2 コンポーネントから cron スケジューラーを使用します。

none

ScheduledPollConsumer Scheduler

schedulerProperties (scheduler)

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

Map

startScheduler (scheduler)

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

true

boolean

timeUnit (scheduler)

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

MILLISECONDS

TimeUnit

useFixedDelay (scheduler)

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

true

boolean