@Test
	public void testPartitionedJdbcHdfsJobWithColumnsTable() {
		// Deploy stream and job.
		jdbcSink.columns(PartitionedJdbcHdfsJob.DEFAULT_COLUMN_NAMES);
		String data0 = "{\"id\":1,\"name\":\"Sven\"}";
		String data1 = "{\"id\":2,\"name\":\"Anna\"}";
		String data2 = "{\"id\":3,\"name\":\"Nisse\"}";
		jdbcSink.getJdbcTemplate().getDataSource();
		PartitionedJdbcHdfsJob job = jobs.partitionedJdbcHdfsJob();
		// Use a trigger to send data to JDBC
		stream("dataSender", sources.http() + XD_DELIMITER
				+ jdbcSink);
		sources.httpSource("dataSender").postData(data0);
		sources.httpSource("dataSender").postData(data1);
		sources.httpSource("dataSender").postData(data2);

		job(jobName, job.toDSL(), true);
		jobLaunch(jobName);
		waitForJobToComplete(jobName);
		// Evaluate the results of the test.
		String dir = JdbcHdfsJob.DEFAULT_DIRECTORY + "/";
		String path0 = JdbcHdfsJob.DEFAULT_DIRECTORY + "/" + JdbcHdfsJob.DEFAULT_FILE_NAME + "-p0" + "-0.csv";
		String path1 = JdbcHdfsJob.DEFAULT_DIRECTORY + "/" + JdbcHdfsJob.DEFAULT_FILE_NAME + "-p1" + "-0.csv";
		String path2 = JdbcHdfsJob.DEFAULT_DIRECTORY + "/" + JdbcHdfsJob.DEFAULT_FILE_NAME + "-p2" + "-0.csv";
		assertPathsExists(path0, path1, path2);
		Collection<FileStatus> fileStatuses = hadoopUtil.listDir(dir);
		assertEquals("The number of files should be 4. The directory and 3 files. ", 4, fileStatuses.size());
		for (FileStatus fileStatus : fileStatuses) {
			if (!fileStatus.isDirectory()) {
				assertTrue("The file should be of reasonable size", fileStatus.getLen() > 5 && fileStatus.getLen() < 10);
			}
		}
	}
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