org.apache.samza.operators.functions

Interface FlatMapFunction<M extends MessageEnvelope,OM extends MessageEnvelope>

Type Parameters:

M - type of the input MessageEnvelope

OM - type of the transformed MessageEnvelopes

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 extends MessageEnvelope,OM extends MessageEnvelope>

A function that transforms a MessageEnvelope into a collection of 0 or more MessageEnvelopes, possibly of a different type.

Method Summary

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

Method Detail

apply

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

Transforms the provided MessageEnvelope into a collection of 0 or more MessageEnvelopes.

Parameters:

message - the MessageEnvelope to be transformed

Returns:

a collection of 0 or more transformed MessageEnvelopes