本文整理了Java中org.apache.lens.server.api.query.QueryContext.isDriverPersistent
方法的一些代码示例,展示了QueryContext.isDriverPersistent
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryContext.isDriverPersistent
方法的具体详情如下:
包路径:org.apache.lens.server.api.query.QueryContext
类名称:QueryContext
方法名:isDriverPersistent
[英]The is driver persistent.
[中]驱动程序是持久的。
代码示例来源:origin: org.apache.lens/lens-server-api
public boolean isResultAvailableInDriver() {
// result is available in driver if driverStatus.isResultSetAvailable() - will be true for fetching inmemory
// result set.
// if result is persisted in driver driverStatus.isResultSetAvailable() will be false but isDriverPersistent will
// be true. So, for select queries, if result is persisted in driver, we return true so that the result can be
// fetched thru persistent resultset
return driverStatus.isSuccessful() && (isDriverPersistent() || driverStatus.isResultSetAvailable());
}
代码示例来源:origin: apache/lens
public boolean isResultAvailableInDriver() {
// result is available in driver if driverStatus.isResultSetAvailable() - will be true for fetching inmemory
// result set.
// if result is persisted in driver driverStatus.isResultSetAvailable() will be false but isDriverPersistent will
// be true. So, for select queries, if result is persisted in driver, we return true so that the result can be
// fetched thru persistent resultset
return driverStatus.isSuccessful() && (isDriverPersistent() || driverStatus.isResultSetAvailable());
}
代码示例来源:origin: apache/lens
boolean addInsertOverwrite = qdconf.getBoolean(
LensConfConstants.QUERY_ADD_INSERT_OVEWRITE, LensConfConstants.DEFAULT_ADD_INSERT_OVEWRITE);
if (context.isDriverPersistent() && addInsertOverwrite
&& (context.getSelectedDriverQuery().startsWith("SELECT")
|| context.getSelectedDriverQuery().startsWith("select"))) {
代码示例来源:origin: org.apache.lens/lens-driver-hive
boolean addInsertOverwrite = qdconf.getBoolean(
LensConfConstants.QUERY_ADD_INSERT_OVEWRITE, LensConfConstants.DEFAULT_ADD_INSERT_OVEWRITE);
if (context.isDriverPersistent() && addInsertOverwrite
&& (context.getSelectedDriverQuery().startsWith("SELECT")
|| context.getSelectedDriverQuery().startsWith("select"))) {
代码示例来源:origin: org.apache.lens/lens-driver-hive
/**
* Creates the result set.
*
* @param context the context
* @param closeAfterFetch the close after fetch
* @return the lens result set
* @throws LensException the lens exception
*/
private LensResultSet createResultSet(QueryContext context, boolean closeAfterFetch) throws LensException {
OperationHandle op = getHiveHandle(context.getQueryHandle());
log.info("Creating result set for hiveHandle:{}", op);
try {
if (context.isDriverPersistent()) {
return new HivePersistentResultSet(new Path(context.getDriverResultPath()), op, getClient());
} else if (op.hasResultSet()) {
return new HiveInMemoryResultSet(op, getClient(), closeAfterFetch);
} else {
// queries that do not have result
return null;
}
} catch (HiveSQLException hiveErr) {
handleHiveServerError(context, hiveErr);
throw new LensException("Error creating result set", hiveErr);
}
}
代码示例来源:origin: apache/lens
/**
* Creates the result set.
*
* @param context the context
* @param closeAfterFetch the close after fetch
* @return the lens result set
* @throws LensException the lens exception
*/
private LensResultSet createResultSet(QueryContext context, boolean closeAfterFetch) throws LensException {
OperationHandle op = getHiveHandle(context.getQueryHandle());
log.info("Creating result set for hiveHandle:{}", op);
try {
if (context.isDriverPersistent()) {
return new HivePersistentResultSet(new Path(context.getDriverResultPath()), op, getClient());
} else if (op.hasResultSet()) {
return new HiveInMemoryResultSet(op, getClient(), closeAfterFetch);
} else {
// queries that do not have result
return null;
}
} catch (HiveSQLException hiveErr) {
handleHiveServerError(context, hiveErr);
throw new LensException("Error creating result set", hiveErr);
}
}
代码示例来源:origin: apache/lens
if (qctx.isDriverPersistent()) {
assertTrue(qctx.getQueryOutputFormatter() instanceof PersistedOutputFormatter);
} else {
内容来源于网络,如有侵权,请联系作者删除!