org.apache.storm.trident.operation

Interface MapFunction

All Superinterfaces:

Serializable

All Known Subinterfaces:

OperationAwareMapFunction

public interface MapFunction
extends Serializable

A one-one transformation function.

Method Summary

Modifier and Type	Method and Description
Values	execute(TridentTuple input) Invoked by the framework for each trident tuple in a stream.

Method Detail

execute

Values execute(TridentTuple input)

Invoked by the framework for each trident tuple in a stream.

Parameters:

input - the input trident tuple

Returns:

the transformed values