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

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

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

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();

相关文章