private void setLlapOfFragmentId(final ProcessorContext context) {
    // TODO: could we do this only if the OF is actually used?
    String attemptId = Converters.createTaskAttemptId(context).toString();
    LOG.debug("Setting the LLAP fragment ID for OF to {}", attemptId);
    jconf.set(LlapOutputFormat.LLAP_OF_ID_KEY, attemptId);
  }
Process input from tez LogicalInput and write output - for a map plan
Just pump the records through the query plan.
ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java