DebugFlow 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-standard-nar

説明¶

DebugFlow プロセッサーは、タイマーまたはcronベースのスケジュールを使用している場合、 FlowFile またはタイマーイベントの受信に応答して、 FlowFile なしでさまざまなレスポンスを明示的にトリガーできるようにすることで、 FlowFile フレームワークのテストとデバッグを支援します。プロセッサーが動作する際に発生しうる様々な故障モードの演習やテストに必要な応答を強制することができます。

タグ¶

FlowFile、デバッグ、フロー、プロセッサー、テスト、ユーティリティ

入力要件¶

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
OnScheduled 休止時間	@OnScheduled メソッドで、プロセッサをスリープさせる時間を指定し、プロセッサーを強制的に長時間スタートアップできるようにします。
OnStopped 休止時間	@OnStopped メソッドでプロセッサーをスリープさせる時間を指定し、プロセッサーを強制的に長時間シャットダウンできるようにします。
OnUnscheduled 休止時間	@OnUnscheduled メソッドでプロセッサーをスリープさせる時間を指定し、ユーザーが stop をクリックしたときに、プロセッサーが反応するまでに長い時間を要するようにします。
コンテンツサイズ	FlowFile に書き込むたびに書き込むバイト数。
CustomValidate 休止時間	customValidate() メソッドでプロセッサーがスリープする時間を指定します。
@OnScheduled が呼ばれた場合に失敗	@OnScheduled でアノテーションされたメソッドが呼ばれたときに、Processor が Exception をスローするかどうかを指定します。
@OnStopped が呼ばれた場合に失敗	@OnStopped でアノテーションされたメソッドが呼ばれたときに、Processor が Exception をスローするかどうかを指定します。
@OnUnscheduled が呼ばれた場合に失敗	@OnUnscheduled でアノテーションされたメソッドが呼ばれたときに、Processor が Exception をスローするかどうかを指定します。
FlowFile 例外クラス	スローされる例外クラス (java.lang.RuntimeException を継承している必要があります)。
FlowFile 例外の反復	例外をスローする FlowFiles の数。
FlowFile 失敗の反復	障害関係に転送する FlowFiles の数。
FlowFile ロールバック・反復	(ペナルティなしで) ロールバックする FlowFiles の数。
FlowFile ロールバック・ペナルティ・反復	FlowFiles ペナルティでロールバックする数。
FlowFile ロールバック・イールド・反復	ロールバックとイールドする FlowFiles の数。
FlowFile サクセス・反復	成功関係に転送する FlowFiles の数。
休止中の割り込みを無視	Processor のスレッドが (上記の "Pause Time" プロパティのいずれかによって) スリープしているときにスレッドが割り込まれた場合、Processor が割り込みを無視してスリープを継続するか、割り込みを許可するかを示します。
FlowFile 例外クラスなし	FlowFile がない場合にスローされる例外クラス (java.lang.RuntimeException を継承している必要があります)。
FlowFile 例外反復なし	FlowFile がない場合に NPE 例外をスローする回数。
FlowFile 反復をスキップ	FlowFile がない場合に onTrigger をスキップする回数。
FlowFile イールド反復なし	FlowFile がない場合のイールドする回数。
OnTrigger 休止時間	onTrigger()メソッドでプロセッサーをスリープさせる時間を指定し、プロセッサーを強制的に長時間タスクを使用できるようにします。
反復を書き込む	FlowFile に書き込む回数。

リレーションシップ¶

名前	説明
failure	処理に失敗した FlowFiles。
success	FlowFiles は正常に処理されました。