@Test public void assertSimpleJob() { TestSimpleJob simpleJob = new TestSimpleJob(); new LocalTaskExecutor(simpleJob, JobConfiguration.newBuilder(TestSimpleJob.class.getSimpleName(), 3) .cron("*/2 * * * * ?").shardingItemParameters("0=A,1=B").build(), 1).execute(); assertThat(simpleJob.getShardingParameters(), is(Collections.singletonList("B"))); }
public void execute() { createElasticJobExecutor(new CloudJobFacade(getShardingContexts(), jobConfiguration, new JobEventBus())).execute(); }
LocalTaskExecutor { public void execute() { createElasticJobExecutor(new CloudJobFacade(getShardingContexts(), jobConfiguration, new JobEventBus())).execute(); } }
LocalTaskExecutor { public void execute() { createElasticJobExecutor(new CloudJobFacade(getShardingContexts(), jobConfiguration, new JobEventBus())).execute(); } LocalTaskExecutor(final ElasticJob elasticJob, final JobConfiguration jobConfiguration, final int shardingItem);  LocalTaskExecutor(final String elasticJobType, final JobConfiguration jobConfiguration, final int shardingItem); }
LocalTaskExecutor { public void execute() { createElasticJobExecutor(new CloudJobFacade(getShardingContexts(), jobConfiguration, new JobEventBus())).execute(); } LocalTaskExecutor(final ElasticJob elasticJob, final JobConfiguration jobConfiguration, final int shardingItem);  LocalTaskExecutor(final String elasticJobType, final JobConfiguration jobConfiguration, final int shardingItem); void execute(); }
LocalTaskExecutor { public void execute() { createElasticJobExecutor(new CloudJobFacade(getShardingContexts(), jobConfiguration, new JobEventBus())).execute(); } LocalTaskExecutor(final ElasticJob elasticJob, final JobConfiguration jobConfiguration, final int shardingItem);  LocalTaskExecutor(final String elasticJobType, final JobConfiguration jobConfiguration, final int shardingItem); void execute();  }