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

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

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

QueryContext.<init>介绍

[英]Creates context from query
[中]从查询中创建上下文

代码示例

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

/**
 * Creates the context.
 *
 * @param pctx     the pctx
 * @param userName the user name
 * @param conf     the conf
 * @param qconf    the qconf
 * @return the query context
 * @throws LensException the lens exception
 */
protected QueryContext createContext(PreparedQueryContext pctx, String userName, LensConf conf, Configuration qconf,
  long timeOutMillis) throws LensException {
 QueryContext ctx = new QueryContext(pctx, userName, conf, qconf);
 ctx.setExecuteTimeoutMillis(timeOutMillis);
 return ctx;
}

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

/**
 * Creates the context.
 *
 * @param query    the query
 * @param userName the user name
 * @param conf     the conf
 * @param qconf    the qconf
 * @return the query context
 * @throws LensException the lens exception
 */
protected QueryContext createContext(String query, String userName, LensConf conf, Configuration qconf,
  long timeOutMillis) throws LensException {
 QueryContext ctx = new QueryContext(query, userName, conf, qconf, drivers.values());
 ctx.setExecuteTimeoutMillis(timeOutMillis);
 return ctx;
}

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

/**
 * Utility create method to create context with single driver.
 *
 * @param query The user query
 * @param user The submitted query
 * @param qconf The query lens conf
 * @param conf Query configuration object - merged with session
 * @param driver The driver
 * @param lensSessionPublicId The session id
 *
 * @return QueryContext object
 */
public static QueryContext createContextWithSingleDriver(String query, String user, LensConf qconf,
 Configuration conf, LensDriver driver, String lensSessionPublicId, boolean mergeDriverConf) {
 QueryContext ctx = new QueryContext(query, user, qconf, conf, Lists.newArrayList(driver), driver, mergeDriverConf);
 ctx.setLensSessionIdentifier(lensSessionPublicId);
 return ctx;
}

代码示例来源：origin: org.apache.lens/lens-server-api

/**
 * Utility create method to create context with single driver.
 *
 * @param query The user query
 * @param user The submitted query
 * @param qconf The query lens conf
 * @param conf Query configuration object - merged with session
 * @param driver The driver
 * @param lensSessionPublicId The session id
 *
 * @return QueryContext object
 */
public static QueryContext createContextWithSingleDriver(String query, String user, LensConf qconf,
 Configuration conf, LensDriver driver, String lensSessionPublicId, boolean mergeDriverConf) {
 QueryContext ctx = new QueryContext(query, user, qconf, conf, Lists.newArrayList(driver), driver, mergeDriverConf);
 ctx.setLensSessionIdentifier(lensSessionPublicId);
 return ctx;
}

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

private void assertIsCubeQuery(String query, LensConf lensConf, Configuration conf, List<LensDriver> drivers)
  throws LensException {
  List<RewriteUtil.CubeQueryInfo> cubeQueries = RewriteUtil.findCubePositions(query, hconf);
  Assert.assertEquals(cubeQueries.size(), 1);
  Assert.assertEquals(cubeQueries.get(0).query, query);
  QueryContext ctx = new QueryContext(query, null, lensConf, conf, drivers);
  runRewrites(RewriteUtil.rewriteQuery(ctx));
 }
}

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

private QueryContext createQueryContext(final String query, Configuration conf) throws LensException {
 QueryContext context = new QueryContext(query, "SA", new LensConf(), conf, drivers);
 return context;
}

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

protected QueryContext createContext(final String query, Configuration conf, LensDriver driver) throws LensException {
 QueryContext context = new QueryContext(query, "testuser", new LensConf(), conf, Arrays.asList(driver));
 // session id has to be set before calling setDriverQueriesAndPlans
 context.setLensSessionIdentifier(sessionid);
 return context;
}

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

protected QueryContext createContext(PreparedQueryContext query, Configuration conf) {
 QueryContext context = new QueryContext(query, "testuser", new LensConf(), conf);
 context.setLensSessionIdentifier(sessionid);
 return context;
}

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

protected QueryContext createContext(final String query, Configuration conf) throws LensException {
 QueryContext context = new QueryContext(query, "testuser", new LensConf(), conf, drivers);
 // session id has to be set before calling setDriverQueriesAndPlans
 context.setLensSessionIdentifier(sessionid);
 return context;
}

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

QueryContext ctx = new QueryContext(query, null, queryConf, conf, queryService.getDrivers());
Map<LensDriver, String> driverQueries = new HashMap<>();
for (LensDriver driver : queryService.getDrivers()) {

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

+ "group by fact.time_key,time_dim.day_of_week,time_dim.day " + "order by fact.time_key desc";
QueryContext context = new QueryContext(query, "SA", new LensConf(), baseConf, drivers);

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

+ "group by fact.time_key,time_dim.day_of_week,time_dim.day " + "order by fact.time_key  desc ";
QueryContext context = new QueryContext(query, "SA", new LensConf(), baseConf, drivers);
LensResultSet resultSet = driver.execute(context);
assertNotNull(resultSet);

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

@Test
public void testDriverEstimateSkippingForRewritefailure() throws LensException {
 Configuration conf = queryService.getLensConf(lensSessionId, new LensConf());
 QueryContext ctx = new QueryContext("cube select ID from nonexist", "user", new LensConf(), conf,
  queryService.getDrivers());
 for (LensDriver driver : queryService.getDrivers()) {
  ctx.setDriverRewriteError(driver, new LensException());
 }
 // All estimates should be skipped.
 Map<LensDriver, AbstractQueryContext.DriverEstimateRunnable> estimateRunnables = ctx.getDriverEstimateRunnables();
 for (LensDriver driver : estimateRunnables.keySet()) {
  estimateRunnables.get(driver).run();
  assertFalse(estimateRunnables.get(driver).isSucceeded(), driver + " estimate should have been skipped");
 }
 for (LensDriver driver : queryService.getDrivers()) {
  assertNull(ctx.getDriverQueryCost(driver));
 }
}

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

cubeQueries = RewriteUtil.findCubePositions(q1, hconf);
Assert.assertEquals(cubeQueries.size(), 0);
ctx = new QueryContext(q1, null, lensConf, conf, drivers);
runRewrites(RewriteUtil.rewriteQuery(ctx));
Assert.assertEquals(cubeQueries.size(), 1);
Assert.assertEquals(cubeQueries.get(0).query, q2);
ctx = new QueryContext(q2, null, lensConf, conf, drivers);
runRewrites(RewriteUtil.rewriteQuery(ctx));
MetricRegistry reg = LensMetricsRegistry.getStaticRegistry();
Assert.assertEquals(cubeQueries.size(), 1);
Assert.assertEquals(cubeQueries.get(0).query, "select name from cube_table");
ctx = new QueryContext(q2, null, lensConf, conf, drivers);
runRewrites(RewriteUtil.rewriteQuery(ctx));
Assert.assertEquals(cubeQueries.size(), 1);
Assert.assertEquals(cubeQueries.get(0).query, "select name from cube_table");
ctx = new QueryContext(q2, null, lensConf, conf, drivers);
runRewrites(RewriteUtil.rewriteQuery(ctx));
Assert.assertEquals(cubeQueries.size(), 1);
Assert.assertEquals(cubeQueries.get(0).query, "select id,name from cube_dim_table");
ctx = new QueryContext(q2, null, lensConf, conf, drivers);
runRewrites(RewriteUtil.rewriteQuery(ctx));
Assert.assertEquals(cubeQueries.size(), 1);
Assert.assertEquals(cubeQueries.get(0).query, "select name from cube_table");
ctx = new QueryContext(q2, null, lensConf, conf, drivers);

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

public void testInvalidQuery() throws Exception {
 final String query = "SELECT * FROM invalid_table";
 QueryContext ctx = new QueryContext(query, "SA", new LensConf(), baseConf, drivers);
 try {
  LensResultSet rs = driver.execute(ctx);

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

/**
 * Test connection close for failed queries.
 *
 * @throws Exception the exception
 */
@Test
public void testConnectionCloseForFailedQueries() throws Exception {
 createTable("invalid_conn_close");
 insertData("invalid_conn_close");
 final String query = "SELECT * from invalid_conn_close2";
 QueryContext ctx = new QueryContext(query, "SA", new LensConf(), baseConf, drivers);
 for (int i = 0; i < JDBC_POOL_MAX_SIZE.getDefaultValue(); i++) {
  executeAsync(ctx);
  driver.updateStatus(ctx);
  System.out.println("@@@@ QUERY " + (i + 1));
 }
 String validQuery = "SELECT * FROM invalid_conn_close";
 QueryContext validCtx = createQueryContext(validQuery);
 System.out.println("@@@ Submitting valid query");
 executeAsync(validCtx);
 // Wait for query to finish
 while (true) {
  driver.updateStatus(validCtx);
  if (validCtx.getDriverStatus().isFinished()) {
   break;
  }
  Thread.sleep(1000);
 }
 driver.closeQuery(validCtx.getQueryHandle());
}

代码示例来源：origin: org.apache.lens/lens-server-api

public QueryContext toQueryContext(Configuration conf, Collection<LensDriver> drivers) {
 if (null == selectedDriver && null != driverName) {
  selectedDriver = getDriverFromName(drivers);
 }
 QueryContext qctx =
  new QueryContext(userQuery, submitter, this.conf, conf, drivers, selectedDriver, submissionTime,
   false);
 qctx.setQueryHandle(QueryHandle.fromString(handle));
 qctx.setLaunchTime(this.startTime);
 qctx.setEndTime(getEndTime());
 qctx.setStatusSkippingTransitionTest(new QueryStatus(0.0, null, QueryStatus.Status.valueOf(getStatus()),
  null, getResult() != null, null, getErrorMessage() == null ? "" : getErrorMessage(), null));
 qctx.getDriverStatus().setDriverStartTime(getDriverStartTime());
 qctx.getDriverStatus().setDriverFinishTime(getDriverEndTime());
 qctx.setResultSetPath(getResult());
 qctx.setQueryName(getQueryName());
 if (null != driverQuery){
  qctx.setSelectedDriverQuery(driverQuery);
 }
 if (getPriority() != null) {
  qctx.setPriority(Priority.valueOf(getPriority()));
 }
 qctx.setFailedAttempts(getFailedAttempts());
 return qctx;
}

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

public QueryContext toQueryContext(Configuration conf, Collection<LensDriver> drivers) {
 if (null == selectedDriver && null != driverName) {
  selectedDriver = getDriverFromName(drivers);
 }
 QueryContext qctx =
  new QueryContext(userQuery, submitter, this.conf, conf, drivers, selectedDriver, submissionTime,
   false);
 qctx.setQueryHandle(QueryHandle.fromString(handle));
 qctx.setLaunchTime(this.startTime);
 qctx.setEndTime(getEndTime());
 qctx.setStatusSkippingTransitionTest(new QueryStatus(0.0, null, QueryStatus.Status.valueOf(getStatus()),
  null, getResult() != null, null, getErrorMessage() == null ? "" : getErrorMessage(), null));
 qctx.getDriverStatus().setDriverStartTime(getDriverStartTime());
 qctx.getDriverStatus().setDriverFinishTime(getDriverEndTime());
 qctx.setResultSetPath(getResult());
 qctx.setQueryName(getQueryName());
 if (null != driverQuery){
  qctx.setSelectedDriverQuery(driverQuery);
 }
 if (getPriority() != null) {
  qctx.setPriority(Priority.valueOf(getPriority()));
 }
 qctx.setFailedAttempts(getFailedAttempts());
 return qctx;
}

内容来源于网络，如有侵权，请联系作者删除！

QueryContext

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    QueryContext类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com