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

QueryContext.getCatalogService介绍

暂无

代码示例

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

public RuleSet getRules(PlannerPhase phase) {
 return PlannerPhase.mergedRuleSets(
   phase.getRules(context),
   context.getCatalogService().getStorageRules(context, phase));
}

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

@Override
public PhysicalOperator getPhysicalOperator(PhysicalPlanCreator creator) throws IOException {
 Prel child = (Prel) this.getInput();
 PhysicalOperator childPOP = child.getPhysicalOperator(creator);
 DictionaryLookupPOP dictionaryLookupPOP = new DictionaryLookupPOP(creator.getContext().getCatalogService(), childPOP, dictionaryEncodedFields);
 return creator.addMetadata(this, dictionaryLookupPOP);
}

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

context.getCatalogService()
 .getCatalog(SchemaConfig.newBuilder(SystemUser.SYSTEM_USERNAME).build())
  .createDataset(new NamespaceKey(getMaterializationPath(materialization)), datasetMutator);

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

protected QueryContext mockQueryContext(SabotContext dbContext) throws Exception {
 final UserSession userSession = UserSession.Builder.newBuilder().withOptionManager(dbContext.getOptionManager()).build();
 final SessionOptionManager sessionOptions = (SessionOptionManager) userSession.getOptions();
 final QueryOptionManager queryOptions = new QueryOptionManager(sessionOptions);
 final ExecutionControls executionControls = new ExecutionControls(queryOptions, NodeEndpoint.getDefaultInstance());
 final OperatorTable table = new OperatorTable(FUNCTIONS());
 final LogicalPlanPersistence lp = dbContext.getLpPersistence();
 final CatalogService registry = dbContext.getCatalogService();
 final QueryContext context = Mockito.mock(QueryContext.class);
 when(context.getSession()).thenReturn(userSession);
 when(context.getLpPersistence()).thenReturn(lp);
 when(context.getCatalogService()).thenReturn(registry);
 when(context.getFunctionRegistry()).thenReturn(FUNCTIONS());
 when(context.getSession()).thenReturn(UserSession.Builder.newBuilder().setSupportComplexTypes(true).build());
 when(context.getCurrentEndpoint()).thenReturn(NodeEndpoint.getDefaultInstance());
 when(context.getActiveEndpoints()).thenReturn(ImmutableList.of(NodeEndpoint.getDefaultInstance()));
 when(context.getPlannerSettings()).thenReturn(new PlannerSettings(dbContext.getConfig(), queryOptions, dbContext.getClusterResourceInformation()));
 when(context.getOptions()).thenReturn(queryOptions);
 when(context.getConfig()).thenReturn(DEFAULT_SABOT_CONFIG);
 when(context.getOperatorTable()).thenReturn(table);
 when(context.getAllocator()).thenReturn(allocator);
 when(context.getExecutionControls()).thenReturn(executionControls);
 when(context.getMaterializationProvider()).thenReturn(Mockito.mock(MaterializationDescriptorProvider.class));
 return context;
}