@Override
		public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
			final String fileName = chunkContext.getStepContext().getStepExecution().getExecutionContext().getString(
					"filePath");
			Assert.notNull(fileName);
			boolean result = this.template.get(MessageBuilder.withPayload(fileName).build(), new InputStreamCallback() {

				@Override
				public void doWithInputStream(InputStream stream) throws IOException {
					// TODO hadoop
					FileOutputStream out = new FileOutputStream(new File(tmpDir,
							fileName.replaceAll("\\/", "_")));
					FileCopyUtils.copy(stream, out);
				}

			});
			if (!result) {
				throw new MessagingException("Error during file transfer");
			}
			else {
				return RepeatStatus.FINISHED;
			}
		}
Replaces Hadoop tasklet so we can just write to java.io.tmpdir instead.
extensions/spring-xd-extension-batch/src/test/java/org/springframework/batch/integration/x/RemoteFileToTmpTests.java