karthikch53

private static class RecordingProgressMonitor implements Consumer < QueryStats > {
    
    private final ImmutableList.Builder < QueryStats > builder = ImmutableList.builder();
    private boolean finished;
    
    @Override
    public synchronized void accept(QueryStats queryStats) {
        checkState(!finished);
        builder.add(queryStats);
    }