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

Distribution.snapshot介绍

暂无

代码示例

代码示例来源：origin: prestodb/presto

private static DistributionSnapshot getTestDistribution(int count)
  {
    Distribution distribution = new Distribution();
    for (int i = 0; i < count; i++) {
      distribution.add(i);
    }
    return distribution.snapshot();
  }
}

代码示例来源：origin: prestodb/presto

private static DistributionSnapshot getTestDistribution(int count)
  {
    Distribution distribution = new Distribution();
    for (int i = 0; i < count; i++) {
      distribution.add(i);
    }
    return distribution.snapshot();
  }
}

代码示例来源：origin: prestodb/presto

succinctBytes(pipelineMemoryContext.getSystemMemory()),
queuedTime.snapshot(),
elapsedTime.snapshot(),

代码示例来源：origin: prestodb/presto

getSplitDistribution.snapshot(),

代码示例来源：origin: prestodb/presto

private static StageCpuDistribution computeCpuDistribution(StageInfo stageInfo)
  {
    Distribution cpuDistribution = new Distribution();

    for (TaskInfo taskInfo : stageInfo.getTasks()) {
      cpuDistribution.add(taskInfo.getStats().getTotalCpuTime().toMillis());
    }

    DistributionSnapshot snapshot = cpuDistribution.snapshot();

    return new StageCpuDistribution(
        stageInfo.getStageId().getId(),
        stageInfo.getTasks().size(),
        snapshot.getP25(),
        snapshot.getP50(),
        snapshot.getP75(),
        snapshot.getP90(),
        snapshot.getP95(),
        snapshot.getP99(),
        snapshot.getMin(),
        snapshot.getMax(),
        (long) snapshot.getTotal(),
        snapshot.getTotal() / snapshot.getCount());
  }
}

代码示例来源：origin: airlift/airlift

public DistributionStatSnapshot snapshot()
{
  return new DistributionStatSnapshot(
      getOneMinute().snapshot(),
      getFiveMinutes().snapshot(),
      getFifteenMinutes().snapshot(),
      getAllTime().snapshot());
}

代码示例来源：origin: io.airlift/stats

public DistributionStatSnapshot snapshot()
{
  return new DistributionStatSnapshot(
      getOneMinute().snapshot(),
      getFiveMinutes().snapshot(),
      getFifteenMinutes().snapshot(),
      getAllTime().snapshot());
}

代码示例来源：origin: io.prestosql/presto-main

private static DistributionSnapshot getTestDistribution(int count)
  {
    Distribution distribution = new Distribution();
    for (int i = 0; i < count; i++) {
      distribution.add(i);
    }
    return distribution.snapshot();
  }
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

private static DistributionSnapshot getTestDistribution(int count)
  {
    Distribution distribution = new Distribution();
    for (int i = 0; i < count; i++) {
      distribution.add(i);
    }
    return distribution.snapshot();
  }
}

代码示例来源：origin: prestosql/presto

private static DistributionSnapshot getTestDistribution(int count)
  {
    Distribution distribution = new Distribution();
    for (int i = 0; i < count; i++) {
      distribution.add(i);
    }
    return distribution.snapshot();
  }
}

代码示例来源：origin: io.prestosql/presto-main

private static DistributionSnapshot getTestDistribution(int count)
  {
    Distribution distribution = new Distribution();
    for (int i = 0; i < count; i++) {
      distribution.add(i);
    }
    return distribution.snapshot();
  }
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

private static DistributionSnapshot getTestDistribution(int count)
  {
    Distribution distribution = new Distribution();
    for (int i = 0; i < count; i++) {
      distribution.add(i);
    }
    return distribution.snapshot();
  }
}

代码示例来源：origin: prestosql/presto

private static DistributionSnapshot getTestDistribution(int count)
  {
    Distribution distribution = new Distribution();
    for (int i = 0; i < count; i++) {
      distribution.add(i);
    }
    return distribution.snapshot();
  }
}

代码示例来源：origin: prestosql/presto

succinctBytes(pipelineMemoryContext.getSystemMemory()),
queuedTime.snapshot(),
elapsedTime.snapshot(),

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

new DataSize(systemMemoryReservation.get(), BYTE).convertToMostSuccinctDataSize(),
queuedTime.snapshot(),
elapsedTime.snapshot(),

代码示例来源：origin: io.prestosql/presto-main

succinctBytes(pipelineMemoryContext.getSystemMemory()),
queuedTime.snapshot(),
elapsedTime.snapshot(),

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

getSplitDistribution.snapshot(),
scheduleTaskDistribution.snapshot(),
addSplitDistribution.snapshot(),

代码示例来源：origin: prestosql/presto

getSplitDistribution.snapshot(),

代码示例来源：origin: io.prestosql/presto-main

private static StageCpuDistribution computeCpuDistribution(StageInfo stageInfo)
  {
    Distribution cpuDistribution = new Distribution();

    for (TaskInfo taskInfo : stageInfo.getTasks()) {
      cpuDistribution.add(taskInfo.getStats().getTotalCpuTime().toMillis());
    }

    DistributionSnapshot snapshot = cpuDistribution.snapshot();

    return new StageCpuDistribution(
        stageInfo.getStageId().getId(),
        stageInfo.getTasks().size(),
        snapshot.getP25(),
        snapshot.getP50(),
        snapshot.getP75(),
        snapshot.getP90(),
        snapshot.getP95(),
        snapshot.getP99(),
        snapshot.getMin(),
        snapshot.getMax(),
        (long) snapshot.getTotal(),
        snapshot.getTotal() / snapshot.getCount());
  }
}

代码示例来源：origin: prestosql/presto

private static StageCpuDistribution computeCpuDistribution(StageInfo stageInfo)
  {
    Distribution cpuDistribution = new Distribution();

    for (TaskInfo taskInfo : stageInfo.getTasks()) {
      cpuDistribution.add(taskInfo.getStats().getTotalCpuTime().toMillis());
    }

    DistributionSnapshot snapshot = cpuDistribution.snapshot();

    return new StageCpuDistribution(
        stageInfo.getStageId().getId(),
        stageInfo.getTasks().size(),
        snapshot.getP25(),
        snapshot.getP50(),
        snapshot.getP75(),
        snapshot.getP90(),
        snapshot.getP95(),
        snapshot.getP99(),
        snapshot.getMin(),
        snapshot.getMax(),
        (long) snapshot.getTotal(),
        snapshot.getTotal() / snapshot.getCount());
  }
}