org.apache.lens.server.api.query.QueryContext.isDriverPersistent()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(3.9k)|赞(0)|评价(0)|浏览(75)

本文整理了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

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 {

相关文章

微信公众号

最新文章

更多