本文整理了Java中org.apache.hadoop.hive.ql.history.HiveHistory.logPlanProgress()方法的一些代码示例，展示了HiveHistory.logPlanProgress()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HiveHistory.logPlanProgress()方法的具体详情如下：
包路径：org.apache.hadoop.hive.ql.history.HiveHistory
类名称：HiveHistory
方法名：logPlanProgress

HiveHistory.logPlanProgress介绍

[英]Logs the current plan state
[中]记录当前计划状态

代码示例

代码示例来源：origin: apache/hive

@Override
public void logPlanProgress(SessionState ss) throws IOException {
 ss.getHiveHistory().logPlanProgress(queryPlan);
}

代码示例来源：origin: apache/drill

@Override
public void logPlanProgress(SessionState ss) throws IOException {
 ss.getHiveHistory().logPlanProgress(queryPlan);
}

代码示例来源：origin: apache/hive

/**
 * This method is called in the Driver on every task. It updates counters and calls execute(),
 * which is overridden in each task
 *
 * @return return value of execute()
 */
public int executeTask(HiveHistory hiveHistory) {
 try {
  this.setStarted();
  if (hiveHistory != null) {
   hiveHistory.logPlanProgress(queryPlan);
  }
  if (conf != null) {
   LOG.debug("Task getting executed using mapred tag : " + conf.get(MRJobConfig.JOB_TAGS));
  }
  int retval = execute(driverContext);
  this.setDone();
  if (hiveHistory != null) {
   hiveHistory.logPlanProgress(queryPlan);
  }
  return retval;
 } catch (IOException e) {
  throw new RuntimeException("Unexpected error: " + e.getMessage(), e);
 }
}

代码示例来源：origin: apache/hive

private void releasePlan(QueryPlan plan) {
 // Plan maybe null if Driver.close is called in another thread for the same Driver object
 lDrvState.stateLock.lock();
 try {
  if (plan != null) {
   plan.setDone();
   if (SessionState.get() != null) {
    try {
     SessionState.get().getHiveHistory().logPlanProgress(plan);
    } catch (Exception e) {
     // Log and ignore
     LOG.warn("Could not log query plan progress", e);
    }
   }
  }
 } finally {
  lDrvState.stateLock.unlock();
 }
}

代码示例来源：origin: apache/drill

private void releasePlan(QueryPlan plan) {
 // Plan maybe null if Driver.close is called in another thread for the same Driver object
 lDrvState.stateLock.lock();
 try {
  if (plan != null) {
   plan.setDone();
   if (SessionState.get() != null) {
    try {
     SessionState.get().getHiveHistory().logPlanProgress(plan);
    } catch (Exception e) {
     // Log and ignore
     LOG.warn("Could not log query plan progress", e);
    }
   }
  }
 } finally {
  lDrvState.stateLock.unlock();
 }
}

代码示例来源：origin: apache/drill

/**
 * This method is called in the Driver on every task. It updates counters and calls execute(),
 * which is overridden in each task
 *
 * @return return value of execute()
 */
public int executeTask() {
 try {
  SessionState ss = SessionState.get();
  this.setStarted();
  if (ss != null) {
   ss.getHiveHistory().logPlanProgress(queryPlan);
  }
  int retval = execute(driverContext);
  this.setDone();
  if (ss != null) {
   ss.getHiveHistory().logPlanProgress(queryPlan);
  }
  return retval;
 } catch (IOException e) {
  throw new RuntimeException("Unexpected error: " + e.getMessage(), e);
 }
}

代码示例来源：origin: apache/hive

SessionState.get().getHiveHistory().logPlanProgress(plan);

代码示例来源：origin: apache/drill

SessionState.get().getHiveHistory().startQuery(queryStr,
  conf.getVar(HiveConf.ConfVars.HIVEQUERYID));
SessionState.get().getHiveHistory().logPlanProgress(plan);

代码示例来源：origin: com.facebook.presto.hive/hive-apache

@Override
public void logPlanProgress(SessionState ss) throws IOException {
 ss.getHiveHistory().logPlanProgress(queryPlan);
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

/**
 * This method is called in the Driver on every task. It updates counters and calls execute(),
 * which is overridden in each task
 *
 * @return return value of execute()
 */
public int executeTask() {
 try {
  SessionState ss = SessionState.get();
  this.setStarted();
  if (ss != null) {
   ss.getHiveHistory().logPlanProgress(queryPlan);
  }
  int retval = execute(driverContext);
  this.setDone();
  if (ss != null) {
   ss.getHiveHistory().logPlanProgress(queryPlan);
  }
  return retval;
 } catch (IOException e) {
  throw new RuntimeException("Unexpected error: " + e.getMessage(), e);
 }
}

代码示例来源：origin: org.apache.hadoop.hive/hive-exec

/**
 * This method is called in the Driver on every task. It updates counters and calls execute(),
 * which is overridden in each task
 *
 * @return return value of execute()
 */
public int executeTask() {
 try {
  SessionState ss = SessionState.get();
  this.setStarted();
  if (ss != null) {
   ss.getHiveHistory().logPlanProgress(queryPlan);
  }
  int retval = execute(driverContext);
  this.setDone();
  if (ss != null) {
   ss.getHiveHistory().logPlanProgress(queryPlan);
  }
  return retval;
 } catch (IOException e) {
  throw new RuntimeException(e.getMessage());
 }
}

代码示例来源：origin: org.apache.hadoop.hive/hive-exec

Keys.TASK_HADOOP_PROGRESS, output);
  ss.getHiveHistory().progressTask(SessionState.get().getQueryId(), this);
  ss.getHiveHistory().logPlanProgress(queryPlan);
ss.getHiveHistory().logPlanProgress(queryPlan);

代码示例来源：origin: org.apache.hadoop.hive/hive-exec

SessionState.get().getHiveHistory().startQuery(queryStr,
   conf.getVar(HiveConf.ConfVars.HIVEQUERYID));
 SessionState.get().getHiveHistory().logPlanProgress(plan);
 SessionState.get().getHiveHistory().logPlanProgress(plan);
} catch (Exception e) {

代码示例来源：origin: com.facebook.presto.hive/hive-apache

SessionState.get().getHiveHistory().startQuery(queryStr,
   conf.getVar(HiveConf.ConfVars.HIVEQUERYID));
 SessionState.get().getHiveHistory().logPlanProgress(plan);
try {
 SessionState.get().getLineageState().clear();
 SessionState.get().getHiveHistory().logPlanProgress(plan);
} catch (Exception e) {