org.apache.samza.system.descriptors

Interface InputTransformer<OM>

Type Parameters:

OM - type of the transformed message

All Superinterfaces:

ClosableFunction, InitableFunction, java.io.Serializable

public interface InputTransformer<OM>
extends InitableFunction, ClosableFunction, java.io.Serializable

Transforms an IncomingMessageEnvelope with deserialized key and message to a message of type OM which is delivered to the MessageStream. Called in InputOperatorImpl when incoming messages from a SystemConsumer are being delivered to the application.

This is provided by default by transforming system descriptor implementations and can not be overridden or set on a per stream level.

Method Summary

Modifier and Type	Method and Description
OM	apply(IncomingMessageEnvelope ime) Transforms the provided IncomingMessageEnvelope with deserialized key and message into another message which is delivered to the MessageStream.

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(IncomingMessageEnvelope ime)

Transforms the provided IncomingMessageEnvelope with deserialized key and message into another message which is delivered to the MessageStream.

Parameters:

ime - the IncomingMessageEnvelope to be transformed

Returns:

the transformed message