@Test public void assertDataflowJob() { TestDataflowJob dataflowJob = new TestDataflowJob(); new LocalTaskExecutor(dataflowJob, JobConfiguration.newBuilder(TestDataflowJob.class.getSimpleName(), 3) .cron("*/2 * * * * ?").setProperty(DataflowJobProperties.STREAM_PROCESS_KEY, Boolean.FALSE.toString()).build(), 1).execute(); assertFalse(dataflowJob.getOutput().isEmpty()); assertThat(dataflowJob.getOutput(), is(Collections.singletonList("1-d"))); }
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();  }