org.apache.samza.operators.functions

Interface MapFunction<M extends MessageEnvelope,OM extends MessageEnvelope>

Type Parameters:

M - type of the input MessageEnvelope

OM - type of the transformed MessageEnvelope

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@InterfaceStability.Unstable
 @FunctionalInterface
public interface MapFunction<M extends MessageEnvelope,OM extends MessageEnvelope>

A function that transforms a MessageEnvelope into another MessageEnvelope, possibly of a different type.

Method Summary

Modifier and Type	Method and Description
OM	apply(M message) Transforms the provided MessageEnvelope into another MessageEnvelope

Method Detail

apply

OM apply(M message)

Transforms the provided MessageEnvelope into another MessageEnvelope

Parameters:

message - the MessageEnvelope to be transformed

Returns:

the transformed MessageEnvelope