@Test
	public void testHdfsJdbcJob() {
		String data = UUID.randomUUID().toString();
		HdfsJdbcJob job = jobs.hdfsJdbcJob();
		job.fileName(HdfsJdbcJob.DEFAULT_FILE_NAME + "-0.txt");
		// Create a stream that writes to a hdfs file. This file will be used by the job.
		stream("dataSender", sources.http() + XD_DELIMITER + sinks.hdfs()
				.directoryName(HdfsJdbcJob.DEFAULT_DIRECTORY).fileName(DEFAULT_FILE_NAME).toDSL());
		sources.httpSource("dataSender").postData(data);
		job(job.toDSL());
		waitForXD();
		//Undeploy the dataSender stream to force XD to close the file.
		undeployStream("dataSender");
		waitForXD();
		jobLaunch();
		waitForXD();
		String query = String.format("SELECT data FROM %s", tableName);
		assertEquals(data,
				jdbcSink.getJdbcTemplate().queryForObject(query, String.class));
	}
Asserts that hdfsJdbcJob has written the test data from a file on hdfs to the table.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/HdfsJdbcTest.java