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