Description
Current implementation combines the already received messages.
if (combiner != null) { M combined = combiner.combine(iterable); vertex.compute(Collections.singleton(combined)); } else { vertex.compute(iterable); }
Messages should be combined before sending to another vertex.