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

类 PipelineJobCenter

java.lang.Object

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

public final class PipelineJobCenter
extends Object

Pipeline job center.

构造器概要

构造器

构造器和说明
PipelineJobCenter()

方法概要

限定符和类型	方法和说明
static void	addJob(String jobId, PipelineJob job) Add job.
static Optional<PipelineJobItemContext>	getJobItemContext(String jobId, int shardingItem) Get job item context.
static boolean	isJobExisting(String jobId) Is job existing.
static void	stop(String jobId) Stop job.

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

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

构造器详细资料

PipelineJobCenter

public PipelineJobCenter()

方法详细资料

addJob

public static void addJob(String jobId,
                          PipelineJob job)

Add job.

参数:

jobId - job id

job - job

isJobExisting

public static boolean isJobExisting(String jobId)

Is job existing.

参数:

jobId - job id

返回:

true when job exists, else false

stop

public static void stop(String jobId)

Stop job.

参数:

jobId - job id

getJobItemContext

public static Optional<PipelineJobItemContext> getJobItemContext(String jobId,
                                                                 int shardingItem)

Get job item context.

参数:

jobId - job id

shardingItem - sharding item

返回:

job item context