org.apache.samza.operators

Interface StreamOperatorTask

@InterfaceStability.Unstable
public interface StreamOperatorTask

A StreamOperatorTask is the basic interface to implement for processing MessageStreams. Implementations can describe the transformation steps for each MessageStream in the transform(java.util.Map<org.apache.samza.system.SystemStreamPartition, org.apache.samza.operators.MessageStream<org.apache.samza.operators.data.IncomingSystemMessageEnvelope>>) method using MessageStream APIs.

Implementations may be augmented by implementing InitableTask, WindowableTask and ClosableTask interfaces, but should not implement StreamTask or AsyncStreamTask interfaces.

Method Summary

Modifier and Type	Method and Description
void	transform(java.util.Map<SystemStreamPartition,MessageStream<IncomingSystemMessageEnvelope>> messageStreams) Describe the transformation steps for each MessageStreams for this task using the MessageStream APIs.

Method Detail

transform

void transform(java.util.Map<SystemStreamPartition,MessageStream<IncomingSystemMessageEnvelope>> messageStreams)

Describe the transformation steps for each MessageStreams for this task using the MessageStream APIs. Each MessageStream corresponds to one SystemStreamPartition in the input system.

Parameters:

messageStreams - the MessageStreams that receive IncomingSystemMessageEnvelopes from their corresponding SystemStreamPartition