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

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

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

QueryContext.getDriverQueryCost介绍

暂无

代码示例

代码示例来源: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

ctx.setOlapQuery(true);
Priority priority = driver.decidePriority(ctx);
assertEquals(priority, expected, "cost: " + ctx.getDriverQueryCost(driver) + "priority: " + priority);
assertEquals(ctx.getConf().get("mapred.job.priority"), priority.toString());
assertEquals(driver.decidePriority(ctx, alwaysNormalPriorityDecider), Priority.NORMAL);

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

ctx.setDriverCost(driver, driver.queryCostCalculator.calculateCost(ctx, driver));
assertEquals(driver.decidePriority(ctx), Priority.VERY_HIGH);
assertEquals(alwaysNormalPriorityDecider.decidePriority(ctx.getDriverQueryCost(driver)), Priority.NORMAL);

相关文章

微信公众号

最新文章

更多