@Before
	public void initialize() {
		jobName = "jdbchdfs" + UUID.randomUUID().toString();
		jdbcSink = sinks.jdbc();
		tableName = DEFAULT_TABLE_NAME;
		jdbcSink.tableName(tableName);
		cleanup();
		if (hadoopUtil.fileExists(JdbcHdfsJob.DEFAULT_DIRECTORY)) {
			hadoopUtil.fileRemove(JdbcHdfsJob.DEFAULT_DIRECTORY);
		}
	}
Removes the table created from a previous test. Also deletes the result hdfs directory.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/JdbcHdfsTest.java