public OutputStreamImpl<M> getOutputStream() {
    return this.outputStream;
  }
The {@link OutputStreamImpl} that this operator is sending its output to.
@return the {@link OutputStreamImpl} for this operator if any, else null.
samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java