November 2019
Intermediate to advanced
304 pages
8h 40m
English
RecordReader reader = new CSVRecordReader(0,','); reader.initialize(new FileSplit(file));
List<List<Writable>> transformed = LocalTransformExecutor.execute(recordReader, transformProcess)
JavaRDD<List<Writable>> transformed = SparkTransformExecutor.execute(inputRdd, transformProcess)