本文整理了Java中com.dremio.exec.ops.QueryContext.getCatalog
方法的一些代码示例,展示了QueryContext.getCatalog
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryContext.getCatalog
方法的具体详情如下:
包路径:com.dremio.exec.ops.QueryContext
类名称:QueryContext
方法名:getCatalog
暂无
代码示例来源:origin: dremio/dremio-oss
final CreateTableEntry createTableEntry = context.getCatalog()
.resolveCatalog(SystemUser.SYSTEM_USERNAME)
.createNewTable(new NamespaceKey(storeTable), WriterOptions.DEFAULT, storageOptions);
代码示例来源: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
final CreateTableEntry createTableEntry = context.getCatalog()
.resolveCatalog(SystemUser.SYSTEM_USERNAME)
.createNewTable(new NamespaceKey(storeTable), writerOptions, storageOptions);
代码示例来源:origin: dremio/dremio-oss
final RelNode intermediateNode = transform(config, PlannerType.VOLCANO, PlannerPhase.LOGICAL, preLog, logicalTraits, true);
final Catalog catalog = config.getContext().getCatalog();
if (catalog instanceof CachingCatalog) {
config.getObserver().tablesCollected(catalog.getAllRequestedTables());
代码示例来源:origin: dremio/dremio-oss
final RelNode queryRelNode = convertedRelNode.getConvertedNode();
final RelNode newViewRelNode = SqlHandlerUtil.resolveNewTableRel(true, createView.getFieldNames(), validatedRowType, queryRelNode);
Catalog catalog = config.getContext().getCatalog();
NamespaceKey viewPath = catalog.resolveSingle(createView.getPath());
NamespaceKey defaultSchema = catalog.getDefaultSchema();
final DremioTable existingTable = config.getContext().getCatalog().getTableNoResolve(viewPath);
List<String> viewContext = defaultSchema == null ? null : defaultSchema.getPathComponents();
config.getContext().getCatalog().updateView(viewPath, view);
replaced = true;
} else {
config.getContext().getCatalog().createView(viewPath, view);
代码示例来源:origin: dremio/dremio-oss
Iterable<DremioTable> requestedTables = sqlHandlerConfig.getContext().getCatalog().getAllRequestedTables();
代码示例来源:origin: dremio/dremio-oss
final long ringCount = config.getContext().getOptions().getOption(PlannerSettings.RING_COUNT);
final Rel writerDrel = new WriterRel(drel.getCluster(), drel.getCluster().traitSet().plus(Rel.LOGICAL),
drel, config.getContext().getCatalog().createNewTable(
new NamespaceKey(ReflectionUtils.getMaterializationPath(newMaterialization)),
getWriterOptions((int) ringCount, goal, fields), ImmutableMap.of()),
代码示例来源:origin: dremio/dremio-oss
optionManager.getOption(PlannerSettings.INCLUDE_DATASET_PROFILE), this.queryContext.getCatalog());
代码示例来源: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
drel, config.getContext().getCatalog().createNewTable(
new NamespaceKey(tablePath),
getWriterOptions(0, goal, fields), ImmutableMap.of()
代码示例来源:origin: dremio/dremio-oss
queryContext.getSession(),
observer,
queryContext.getCatalog(),
queryContext.getSubstitutionProviderFactory(),
queryContext.getConfig(),
代码示例来源: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
queryContext.getSession(),
observer,
queryContext.getCatalog(),
queryContext.getSubstitutionProviderFactory(),
queryContext.getConfig(),
代码示例来源:origin: dremio/dremio-oss
final Catalog catalog = config.getContext().getCatalog();
final NamespaceKey path = catalog.resolveSingle(sqlCreateTable.getPath());
DremioTable table = catalog.getTableNoResolve(path);
代码示例来源:origin: dremio/dremio-oss
context.getSession(),
observer,
context.getCatalog(),
context.getSubstitutionProviderFactory(),
context.getConfig(),
final Catalog catalog = context.getCatalog();
final SqlNode sqlNode = parser.parse(sql);
final SqlHandlerConfig config = new SqlHandlerConfig(context, parser, observer, parser.getMaterializations());
内容来源于网络,如有侵权,请联系作者删除!