public final class PipelineJobProgressDetector extends Object
| 构造器和说明 |
|---|
PipelineJobProgressDetector() |
| 限定符和类型 | 方法和说明 |
|---|---|
static boolean |
allInventoryTasksFinished(Collection<InventoryTask> inventoryTasks)
All inventory tasks is finished.
|
static boolean |
isJobCompleted(int jobShardingCount,
Collection<? extends PipelineJobItemProgress> jobItemProgresses)
Whether job is completed (successful or failed).
|
static boolean |
isJobSuccessful(int jobShardingCount,
Collection<? extends PipelineJobItemProgress> jobItemProgresses)
Whether job is successful.
|
public static boolean allInventoryTasksFinished(Collection<InventoryTask> inventoryTasks)
inventoryTasks - to check inventory taskspublic static boolean isJobCompleted(int jobShardingCount,
Collection<? extends PipelineJobItemProgress> jobItemProgresses)
jobShardingCount - job sharding countjobItemProgresses - job item progressespublic static boolean isJobSuccessful(int jobShardingCount,
Collection<? extends PipelineJobItemProgress> jobItemProgresses)
jobShardingCount - job sharding countjobItemProgresses - job item progressesCopyright © 2022 The Apache Software Foundation. All rights reserved.