public int launch ( final String configurationHdfsPath , final String jobHdfsPath ) throws Exception { // create hadoop configuration directory final File hadoopConfDir = createTemporaryHadoopConfDir ( ) ; final SparkLauncher sparkLauncher = createSparkLauncher ( hadoopConfDir , configurationHdfsPath , jobHdfsPath , null ) ; return launch ( sparkLauncher ) ; }
Launches and waits for the execution of a DataCleaner job on Spark .