com.dremio.exec.ops.QueryContext.getSubstitutionProviderFactory()方法的使用及代码示例

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

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

QueryContext.getSubstitutionProviderFactory介绍

暂无

代码示例

代码示例来源:origin: dremio/dremio-oss

ExpansionHelper(QueryContext context) {
 this.context = Preconditions.checkNotNull(context, "query context required");
 converter = new SqlConverter(
  context.getPlannerSettings(),
  context.getOperatorTable(),
  context,
  MaterializationDescriptorProvider.EMPTY,
  context.getFunctionRegistry(),
  context.getSession(),
  AbstractAttemptObserver.NOOP,
  context.getCatalog(),
  context.getSubstitutionProviderFactory(),
  context.getConfig(),
  context.getScanResult());
}

代码示例来源:origin: dremio/dremio-oss

private SqlConverter getNewConverter(QueryContext context, SqlQuery query, AttemptObserver observerForSubstitution) {
 Catalog catalog = context.getCatalog();
 final List<String> sqlContext = query.getContext();
 if(sqlContext != null){
  NamespaceKey path = new NamespaceKey(sqlContext);
  try {
   catalog = catalog.resolveCatalog(path);
  } catch (Exception e) {
   throw UserException.validationError(e)
    .message("Unable to resolve schema path [%s]. Failure resolving [%s] portion of path.", sqlContext, path)
    .build(logger);
  }
 }
 return new SqlConverter(
   context.getPlannerSettings(),
   context.getOperatorTable(),
   context,
   context.getMaterializationProvider(),
   context.getFunctionRegistry(),
   context.getSession(),
   observerForSubstitution,
   catalog,
   context.getSubstitutionProviderFactory(),
   context.getConfig(),
   context.getScanResult());
}

代码示例来源:origin: dremio/dremio-oss

observer,
queryContext.getCatalog(),
queryContext.getSubstitutionProviderFactory(),
queryContext.getConfig(),
queryContext.getScanResult());

代码示例来源:origin: dremio/dremio-oss

protected ElasticsearchGroupScan generate(String sql) throws Exception {
 AttemptObserver observer = new PassthroughQueryObserver(ExecTest.mockUserClientConnection(null));
 SqlConverter converter = new SqlConverter(context.getPlannerSettings(),
  context.getOperatorTable(), context, context.getMaterializationProvider(), context.getFunctionRegistry(),
  context.getSession(), observer, context.getCatalog(), context.getSubstitutionProviderFactory(), context.getConfig(),
  context.getScanResult());
 SqlNode node = converter.parse(sql);
 SqlHandlerConfig config = new SqlHandlerConfig(context, converter, observer, null);
 NormalHandler handler = new NormalHandler();
 PhysicalPlan plan = handler.getPlan(config, sql, node);
 List<PhysicalOperator> operators = plan.getSortedOperators();
 ElasticsearchGroupScan scan = find(operators);
 assertNotNull("Physical plan does not contain an elasticsearch scan for query: " + sql, scan);
 return scan;
}

代码示例来源:origin: dremio/dremio-oss

observer,
queryContext.getCatalog(),
queryContext.getSubstitutionProviderFactory(),
queryContext.getConfig(),
queryContext.getScanResult());

代码示例来源:origin: dremio/dremio-oss

observer,
context.getCatalog(),
context.getSubstitutionProviderFactory(),
context.getConfig(),
context.getScanResult());

相关文章