@InterfaceStability.Unstable public interface StreamGraphBuilder
StreamGraph
object.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
MessageStream s and operators |
void init(StreamGraph graph, Config config)
MessageStream
s and operatorsgraph
- an empty StreamGraph
object to be initializedconfig
- the Config
of the application