@Override
	protected List<String> createCommand() {
		List<String> command = new ArrayList<String>();
		String javaHome = System.getenv("JAVA_HOME");
		if (StringUtils.hasText(javaHome)) {
			command.add(javaHome + "/bin/java");
		}
		else {
			command.add("java");
		}
		command.add(SQOOP_RUNNER_CLASS);
		command.addAll(Arrays.asList(arguments));
		Iterator<PropertySource<?>> i = environment.getPropertySources().iterator();
		while (i.hasNext()) {
			PropertySource<?> p = i.next();
			if (p instanceof EnumerablePropertySource) {
				for (String name : ((EnumerablePropertySource) p).getPropertyNames()) {
					if (name.startsWith(SPRING_HADOOP_CONFIG_PREFIX)) {
						command.add(name + "=" + environment.getProperty(name));
					}
				}
			}
		}
		for (Map.Entry<?, ?> e : hadoopProperties.entrySet()) {
			if (e.getKey().toString().startsWith(SPRING_HADOOP_PREFIX)) {
				command.add(e.getKey() + "=" + e.getValue());
			}
			else {
				command.add(SPRING_HADOOP_CONFIG_PREFIX + "." + e.getKey() + "=" + e.getValue());
			}
		}
		return command;
	}
Tasklet used for running Sqoop tool.

Note: This this class is not thread-safe.

@since 1.1
@author Thomas Risberg
@author Gary Russell
extensions/spring-xd-extension-sqoop/src/main/java/org/springframework/xd/sqoop/SqoopTasklet.java