org.apache.hadoop.hive.ql.history.HiveHistory.setQueryProperty()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(3.2k)|赞(0)|评价(0)|浏览(70)

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

HiveHistory.setQueryProperty介绍

[英]Used to set query status and other attributes of a query
[中]用于设置查询状态和查询的其他属性

代码示例

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

private void addToHistory(Keys key, String value) {
 if (SessionState.get() != null) {
  SessionState.get().getHiveHistory().setQueryProperty(queryState.getQueryId(), key, value);
 }
}

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

private void addToHistory(SparkJobRef jobRef) {
 console.printInfo("Starting Spark Job = " + jobRef.getJobId());
 if (SessionState.get() != null) {
  SessionState.get().getHiveHistory()
  .setQueryProperty(queryState.getQueryId(), Keys.SPARK_JOB_ID, jobRef.getJobId());
 }
}

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

SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_NUM_TASKS,
  String.valueOf(jobs));
SessionState.get().getHiveHistory().setIdToTableMap(plan.getIdToTableNameMap());
SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_RET_CODE,
  String.valueOf(0));
SessionState.get().getHiveHistory().printRowCount(queryId);
SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_RET_CODE,
  String.valueOf(12));

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

SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_NUM_TASKS,
  String.valueOf(jobs));
SessionState.get().getHiveHistory().setIdToTableMap(plan.getIdToTableNameMap());
SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_RET_CODE,
  String.valueOf(0));
SessionState.get().getHiveHistory().printRowCount(queryId);
SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_RET_CODE,
  String.valueOf(12));

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

private void addToHistory(SparkJobRef jobRef) {
 console.printInfo("Starting Spark Job = " + jobRef.getJobId());
 if (SessionState.get() != null) {
  SessionState.get().getHiveHistory()
  .setQueryProperty(SessionState.get().getQueryId(), Keys.SPARK_JOB_ID, jobRef.getJobId());
 }
}

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

SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_NUM_TASKS,
  String.valueOf(jobs));
SessionState.get().getHiveHistory().setIdToTableMap(plan.getIdToTableNameMap());
SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_RET_CODE,
  String.valueOf(0));
SessionState.get().getHiveHistory().printRowCount(queryId);
SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_RET_CODE,
  String.valueOf(12));

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

SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_NUM_TASKS,
   String.valueOf(jobs));
 SessionState.get().getHiveHistory().setIdToTableMap(plan.getIdToTableNameMap());
 SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_RET_CODE,
   String.valueOf(0));
 SessionState.get().getHiveHistory().printRowCount(queryId);
ctx.restoreOriginalTracker();
if (SessionState.get() != null) {
 SessionState.get().getHiveHistory().setQueryProperty(queryId, Keys.QUERY_RET_CODE,
   String.valueOf(12));

相关文章