org.apache.shardingsphere.data.pipeline.core.job.progress

类 PipelineJobProgressDetector

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.job.progress.PipelineJobProgressDetector

public final class PipelineJobProgressDetector
extends Object

Pipeline job progress detector.

构造器概要

构造器

构造器和说明
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.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

PipelineJobProgressDetector

public PipelineJobProgressDetector()

方法详细资料

allInventoryTasksFinished

public static boolean allInventoryTasksFinished(Collection<InventoryTask> inventoryTasks)

All inventory tasks is finished.

参数:

inventoryTasks - to check inventory tasks

返回:

is finished

isJobCompleted

public static boolean isJobCompleted(int jobShardingCount,
                                     Collection<? extends PipelineJobItemProgress> jobItemProgresses)

Whether job is completed (successful or failed).

参数:

jobShardingCount - job sharding count

jobItemProgresses - job item progresses

返回:

completed or not

isJobSuccessful

public static boolean isJobSuccessful(int jobShardingCount,
                                      Collection<? extends PipelineJobItemProgress> jobItemProgresses)

Whether job is successful.

参数:

jobShardingCount - job sharding count

jobItemProgresses - job item progresses

返回:

completed or not