1. Load the dataset into RecordReader. Load the CSV data in the case of CSVRecordReader:

RecordReader reader = new CSVRecordReader(0,',');
 reader.initialize(new FileSplit(file)); 

2. Execute the transforms in local using LocalTransformExecutor: 

List<List<Writable>> transformed = LocalTransformExecutor.execute(recordReader, transformProcess)

3. Execute the transforms in Spark using SparkTransformExecutor: 

JavaRDD<List<Writable>> transformed = SparkTransformExecutor.execute(inputRdd, transformProcess)