本文整理了Java中com.facebook.presto.execution.QueryStats.getLogicalWrittenDataSize
方法的一些代码示例,展示了QueryStats.getLogicalWrittenDataSize
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryStats.getLogicalWrittenDataSize
方法的具体详情如下:
包路径:com.facebook.presto.execution.QueryStats
类名称:QueryStats
方法名:getLogicalWrittenDataSize
暂无
代码示例来源:origin: prestodb/presto
private QueryStatistics createQueryStatistics(QueryInfo queryInfo)
{
ImmutableList.Builder<String> operatorSummaries = ImmutableList.builder();
for (OperatorStats summary : queryInfo.getQueryStats().getOperatorSummaries()) {
operatorSummaries.add(operatorStatsCodec.toJson(summary));
}
QueryStats queryStats = queryInfo.getQueryStats();
return new QueryStatistics(
ofMillis(queryStats.getTotalCpuTime().toMillis()),
ofMillis(queryStats.getTotalScheduledTime().toMillis()),
ofMillis(queryStats.getQueuedTime().toMillis()),
Optional.of(ofMillis(queryStats.getAnalysisTime().toMillis())),
Optional.of(ofMillis(queryStats.getDistributedPlanningTime().toMillis())),
queryStats.getPeakUserMemoryReservation().toBytes(),
queryStats.getPeakTotalMemoryReservation().toBytes(),
queryStats.getPeakTaskTotalMemory().toBytes(),
queryStats.getRawInputDataSize().toBytes(),
queryStats.getRawInputPositions(),
queryStats.getOutputDataSize().toBytes(),
queryStats.getOutputPositions(),
queryStats.getLogicalWrittenDataSize().toBytes(),
queryStats.getWrittenPositions(),
queryStats.getCumulativeUserMemory(),
queryStats.getStageGcStatistics(),
queryStats.getCompletedDrivers(),
queryInfo.isCompleteInfo(),
getCpuDistributions(queryInfo),
operatorSummaries.build());
}
代码示例来源:origin: prestodb/presto
@Test
public void testWrittenStats()
{
String sql = "CREATE TABLE test_written_stats AS SELECT * FROM nation";
DistributedQueryRunner distributedQueryRunner = (DistributedQueryRunner) getQueryRunner();
ResultWithQueryId<MaterializedResult> resultResultWithQueryId = distributedQueryRunner.executeWithQueryId(getSession(), sql);
QueryInfo queryInfo = distributedQueryRunner.getQueryInfo(resultResultWithQueryId.getQueryId());
assertEquals(queryInfo.getQueryStats().getOutputPositions(), 1L);
assertEquals(queryInfo.getQueryStats().getWrittenPositions(), 25L);
assertTrue(queryInfo.getQueryStats().getLogicalWrittenDataSize().toBytes() > 0L);
sql = "INSERT INTO test_written_stats SELECT * FROM nation LIMIT 10";
resultResultWithQueryId = distributedQueryRunner.executeWithQueryId(getSession(), sql);
queryInfo = distributedQueryRunner.getQueryInfo(resultResultWithQueryId.getQueryId());
assertEquals(queryInfo.getQueryStats().getOutputPositions(), 1L);
assertEquals(queryInfo.getQueryStats().getWrittenPositions(), 10L);
assertTrue(queryInfo.getQueryStats().getLogicalWrittenDataSize().toBytes() > 0L);
assertUpdate("DROP TABLE test_written_stats");
}
代码示例来源:origin: prestodb/presto
assertEquals(58, actual.getLogicalWrittenDataSize().toBytes());
代码示例来源:origin: com.facebook.presto/presto-tests
@Test
public void testWrittenStats()
{
String sql = "CREATE TABLE test_written_stats AS SELECT * FROM nation";
DistributedQueryRunner distributedQueryRunner = (DistributedQueryRunner) getQueryRunner();
ResultWithQueryId<MaterializedResult> resultResultWithQueryId = distributedQueryRunner.executeWithQueryId(getSession(), sql);
QueryInfo queryInfo = distributedQueryRunner.getQueryInfo(resultResultWithQueryId.getQueryId());
assertEquals(queryInfo.getQueryStats().getOutputPositions(), 1L);
assertEquals(queryInfo.getQueryStats().getWrittenPositions(), 25L);
assertTrue(queryInfo.getQueryStats().getLogicalWrittenDataSize().toBytes() > 0L);
sql = "INSERT INTO test_written_stats SELECT * FROM nation LIMIT 10";
resultResultWithQueryId = distributedQueryRunner.executeWithQueryId(getSession(), sql);
queryInfo = distributedQueryRunner.getQueryInfo(resultResultWithQueryId.getQueryId());
assertEquals(queryInfo.getQueryStats().getOutputPositions(), 1L);
assertEquals(queryInfo.getQueryStats().getWrittenPositions(), 10L);
assertTrue(queryInfo.getQueryStats().getLogicalWrittenDataSize().toBytes() > 0L);
assertUpdate("DROP TABLE test_written_stats");
}
内容来源于网络,如有侵权,请联系作者删除!