Gradleによるフローの実行
準備
以下が必要です。
- Java SE JDK 8以降
- MarkLogicサーバー(「バージョン互換性」を参照してください)
- Gradle 4.6以降
手順
- コマンドラインウィンドウを開き、プロジェクトのルートディレクトリに移動します。
- プロジェクトのルートで、GradleタスクhubRunFlowを実行します。
./gradlew hubRunFlow -PflowName=YourFlowName -PentityName=YourEntityName -PbatchSize=100 -PthreadCount=4 -PshowOptions=[true|false] -PfailHard=[true|false] -Psteps="1,2" -PjobId="abc123" [ -Poptions="{ customkey: customvalue, ...}" | -PoptionsFile=/path/to.json ] -i gradlew.bat hubRunFlow -PflowName=YourFlowName -PentityName=YourEntityName -PbatchSize=100 -PthreadCount=4 -PshowOptions=[true|false] -PfailHard=[true|false] -Psteps="1,2" -PjobId="abc123" [ -Poptions="{ customkey: customvalue, ...}" | -PoptionsFile=/path/to.json ] -i - flowName
- (必須)実行するハーモナイズフローの名前。
- entityName
- (フローにマッピングステップが含まれている場合に必須)マッピングステップで使用するエンティティの名前。
- batchSize
- バッチに含める項目の数。デフォルトは100です。
- threadCount
- 実行するスレッドの数。デフォルトは4です。
- showOptions
true
の場合、コマンドに渡されたオプションが出力されます。デフォルトは、false
です。- failHard
true
の場合、ステップが失敗するとすぐにフローの実行が終了します。デフォルトは、false
です。- steps
- 実行するステップ番号(カンマ区切りで指定)。指定していない場合は、フロー全体が実行されます。
- jobId
- このフローの実行に対応付けられた一意のジョブID。このオプションは、フローの実行がより大きなプロセスの一部である場合に使用できます(例えば、NiFiが独自のジョブ/プロセスIDによりオーケストレーションしたプロセスなど)。既存のデータハブのジョブIDと同じにすることはできません。指定していない場合は、一意のデータハブジョブIDが割り当てられます。
- options
- キー/バリューペアを含むJSON構造が、カスタムパラメータとしてステップモジュールに渡されます。
- optionsFile
- キー/バリューペアを含むJSONファイルへのパスが、カスタムパラメータとしてステップモジュールに渡されます。