@Test public void assertScriptJob() { new LocalTaskExecutor(new TestDataflowJob(), JobConfiguration.newBuilder("TestScriptJob", 3) .cron("*/2 * * * * ?").setProperty(ScriptJobProperties.SCRIPT_KEY, "echo test").build(), 1).execute(); }
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();  }