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

Interface MessageGeneratorVertex.MessageGeneratorFunction<I,K,V>

Type Parameters:

I - input type

K - of the output pair.

V - of the output pair.

All Superinterfaces:

java.util.function.BiFunction<I,java.util.Map<K,V>,java.util.Map<K,V>>, java.io.Serializable

Enclosing class:

MessageGeneratorVertex<I,K,V>

public static interface MessageGeneratorVertex.MessageGeneratorFunction<I,K,V>
extends java.util.function.BiFunction<I,java.util.Map<K,V>,java.util.Map<K,V>>, java.io.Serializable

Applied on the input data elements to produce a message.

Method Summary

Methods inherited from interface java.util.function.BiFunction

andThen, apply