org.apache.shardingsphere.elasticjob.dataflow.executor

类 DataflowJobExecutor

java.lang.Object

org.apache.shardingsphere.elasticjob.dataflow.executor.DataflowJobExecutor

所有已实现的接口:

ClassedJobItemExecutor<DataflowJob>, JobItemExecutor<DataflowJob>

public final class DataflowJobExecutor
extends Object
implements ClassedJobItemExecutor<DataflowJob>

Dataflow job executor.

构造器概要

构造器

构造器和说明
DataflowJobExecutor()

方法概要

限定符和类型	方法和说明
Class<DataflowJob>	getElasticJobClass()
void	process(DataflowJob elasticJob, org.apache.shardingsphere.elasticjob.api.JobConfiguration jobConfig, JobFacade jobFacade, org.apache.shardingsphere.elasticjob.api.ShardingContext shardingContext)

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

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

构造器详细资料

DataflowJobExecutor

public DataflowJobExecutor()

方法详细资料

process

public void process(DataflowJob elasticJob,
                    org.apache.shardingsphere.elasticjob.api.JobConfiguration jobConfig,
                    JobFacade jobFacade,
                    org.apache.shardingsphere.elasticjob.api.ShardingContext shardingContext)

指定者:

process 在接口中 JobItemExecutor<DataflowJob>

getElasticJobClass

public Class<DataflowJob> getElasticJobClass()

指定者:

getElasticJobClass 在接口中 ClassedJobItemExecutor<DataflowJob>