private void assertPathsExists(String... paths) {
		for (String path : paths) {
			assertTrue(path + " is missing from hdfs",
					hadoopUtil.waitForPath(WAIT_TIME, path));// wait up to 10 seconds for file to be closed
		}
	}
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