本文整理了Java中org.apache.hadoop.hive.ql.Driver.rollback()
方法的一些代码示例,展示了Driver.rollback()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Driver.rollback()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.Driver
类名称:Driver
方法名:rollback
暂无
代码示例来源:origin: apache/hive
public void lockAndRespond() throws CommandProcessorResponse {
// Assumes the query has already been compiled
if (plan == null) {
throw new IllegalStateException(
"No previously compiled query for driver - queryId=" + queryState.getQueryId());
}
if (requiresLock()) {
try {
acquireLocks();
} catch (CommandProcessorResponse cpr) {
rollback(cpr);
throw cpr;
}
}
}
代码示例来源:origin: apache/drill
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()));
return rollback(createProcessorResponse(ret));
if (ret != 0) {
return rollback(createProcessorResponse(ret));
代码示例来源:origin: apache/hive
execute();
} catch (CommandProcessorResponse cpr) {
rollback(cpr);
throw cpr;
内容来源于网络,如有侵权,请联系作者删除!