org.apache.samza.operators.functions

Interface FlatMapFunction<M,OM>

Type Parameters:

M - type of the input message

OM - type of the transformed messages

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

Transforms an input message into a collection of 0 or more messages, possibly of a different type.

Method Summary

Modifier and Type	Method and Description
java.util.Collection<OM>	apply(M message) Transforms the provided message into a collection of 0 or more messages.

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

java.util.Collection<OM> apply(M message)

Transforms the provided message into a collection of 0 or more messages.

Parameters:

message - the input message to be transformed

Returns:

a collection of 0 or more transformed messages