@Override
  public void abort() {
    // this will stop run() from pushing records, along with potentially
    // blocking initialization.
    super.abort();

    // this will abort initializeOp()
    if (mapOp != null) {
      LOG.info("Forwarding abort to mapOp: {} ", mapOp.getName());
      mapOp.abort();
    } else {
      LOG.info("mapOp not setup yet. abort not being forwarded");
    }
  }
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