org.apache.samza.operators
Interfaces
MessageStream
StreamOperatorTask