Package org.springframework.batch.core

Examples of org.springframework.batch.core.JobParameter

138
139
140
141
142
143
144
145
146
147
148
149
      fs.delete(p2, true);
      assertFalse(fs.exists(p1));
      assertFalse(fs.exists(p2));

      Map<String, JobParameter> params = new HashMap<String, JobParameter>();
      params.put("remoteDirectory", new JobParameter("/foo/"));
      params.put("hdfsDirectory", new JobParameter("/qux"));
      JobParameters parameters = new JobParameters(params);
      JobExecution execution = launcher.run(job, parameters);
      assertEquals(ExitStatus.COMPLETED, execution.getExitStatus());

      assertTrue(fs.exists(p1));
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
148
  }

  @Test
  public void testSimple() throws Exception {
    Map<String, JobParameter> params = new HashMap<String, JobParameter>();
    params.put("remoteDirectory", new JobParameter("/foo/"));
    params.put("hdfsDirectory", new JobParameter("/qux"));
    JobParameters parameters = new JobParameters(params);
    JobExecution execution = launcher.run(job, parameters);
    assertEquals(ExitStatus.COMPLETED, execution.getExitStatus());

    File file = new File(tmpDir, "_foo_bar.txt");
View Full Code Here
183
184
185
186
187
188
189
190
191
192
    int numberOfJobParameters = JobParametersHolder.getJobParameters().size();
    assertTrue("Expecting 2 parameters but got " + numberOfJobParameters, numberOfJobParameters == 2);

    assertNotNull(JobParametersHolder.getJobParameters().get("random"));

    final JobParameter parameter1 = JobParametersHolder.getJobParameters().get("param1");

    assertNotNull(parameter1);
    assertEquals("spring rocks!", parameter1.getValue());
  }
View Full Code Here
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
    assertTrue("The countdown latch expired and did not count down.", done);
    assertTrue("Expecting 3 parameters.", JobParametersHolder.getJobParameters().size() == 3);
    assertNotNull(JobParametersHolder.getJobParameters().get("random"));

    final JobParameter parameter1 = JobParametersHolder.getJobParameters().get("param1");
    final JobParameter parameter2 = JobParametersHolder.getJobParameters().get("param2");

    assertNotNull(parameter1);
    assertNotNull(parameter2);
    assertTrue("parameter1 should be a Long", parameter1.getValue() instanceof Long);
    assertTrue("parameter2 should be a java.util.Date", parameter2.getValue() instanceof Date);

    final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");
    final Date expectedDate = dateFormat.parse("1990/10/03");

    assertEquals("Was expecting the Long value 12345", Long.valueOf(12345), parameter1.getValue());
    assertEquals("Should be the same dates", expectedDate, parameter2.getValue());

    assertFalse("parameter1 should be non-identifying", parameter1.isIdentifying());
    assertTrue("parameter2 should be identifying", parameter2.isIdentifying());
  }
View Full Code Here
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
    // Make sure the job parameters are set when passing through job launch command
    assertTrue("Expecting 3 parameters, but got: " + JobParametersHolder.getJobParameters(),
        JobParametersHolder.getJobParameters().size() == 3);
    assertNotNull(JobParametersHolder.getJobParameters().get("random"));

    final JobParameter parameter1 = JobParametersHolder.getJobParameters().get("param1");
    final JobParameter parameter2 = JobParametersHolder.getJobParameters().get("param2");

    assertNotNull(parameter1);
    assertNotNull(parameter2);
    assertTrue("parameter1 should be a Long", parameter1.getValue() instanceof Long);
    assertTrue("parameter2 should be a java.util.Date", parameter2.getValue() instanceof Date);

    final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");
    final Date expectedDate = dateFormat.parse("1990/10/03");

    assertEquals("Was expecting the Long value 12345", Long.valueOf(12345), parameter1.getValue());
    assertEquals("Should be the same dates", expectedDate, parameter2.getValue());

    assertFalse("parameter1 should be non-identifying", parameter1.isIdentifying());
    assertTrue("parameter2 should be identifying", parameter2.isIdentifying());
  }
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
    final String value = node.get("value").asText();
    final boolean identifying = node.get("identifying").asBoolean();
    final String type = node.get("type").asText();

    final JobParameter jobParameter;

    if (!type.isEmpty() && !type.equalsIgnoreCase("STRING")) {
      if ("DATE".equalsIgnoreCase(type)) {
        jobParameter = new JobParameter(DateTime.parse(value).toDate(), identifying);
      }
      else if ("DOUBLE".equalsIgnoreCase(type)) {
        jobParameter = new JobParameter(Double.valueOf(value), identifying);
      }
      else if ("LONG".equalsIgnoreCase(type)) {
        jobParameter = new JobParameter(Long.valueOf(value), identifying);
      }
      else {
        throw new IllegalStateException("Unsupported JobParameter type: " + type);
      }
    }
    else {
      jobParameter = new JobParameter(value, identifying);
    }

    if (logger.isDebugEnabled()) {
      logger.debug(String.format("jobParameter - value: %s (type: %s, isIdentifying: %s)",
          jobParameter.getValue(), jobParameter.getType().name(), jobParameter.isIdentifying()));
    }

    return jobParameter;
  }
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
    JobInstance jobInstance2 = new JobInstance(2l, job2.getName());
    JobInstance jobInstance3 = new JobInstance(3l, job3.getName());
    JobInstance jobInstance4 = new JobInstance(4l, job4.getName());
    JobInstance jobInstance5 = new JobInstance(5l, job5.getName());
    Map<String, JobParameter> parametersMap1 = new HashMap<String, JobParameter>();
    parametersMap1.put("param1", new JobParameter("test", true));
    parametersMap1.put("param2", new JobParameter(123l, false));

    DefaultJobParametersValidator jobParametersValidator = new DefaultJobParametersValidator();
    String[] requiredStrings = new String[] {"myRequiredString"};
    jobParametersValidator.setRequiredKeys(requiredStrings);
    job5.setJobParametersValidator(jobParametersValidator);

    Map<String, JobParameter> parametersMap5 = new HashMap<String, JobParameter>();
    parametersMap5.put("somthingElse", new JobParameter("test", true));


    JobParameters jobParameters1 = new JobParameters(parametersMap1);
    JobParameters jobParameters2 = new JobParameters(parametersMap1);
    JobParameters jobParameters3 = new JobParameters(parametersMap1);
View Full Code Here
24
25
26
27
28
29
30
31
public class TrivialJobParametersIncrementer implements JobParametersIncrementer {

    public JobParameters getNext(JobParameters parameters) {
        Map<String, JobParameter> map = new HashMap<String, JobParameter>(parameters.getParameters());
        map.put("run.count", new JobParameter(parameters.getLong("run.count", -1) + 1));
        return new JobParameters(map);
    }
View Full Code Here
TOP

Related Classes of org.springframework.batch.core.JobParameter

  • com.iisigroup.cap.batch.dao.impl.BatchExecutionDaoImpl
  • com.vmware.bdd.manager.ClusterManager
  • com.vmware.bdd.manager.JobManager
  • com.vmware.bdd.manager.TestJobManager
  • com.vmware.bdd.service.job.SubJobParametersExtractor
  • org.springframework.batch.admin.sample.TrivialJobParametersIncrementer
  • org.springframework.batch.core.converter.DefaultJobParametersConverter
  • org.springframework.batch.core.launch.support.ScheduledJobParametersFactory
  • org.springframework.batch.core.repository.dao.JdbcJobExecutionDao
  • org.springframework.batch.core.step.tasklet.AsyncChunkOrientedStepIntegrationTests
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.