private String getTestFilePath(String directory, FileStatus status) {
		String fileName = status.getPath().getName();
		if (StringUtils.getFilenameExtension(fileName).equals("tmp")) {
			fileName = FilenameUtils.removeExtension(fileName);
		}
		return directory + "/" + fileName;
	}
Asserts that data sent to the hdfs sink is stored on a hadoop hdfs.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/HdfsTest.java