- Type Parameters:
K
- input topic key type
M
- input topic message type
- All Implemented Interfaces:
- Serializable, org.apache.spark.api.java.function.PairFunction<kafka.message.MessageAndMetadata<K,M>,K,M>
- Enclosing class:
- AbstractSparkLayer<K,M>
public static final class AbstractSparkLayer.MMDToTuple2Fn<K,M>
extends Object
implements org.apache.spark.api.java.function.PairFunction<kafka.message.MessageAndMetadata<K,M>,K,M>
Translates a MessageAndMetadata
key-message pair to a Tuple2
of the same.
- See Also:
- Serialized Form