@Override
  public void abort() {
    RecordProcessor rProcLocal;
    synchronized (this) {
      LOG.info("Received abort");
      aborted.set(true);
      rProcLocal = rproc;
    }
    if (rProcLocal != null) {
      LOG.info("Forwarding abort to RecordProcessor");
      rProcLocal.abort();
    } else {
      LOG.info("RecordProcessor not yet setup. Abort will be ignored");
    }
  }
This provides the ability to pass things into TezProcessor, which is normally impossible
because of how Tez APIs are structured. Piggyback on ExecutionContext.
ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java