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

Interface TriggerVertex.MessageGeneratorFunction<I,​K,​V>

  • Type Parameters:
    I - input type
    K - of the output pair.
    V - of the output pair.
    All Superinterfaces:
    BiFunction<I,​Map<K,​V>,​Map<K,​V>>, Serializable
    Enclosing class:
    TriggerVertex<I,​K,​V>
    public static interface TriggerVertex.MessageGeneratorFunction<I,​K,​V>
extends BiFunction<I,​Map<K,​V>,​Map<K,​V>>, Serializable
    Applied on the input data elements to produce a message.