org.apache.samza.operators

Interface StreamGraphBuilder

@InterfaceStability.Unstable
public interface StreamGraphBuilder

This interface defines a factory class that user will implement to create user-defined operator DAG in a StreamGraph object.

Method Summary

Modifier and Type	Method and Description
void	init(StreamGraph graph, Config config) Users are required to implement this abstract method to initialize the processing logic of the application, in terms of a DAG of MessageStreams and operators

Method Detail

init

void init(StreamGraph graph,
          Config config)

Users are required to implement this abstract method to initialize the processing logic of the application, in terms of a DAG of MessageStreams and operators

Parameters:

graph - an empty StreamGraph object to be initialized

config - the Config of the application