本文整理了Java中com.facebook.presto.memory.QueryContext.getMemoryPool
方法的一些代码示例,展示了QueryContext.getMemoryPool
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryContext.getMemoryPool
方法的具体详情如下:
包路径:com.facebook.presto.memory.QueryContext
类名称:QueryContext
方法名:getMemoryPool
暂无
代码示例来源:origin: prestodb/presto
private long getMemoryAlreadyBeingRevoked(Collection<SqlTask> sqlTasks, MemoryPool memoryPool)
{
return sqlTasks.stream()
.filter(task -> task.getTaskStatus().getState() == TaskState.RUNNING)
.filter(task -> task.getQueryContext().getMemoryPool() == memoryPool)
.mapToLong(task -> task.getQueryContext().accept(new TraversingQueryContextVisitor<Void, Long>()
{
@Override
public Long visitOperatorContext(OperatorContext operatorContext, Void context)
{
if (operatorContext.isMemoryRevokingRequested()) {
return operatorContext.getReservedRevocableBytes();
}
return 0L;
}
@Override
public Long mergeResults(List<Long> childrenResults)
{
return childrenResults.stream()
.mapToLong(i -> i).sum();
}
}, null))
.sum();
}
代码示例来源:origin: prestodb/presto
sqlTasks.stream()
.filter(task -> task.getTaskStatus().getState() == TaskState.RUNNING)
.filter(task -> task.getQueryContext().getMemoryPool() == memoryPool)
.sorted(ORDER_BY_CREATE_TIME)
.forEach(task -> task.getQueryContext().accept(new VoidTraversingQueryContextVisitor<AtomicLong>()
代码示例来源:origin: prestodb/presto
@BeforeMethod
public void setUp()
{
executor = newCachedThreadPool(daemonThreadsNamed("test-executor-%s"));
scheduledExecutor = newScheduledThreadPool(2, daemonThreadsNamed("test-scheduledExecutor-%s"));
TaskContext taskContext = TestingTaskContext.builder(executor, scheduledExecutor, TEST_SESSION)
.setQueryMaxMemory(DataSize.valueOf("100MB"))
.setMemoryPoolSize(DataSize.valueOf("10B"))
.setQueryId(QUERY_ID)
.build();
memoryPool = taskContext.getQueryContext().getMemoryPool();
driverContext = taskContext
.addPipelineContext(0, true, true, false)
.addDriverContext();
}
内容来源于网络,如有侵权,请联系作者删除!