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

直接已知子类:

MigrationJobAPIImpl

public abstract class AbstractPipelineJobAPIImpl
extends Object
implements PipelineJobAPI

Abstract pipeline job API impl.

字段概要

字段

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

构造器概要

构造器

构造器和说明
AbstractPipelineJobAPIImpl()

方法概要

限定符和类型	方法和说明
void	alterProcessConfiguration(PipelineProcessConfiguration processConfig)
protected void	checkModeConfig()
protected abstract void	cleanTempTableOnRollback(String jobId)
void	commit(String jobId)
void	createProcessConfiguration(PipelineProcessConfiguration processConfig)
void	dropProcessConfiguration(String confPath)
protected void	fillJobInfo(PipelineJobInfo jobInfo, org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)
protected org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO	getElasticJobConfigPOJO(String jobId)
protected abstract PipelineJobConfiguration	getJobConfiguration(org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)
protected abstract PipelineJobInfo	getJobInfo(String jobId)
protected abstract JobType	getJobType()
String	getType()
List<? extends PipelineJobInfo>	list()
String	marshalJobId(PipelineJobId pipelineJobId) Marshal pipeline job id.
protected abstract String	marshalJobIdLeftPart(PipelineJobId pipelineJobId)
void	rollback(String jobId)
PipelineProcessConfiguration	showProcessConfiguration()
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.infra.util.spi.type.typed.TypedSPI

getTypeAliases

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

getJobItemProgress, persistJobItemProgress, updateJobItemStatus

字段详细资料

DATE_TIME_FORMATTER

protected static final DateTimeFormatter DATE_TIME_FORMATTER

构造器详细资料

AbstractPipelineJobAPIImpl

public AbstractPipelineJobAPIImpl()

方法详细资料

getJobType

protected abstract JobType getJobType()

createProcessConfiguration

public void createProcessConfiguration(PipelineProcessConfiguration processConfig)

指定者:

createProcessConfiguration 在接口中 PipelineJobPublicAPI

alterProcessConfiguration

public void alterProcessConfiguration(PipelineProcessConfiguration processConfig)

指定者:

alterProcessConfiguration 在接口中 PipelineJobPublicAPI

dropProcessConfiguration

public void dropProcessConfiguration(String confPath)

指定者:

dropProcessConfiguration 在接口中 PipelineJobPublicAPI

showProcessConfiguration

public PipelineProcessConfiguration showProcessConfiguration()

指定者:

showProcessConfiguration 在接口中 PipelineJobPublicAPI

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)

fillJobInfo

protected void fillJobInfo(PipelineJobInfo jobInfo,
                           org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)

start

public Optional<String> start(PipelineJobConfiguration jobConfig)

从接口复制的说明: PipelineJobAPI

Start job.

指定者:

start 在接口中 PipelineJobAPI

参数:

jobConfig - job configuration

返回:

job id

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

rollback

public void rollback(String jobId)
              throws SQLException

指定者:

rollback 在接口中 PipelineJobPublicAPI

抛出:

SQLException

cleanTempTableOnRollback

protected abstract void cleanTempTableOnRollback(String jobId)
                                          throws SQLException

抛出:

SQLException

commit

public void commit(String jobId)

指定者:

commit 在接口中 PipelineJobPublicAPI

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