org.apache.shardingsphere.data.pipeline.core.api.impl

类 AbstractPipelineJobAPIImpl

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

所有已实现的接口:

PipelineJobPublicAPI, PipelineJobAPI, PipelineJobItemAPI, org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

直接已知子类:

AbstractInventoryIncrementalJobAPIImpl, ConsistencyCheckJobAPIImpl

public abstract class AbstractPipelineJobAPIImpl
extends Object
implements PipelineJobAPI

Abstract pipeline job API impl.

字段概要

字段

限定符和类型	字段和说明
protected static DateTimeFormatter	DATE_TIME_FORMATTER

构造器概要

构造器

构造器和说明
AbstractPipelineJobAPIImpl()

方法概要

限定符和类型	方法和说明
protected void	checkModeConfig()
void	cleanJobItemErrorMessage(String jobId, int shardingItem) Clean job item error message.
protected void	dropJob(String jobId)
protected org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO	getElasticJobConfigPOJO(String jobId)
protected abstract String	getJobClassName()
protected abstract PipelineJobConfiguration	getJobConfiguration(org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)
protected abstract PipelineJobInfo	getJobInfo(String jobId)
String	getJobItemErrorMessage(String jobId, int shardingItem) Get job item error message.
String	getType()
List<? extends PipelineJobInfo>	list()
String	marshalJobId(PipelineJobId pipelineJobId) Marshal pipeline job id.
protected abstract String	marshalJobIdLeftPart(PipelineJobId pipelineJobId)
void	persistJobItemErrorMessage(String jobId, int shardingItem, Object error) Persist job item error message.
Optional<String>	start(PipelineJobConfiguration jobConfig) Start job.
void	startDisabledJob(String jobId)
void	stop(String jobId)
protected abstract YamlPipelineJobConfiguration	swapToYamlJobConfiguration(PipelineJobConfiguration jobConfig)

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

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

从接口继承的方法 org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI

buildPipelineProcessContext, buildTaskConfiguration, extendYamlJobConfiguration, getJobConfiguration

从接口继承的方法 org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPI

getJobType

从接口继承的方法 org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI

getJobItemProgress, persistJobItemProgress, updateJobItemStatus

从接口继承的方法 org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

getTypeAliases

字段详细资料

DATE_TIME_FORMATTER

protected static final DateTimeFormatter DATE_TIME_FORMATTER

构造器详细资料

AbstractPipelineJobAPIImpl

public AbstractPipelineJobAPIImpl()

方法详细资料

marshalJobId

public final String marshalJobId(PipelineJobId pipelineJobId)

从接口复制的说明: PipelineJobAPI

Marshal pipeline job id.

指定者:

marshalJobId 在接口中 PipelineJobAPI

参数:

pipelineJobId - pipeline job id

返回:

marshaled text

marshalJobIdLeftPart

protected abstract String marshalJobIdLeftPart(PipelineJobId pipelineJobId)

list

public List<? extends PipelineJobInfo> list()

指定者:

list 在接口中 PipelineJobPublicAPI

checkModeConfig

protected void checkModeConfig()

getJobInfo

protected abstract PipelineJobInfo getJobInfo(String jobId)

start

public Optional<String> start(PipelineJobConfiguration jobConfig)

从接口复制的说明: PipelineJobAPI

Start job.

指定者:

start 在接口中 PipelineJobAPI

参数:

jobConfig - job configuration

返回:

job id

getJobClassName

protected abstract String getJobClassName()

swapToYamlJobConfiguration

protected abstract YamlPipelineJobConfiguration swapToYamlJobConfiguration(PipelineJobConfiguration jobConfig)

getJobConfiguration

protected abstract PipelineJobConfiguration getJobConfiguration(org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)

startDisabledJob

public void startDisabledJob(String jobId)

指定者:

startDisabledJob 在接口中 PipelineJobPublicAPI

stop

public void stop(String jobId)

指定者:

stop 在接口中 PipelineJobPublicAPI

dropJob

protected void dropJob(String jobId)

getElasticJobConfigPOJO

protected final org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO getElasticJobConfigPOJO(String jobId)

getType

public String getType()

指定者:

getType 在接口中 org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

getJobItemErrorMessage

public String getJobItemErrorMessage(String jobId,
                                     int shardingItem)

从接口复制的说明: PipelineJobAPI

Get job item error message.

指定者:

getJobItemErrorMessage 在接口中 PipelineJobAPI

参数:

jobId - job id

shardingItem - sharding item

返回:

map, key is sharding item, value is error message

persistJobItemErrorMessage

public void persistJobItemErrorMessage(String jobId,
                                       int shardingItem,
                                       Object error)

从接口复制的说明: PipelineJobAPI

Persist job item error message.

指定者:

persistJobItemErrorMessage 在接口中 PipelineJobAPI

参数:

jobId - job id

shardingItem - sharding item

error - error

cleanJobItemErrorMessage

public void cleanJobItemErrorMessage(String jobId,
                                     int shardingItem)

从接口复制的说明: PipelineJobAPI

Clean job item error message.

指定者:

cleanJobItemErrorMessage 在接口中 PipelineJobAPI

参数:

jobId - job id

shardingItem - sharding item