@Override
  protected void handleInit(Context context) {
  }
An operator that builds the input message from the incoming message.
samza-core/src/main/java/org/apache/samza/operators/impl/InputOperatorImpl.java