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

Distribution.add介绍

暂无

代码示例

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

public void recordGetSplitTime(long startNanos)
{
  long elapsedNanos = System.nanoTime() - startNanos;
  getSplitDistribution.add(elapsedNanos);
  scheduledStats.getGetSplitTime().add(elapsedNanos, NANOSECONDS);
}

代码示例来源：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

drivers.add(driverStats);
queuedTime.add(driverStats.getQueuedTime().roundTo(NANOSECONDS));
elapsedTime.add(driverStats.getElapsedTime().roundTo(NANOSECONDS));

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

queuedTime.add(driverStats.getQueuedTime().roundTo(NANOSECONDS));
elapsedTime.add(driverStats.getElapsedTime().roundTo(NANOSECONDS));

代码示例来源：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 void add(long value)
{
  oneMinute.add(value);
  fiveMinutes.add(value);
  fifteenMinutes.add(value);
  allTime.add(value);
}

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

public void add(long value)
{
  oneMinute.add(value);
  fiveMinutes.add(value);
  fifteenMinutes.add(value);
  allTime.add(value);
}

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

public void recordScheduleTaskTime(long startNanos)
{
  scheduleTaskDistribution.add(System.nanoTime() - startNanos);
}

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

public void recordGetSplitTime(long startNanos)
{
  getSplitDistribution.add(System.nanoTime() - startNanos);
}

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

public void recordAddSplit(long startNanos)
{
  addSplitDistribution.add(System.nanoTime() - startNanos);
}

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

public void recordGetSplitTime(long startNanos)
{
  long elapsedNanos = System.nanoTime() - startNanos;
  getSplitDistribution.add(elapsedNanos);
  scheduledStats.getGetSplitTime().add(elapsedNanos, NANOSECONDS);
}

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

public void recordGetSplitTime(long startNanos)
{
  long elapsedNanos = System.nanoTime() - startNanos;
  getSplitDistribution.add(elapsedNanos);
  scheduledStats.getGetSplitTime().add(elapsedNanos, NANOSECONDS);
}

代码示例来源：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: 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: 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: 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

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