@@ -0,0 +1,403 @@
+package com.github.sparkcaller;%0A%0Aimport org.apache.spark.api.java.function.Function;%0Aimport java.io.File;%0A%0Apublic class FileMover implements Function%3CFile, File%3E %7B%0A    String targetPath;%0A%0A    public FileMover(String targetPath) %7B%0A        this.targetPath = targetPath;%0A    %7D%0A%0A    @Override%0A    public File call(File file) throws Exception %7B%0A        return Utils.moveToDir(file, this.targetPath);%0A    %7D%0A%7D%0A

Add a class which can be used to move files in parallel.