Easy Batch implementation of http://aseigneurin.github.io/2015/01/23/spark-vs-command-line-tools.html #EasyBatch

Main.java

public class Main {

    public static void main(String[] args) throws FileNotFoundException {
        
        Engine engine = new EngineBuilder()
                .reader(new FlatFileRecordReader(new File("/path/tp/ChessData-master/data.pgn")))
                .filter(new GrepFilter("[Result"))
                .processor(new ComputationalRecordProcessor<StringRecord, StringRecord, Map<String, Integer>>() {
                    Map<String, Integer> results = new HashMap<String, Integer>();

                    public Map<String, Integer> getComputationResult() {
                        return results;
                    }

                    public StringRecord processRecord(StringRecord stringRecord) throws Exception {
                        String payload = stringRecord.getPayload();
                        String result = payload.substring(payload.indexOf("\"") + 1, payload.indexOf("-"));
                        if (results.get(result) == null) {
                            results.put(result, 0);
                        }
                        results.put(result, results.get(result) + 1);
                        return stringRecord;
                    }
                })
                .silentMode(true)
                .build();

        Report report = engine.call();

        System.out.println("report = " + report);
    }
}