Package org.apache.nemo.common.ir.vertex.utility.runtimepass

Interface MessageAggregatorVertex.InitialStateSupplier<O>

Type Parameters:

O - of the output aggregated message.

All Superinterfaces:

java.io.Serializable, java.util.function.Supplier<O>

Enclosing class:

MessageAggregatorVertex<K,V,O>

public static interface MessageAggregatorVertex.InitialStateSupplier<O>
extends java.util.function.Supplier<O>, java.io.Serializable

Creates the initial aggregated message.

Method Summary

Methods inherited from interface java.util.function.Supplier

get