org.apache.samza.operators

Interface OutputStream<M>

Type Parameters:

M - the type of message being sent to this OutputStream

@InterfaceStability.Unstable
public interface OutputStream<M>

An output stream to send messages to.