org.apache.samza.operators.functions

Interface MapFunction<M,OM>

Type Parameters:

M - type of the input message

OM - type of the transformed message

All Superinterfaces:

ClosableFunction, InitableFunction, java.io.Serializable

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,OM>
extends InitableFunction, ClosableFunction, java.io.Serializable

Transforms an input message into another message, possibly of a different type.

Method Summary

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

Methods inherited from interface org.apache.samza.operators.functions.InitableFunction

init

Methods inherited from interface org.apache.samza.operators.functions.ClosableFunction

close

Method Detail

apply

OM apply(M message)

Transforms the provided message into another message.

Parameters:

message - the input message to be transformed

Returns:

the transformed message