@Test
	public void testIncrementalJdbcHdfsJobWithOverride() {
		// Deploy stream and job.
		jdbcSink.getJdbcTemplate().getDataSource();
		IncrementalJdbcHdfsJob job = jobs.incrementalJdbcHdfsJob();
		// Use a trigger to send data to JDBC
		stream("dataSender", sources.http() + XD_DELIMITER
				+ jdbcSink);

		String file1Contents = StringUtils.arrayToDelimitedString(new String[] {"1", "2", "3"}, "\n");

		sources.httpSource("dataSender").postData("1");
		sources.httpSource("dataSender").postData("2");
		sources.httpSource("dataSender").postData("3");

		job(jobName, job.toDSL(), true);
		jobLaunch(jobName);
		waitForJobToComplete(jobName);

		// Evaluate the results of the test.
		String path = JdbcHdfsJob.DEFAULT_DIRECTORY + "/" + JdbcHdfsJob.DEFAULT_FILE_NAME + "-p0-0.csv";
		assertPathsExists(path);
		Collection<FileStatus> fileStatuses = hadoopUtil.listDir(path);
		assertEquals("The number of files in list result should only be 1. The file itself. ", 1,
				fileStatuses.size());
		Iterator<FileStatus> statuses = fileStatuses.iterator();
		assertEquals("File size should match the data size +1 for the //n", file1Contents.length() + 1, statuses.next().getLen());
		assertEquals("The data returned from hadoop was different than was sent.  ", file1Contents + "\n",
				hadoopUtil.getFileContentsFromHdfs(path));

		String file2Contents = StringUtils.arrayToDelimitedString(new String[] {"3", "4", "5", "6"}, "\n");

		sources.httpSource("dataSender").postData("4");
		sources.httpSource("dataSender").postData("5");
		sources.httpSource("dataSender").postData("6");

		launchJob(jobName, "{\"overrideCheckColumnValue\" : 2}");
		waitForJobToComplete(jobName, 2);

		// Evaluate the results of the test.
		path = JdbcHdfsJob.DEFAULT_DIRECTORY + "/" + JdbcHdfsJob.DEFAULT_FILE_NAME + "-p0-1.csv";
		assertPathsExists(path);
		fileStatuses = hadoopUtil.listDir(path);
		assertEquals("The number of files in list result should only be 1. The file itself. ", 1,
				fileStatuses.size());
		statuses = fileStatuses.iterator();
		assertEquals("File size should match the data size +1 for the //n", file2Contents.length() + 1, statuses.next().getLen());
		assertEquals("The data returned from hadoop was different than was sent.  ", file2Contents + "\n",
				hadoopUtil.getFileContentsFromHdfs(path));
	}
Asserts that jdbcHdfsJob has written the test data from a jdbc source table to a hdfs file system.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/JdbcHdfsTest.java