org.apache.shardingsphere.elasticjob.lite.internal.schedule

Class LiteJobFacade

java.lang.Object

org.apache.shardingsphere.elasticjob.lite.internal.schedule.LiteJobFacade

All Implemented Interfaces:

org.apache.shardingsphere.elasticjob.executor.JobFacade

public final class LiteJobFacade
extends Object
implements org.apache.shardingsphere.elasticjob.executor.JobFacade

Lite job facade.

Constructor Summary

Constructors

Constructor and Description
LiteJobFacade(CoordinatorRegistryCenter regCenter, String jobName, Collection<ElasticJobListener> elasticJobListeners, org.apache.shardingsphere.elasticjob.tracing.api.TracingConfiguration<?> tracingConfig)

Method Summary

Modifier and Type	Method and Description
void	afterJobExecuted(ShardingContexts shardingContexts)
void	beforeJobExecuted(ShardingContexts shardingContexts)
void	checkJobExecutionEnvironment()
void	clearMisfire(Collection<Integer> shardingItems)
void	failoverIfNecessary()
ShardingContexts	getShardingContexts()
boolean	isExecuteMisfired(Collection<Integer> shardingItems)
boolean	isNeedSharding()
JobConfiguration	loadJobConfiguration(boolean fromCache)
boolean	misfireIfRunning(Collection<Integer> shardingItems)
void	postJobExecutionEvent(org.apache.shardingsphere.elasticjob.tracing.event.JobExecutionEvent jobExecutionEvent)
void	postJobStatusTraceEvent(String taskId, org.apache.shardingsphere.elasticjob.tracing.event.JobStatusTraceEvent.State state, String message)
void	registerJobBegin(ShardingContexts shardingContexts)
void	registerJobCompleted(ShardingContexts shardingContexts)

Methods inherited from class java.lang.Object

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

Constructor Detail

LiteJobFacade

public LiteJobFacade(CoordinatorRegistryCenter regCenter,
                     String jobName,
                     Collection<ElasticJobListener> elasticJobListeners,
                     org.apache.shardingsphere.elasticjob.tracing.api.TracingConfiguration<?> tracingConfig)

Method Detail

loadJobConfiguration

public JobConfiguration loadJobConfiguration(boolean fromCache)

Specified by:

loadJobConfiguration in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

checkJobExecutionEnvironment

public void checkJobExecutionEnvironment()
                                  throws JobExecutionEnvironmentException

Specified by:

checkJobExecutionEnvironment in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

Throws:

JobExecutionEnvironmentException

failoverIfNecessary

public void failoverIfNecessary()

Specified by:

failoverIfNecessary in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

registerJobBegin

public void registerJobBegin(ShardingContexts shardingContexts)

Specified by:

registerJobBegin in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

registerJobCompleted

public void registerJobCompleted(ShardingContexts shardingContexts)

Specified by:

registerJobCompleted in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

getShardingContexts

public ShardingContexts getShardingContexts()

Specified by:

getShardingContexts in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

misfireIfRunning

public boolean misfireIfRunning(Collection<Integer> shardingItems)

Specified by:

misfireIfRunning in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

clearMisfire

public void clearMisfire(Collection<Integer> shardingItems)

Specified by:

clearMisfire in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

isExecuteMisfired

public boolean isExecuteMisfired(Collection<Integer> shardingItems)

Specified by:

isExecuteMisfired in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

isNeedSharding

public boolean isNeedSharding()

Specified by:

isNeedSharding in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

beforeJobExecuted

public void beforeJobExecuted(ShardingContexts shardingContexts)

Specified by:

beforeJobExecuted in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

afterJobExecuted

public void afterJobExecuted(ShardingContexts shardingContexts)

Specified by:

afterJobExecuted in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

postJobExecutionEvent

public void postJobExecutionEvent(org.apache.shardingsphere.elasticjob.tracing.event.JobExecutionEvent jobExecutionEvent)

Specified by:

postJobExecutionEvent in interface org.apache.shardingsphere.elasticjob.executor.JobFacade

postJobStatusTraceEvent

public void postJobStatusTraceEvent(String taskId,
                                    org.apache.shardingsphere.elasticjob.tracing.event.JobStatusTraceEvent.State state,
                                    String message)

Specified by:

postJobStatusTraceEvent in interface org.apache.shardingsphere.elasticjob.executor.JobFacade