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

Interface MessageAggregatorVertex.InitialStateSupplier<O>

Type Parameters:

O - of the output aggregated message.

All Superinterfaces:

Serializable, Supplier<O>

Enclosing class:

MessageAggregatorVertex<K,V,O>

public static interface MessageAggregatorVertex.InitialStateSupplier<O>
extends Supplier<O>, Serializable

Creates the initial aggregated message.

Method Summary

Methods inherited from interface java.util.function.Supplier

get