protected OperatorSpec<IncomingMessageEnvelope, Object> getOperatorSpec() {
    return this.inputOpSpec;
  }
An operator that builds the input message from the incoming message.
samza-core/src/main/java/org/apache/samza/operators/impl/InputOperatorImpl.java