本文整理了Java中com.dremio.exec.ops.QueryContext.getNonDefaultOptions
方法的一些代码示例,展示了QueryContext.getNonDefaultOptions
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryContext.getNonDefaultOptions
方法的具体详情如下:
包路径:com.dremio.exec.ops.QueryContext
类名称:QueryContext
方法名:getNonDefaultOptions
[英]Return the list of all non-default options including QUERY, SESSION and SYSTEM level
[中]返回所有非默认选项的列表,包括查询、会话和系统级别
代码示例来源:origin: dremio/dremio-oss
@Before
public void setUp() {
MockitoAnnotations.initMocks(this);
// Boilerplate
AccelerationManager accelerationManager = mock(AccelerationManager.class);
AccelerationDetailsPopulator populator = mock(AccelerationDetailsPopulator.class);
when(populator.computeAcceleration()).thenReturn(ByteString.EMPTY_BYTE_ARRAY);
when(accelerationManager.newPopulator()).thenReturn(populator);
when(context.getAccelerationManager()).thenReturn(accelerationManager);
when(context.getQueryUserName()).thenReturn("myuser");
when(context.getSession()).thenReturn(UserSession.Builder.newBuilder().build());
when(context.getNonDefaultOptions()).thenReturn(new OptionList());
when(catalog.getMetadataStatsCollector()).thenReturn(new MetadataStatsCollector());
}
代码示例来源:origin: dremio/dremio-oss
public QueryManager(
final QueryId queryId,
final QueryContext context,
final CoordToExecTunnelCreator tunnelCreator,
final CompletionListener completionListener,
final Pointer<QueryId> prepareId,
final AttemptObservers observers,
final boolean verboseProfiles,
final boolean includeDatasetProfiles,
final Catalog catalog) {
this.queryId = queryId;
this.tunnelCreator = tunnelCreator;
this.completionListener = completionListener;
this.context = context;
this.prepareId = prepareId;
this.catalog = catalog;
this.nonDefaultOptions = context.getNonDefaultOptions();
resourceAllocationResultObserver = new ResourceAllocationResultObserver();
observers.add(resourceAllocationResultObserver);
capturer = new PlanCaptureAttemptObserver(verboseProfiles, includeDatasetProfiles, context.getFunctionRegistry(),
context.getAccelerationManager().newPopulator());
observers.add(capturer);
observers.add(new TimeMarker());
}
代码示例来源:origin: dremio/dremio-oss
final SimpleParallelizer parallelizer = new SimpleParallelizer(queryContext, observer);
final OptionList fragmentOptions = queryContext.getNonDefaultOptions();
代码示例来源:origin: dremio/dremio-oss
final OptionList fragmentOptions = queryContext.getNonDefaultOptions();
内容来源于网络,如有侵权,请联系作者删除!