org.apache.hadoop.hive.ql.QueryPlan.getOperationName()方法的使用及代码示例

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

QueryPlan.getOperationName介绍

暂无

代码示例

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

public String getOperationName() {
return queryPlan.getOperationName();
}

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

public String getOperationName() {
return queryPlan.getOperationName();
}

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

private void markExplicitTransaction(QueryPlan queryPlan) throws LockException {
isExplicitTransaction = true;
if(++startTransactionCount > 1) {
throw new LockException(null, ErrorMsg.OP_NOT_ALLOWED_IN_TXN, queryPlan.getOperationName(),
JavaUtils.txnIdToString(getCurrentTxnId()), queryPlan.getQueryId());
}
}
/**

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

return;
if (!includedOperationSet.contains(plan.getOperationName())) {
LOG.debug("Not logging events of operation type : {}", plan.getOperationName());
return;

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

SessionState ss = SessionState.get();
if (ss != null && index != null
&& OPERATION_NAMES.contains(plan.getOperationName())
&& !plan.isExplain()) {
try {

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

throw new LockException("No transaction context for operation: " + queryPlan.getOperationName() +
" for " + getQueryIdWaterMark(queryPlan));
case ROLLBACK:
if(!isTxnOpen()) {
throw new LockException(null, ErrorMsg.OP_NOT_ALLOWED_WITHOUT_TXN, queryPlan.getOperationName());
throw new LockException(null, ErrorMsg.OP_NOT_ALLOWED_IN_IMPLICIT_TXN, queryPlan.getOperationName());
throw new LockException(null, ErrorMsg.OP_NOT_ALLOWED_IN_TXN, queryPlan.getOperationName(),
JavaUtils.txnIdToString(getCurrentTxnId()), queryPlan.getQueryId());

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

SessionState ss = SessionState.get();
if (ss != null && index != null
&& OPERATION_NAMES.contains(plan.getOperationName())
&& !plan.isExplain()) {
try {

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

String opName = plan.getOperationName();
boolean isReplicatiOnOperation= opName.equals(HiveOperation.REPLDUMP.getOperationName())
|| opName.equals(HiveOperation.REPLLOAD.getOperationName());

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

assert !txnManager.getAutoCommit() : "didn't expect AC=true";
return rollback(new CommandProcessorResponse(12, ErrorMsg.OP_NOT_ALLOWED_IN_TXN, null,
plan.getOperationName(), Long.toString(txnManager.getCurrentTxnId())));
return rollback(new CommandProcessorResponse(12, ErrorMsg.OP_NOT_ALLOWED_WITHOUT_TXN, null, plan.getOperationName()));
return rollback(new CommandProcessorResponse(12, ErrorMsg.OP_NOT_ALLOWED_IN_AUTOCOMMIT, null, plan.getOperationName()));

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

public String getOperationName() {
return queryPlan.getOperationName();
}

代码示例来源：origin: airbnb/reair

/**
* Creates a lightweight representation of the session state.
*
* @param plan The Hive query plan
*/
public SessionStateLite(QueryPlan plan) {
SessionState sessiOnState= SessionState.get();
this.cOnf= new HiveConf(sessionState.getConf());
this.cmd = plan.getQueryStr();
this.commandType = plan.getOperationName();
this.queryId = plan.getQueryId();
this.mapRedStats = new HashMap<>(sessionState.getMapRedStats());
}

代码示例来源：origin: airbnb/reair

/**
* Creates a lightweight representation of the session state.
*
* @param plan The Hive query plan
*/
public SessionStateLite(QueryPlan plan) {
SessionState sessiOnState= SessionState.get();
this.cOnf= new HiveConf(sessionState.getConf());
this.cmd = plan.getQueryStr();
this.commandType = plan.getOperationName();
this.queryId = plan.getQueryId();
this.mapRedStats = new HashMap<>(sessionState.getMapRedStats());
}