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

QueryStats.getWrittenPositions介绍

暂无

代码示例

代码示例来源：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(gcStatistics.getAverageFullGcSec(), 107);
assertEquals(420, actual.getWrittenPositions());
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");
}