org.apache.flink.metrics.HistogramStatistics.getStdDev()方法的使用及代码示例

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

HistogramStatistics.getStdDev介绍

[英]Returns the standard deviation of the distribution reflected by the histogram statistics.
[中]返回直方图统计信息反映的分布的标准偏差。

代码示例

代码示例来源：origin: apache/flink

@Override
public double getStdDev() {
return histogramStatistics.getStdDev();
}

代码示例来源：origin: apache/flink

@Override
public double getStdDev() {
return histogram.getStatistics().getStdDev();
}

代码示例来源：origin: apache/flink

.append(", max=").append(stats.getMax())
.append(", mean=").append(stats.getMean())
.append(", stddev=").append(stats.getStdDev())
.append(", p50=").append(stats.getQuantile(0.50))
.append(", p75=").append(stats.getQuantile(0.75))

代码示例来源：origin: apache/flink

private void reportHistogram(final String name, final Histogram histogram) {
if (histogram != null) {
HistogramStatistics statistics = histogram.getStatistics();
if (statistics != null) {
send(prefix(name, "count"), String.valueOf(histogram.getCount()));
send(prefix(name, "max"), String.valueOf(statistics.getMax()));
send(prefix(name, "min"), String.valueOf(statistics.getMin()));
send(prefix(name, "mean"), String.valueOf(statistics.getMean()));
send(prefix(name, "stddev"), String.valueOf(statistics.getStdDev()));
send(prefix(name, "p50"), String.valueOf(statistics.getQuantile(0.5)));
send(prefix(name, "p75"), String.valueOf(statistics.getQuantile(0.75)));
send(prefix(name, "p95"), String.valueOf(statistics.getQuantile(0.95)));
send(prefix(name, "p98"), String.valueOf(statistics.getQuantile(0.98)));
send(prefix(name, "p99"), String.valueOf(statistics.getQuantile(0.99)));
send(prefix(name, "p999"), String.valueOf(statistics.getQuantile(0.999)));
}
}
}

代码示例来源：origin: com.alibaba.blink/flink-metrics-dropwizard

@Override
public double getStdDev() {
return histogramStatistics.getStdDev();
}

代码示例来源：origin: org.apache.flink/flink-metrics-jmx

@Override
public double getStdDev() {
return histogram.getStatistics().getStdDev();
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

private static void serializeHistogram(DataOutput out, QueryScopeInfo info, String name, Histogram histogram) throws IOException {
HistogramStatistics stat = histogram.getStatistics();
long min = stat.getMin();
long max = stat.getMax();
double mean = stat.getMean();
double median = stat.getQuantile(0.5);
double stddev = stat.getStdDev();
double p75 = stat.getQuantile(0.75);
double p90 = stat.getQuantile(0.90);
double p95 = stat.getQuantile(0.95);
double p98 = stat.getQuantile(0.98);
double p99 = stat.getQuantile(0.99);
double p999 = stat.getQuantile(0.999);
serializeMetricInfo(out, info);
out.writeUTF(name);
out.writeLong(min);
out.writeLong(max);
out.writeDouble(mean);
out.writeDouble(median);
out.writeDouble(stddev);
out.writeDouble(p75);
out.writeDouble(p90);
out.writeDouble(p95);
out.writeDouble(p98);
out.writeDouble(p99);
out.writeDouble(p999);
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

private static void serializeHistogram(DataOutput out, QueryScopeInfo info, String name, Histogram histogram) throws IOException {
HistogramStatistics stat = histogram.getStatistics();
long min = stat.getMin();
long max = stat.getMax();
double mean = stat.getMean();
double median = stat.getQuantile(0.5);
double stddev = stat.getStdDev();
double p75 = stat.getQuantile(0.75);
double p90 = stat.getQuantile(0.90);
double p95 = stat.getQuantile(0.95);
double p98 = stat.getQuantile(0.98);
double p99 = stat.getQuantile(0.99);
double p999 = stat.getQuantile(0.999);
serializeMetricInfo(out, info);
out.writeUTF(name);
out.writeLong(min);
out.writeLong(max);
out.writeDouble(mean);
out.writeDouble(median);
out.writeDouble(stddev);
out.writeDouble(p75);
out.writeDouble(p90);
out.writeDouble(p95);
out.writeDouble(p98);
out.writeDouble(p99);
out.writeDouble(p999);
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

private static void serializeHistogram(DataOutput out, QueryScopeInfo info, String name, Histogram histogram) throws IOException {
HistogramStatistics stat = histogram.getStatistics();
long min = stat.getMin();
long max = stat.getMax();
double mean = stat.getMean();
double median = stat.getQuantile(0.5);
double stddev = stat.getStdDev();
double p75 = stat.getQuantile(0.75);
double p90 = stat.getQuantile(0.90);
double p95 = stat.getQuantile(0.95);
double p98 = stat.getQuantile(0.98);
double p99 = stat.getQuantile(0.99);
double p999 = stat.getQuantile(0.999);
serializeMetricInfo(out, info);
out.writeUTF(name);
out.writeLong(min);
out.writeLong(max);
out.writeDouble(mean);
out.writeDouble(median);
out.writeDouble(stddev);
out.writeDouble(p75);
out.writeDouble(p90);
out.writeDouble(p95);
out.writeDouble(p98);
out.writeDouble(p99);
out.writeDouble(p999);
}

代码示例来源：origin: org.apache.flink/flink-runtime

private static void serializeHistogram(DataOutput out, QueryScopeInfo info, String name, Histogram histogram) throws IOException {
HistogramStatistics stat = histogram.getStatistics();
long min = stat.getMin();
long max = stat.getMax();
double mean = stat.getMean();
double median = stat.getQuantile(0.5);
double stddev = stat.getStdDev();
double p75 = stat.getQuantile(0.75);
double p90 = stat.getQuantile(0.90);
double p95 = stat.getQuantile(0.95);
double p98 = stat.getQuantile(0.98);
double p99 = stat.getQuantile(0.99);
double p999 = stat.getQuantile(0.999);
serializeMetricInfo(out, info);
out.writeUTF(name);
out.writeLong(min);
out.writeLong(max);
out.writeDouble(mean);
out.writeDouble(median);
out.writeDouble(stddev);
out.writeDouble(p75);
out.writeDouble(p90);
out.writeDouble(p95);
out.writeDouble(p98);
out.writeDouble(p99);
out.writeDouble(p999);
}

代码示例来源：origin: org.apache.beam/beam-runners-flink_2.11

public static String toString(Metric metric) {
if (metric instanceof Counter) {
return Long.toString(((Counter) metric).getCount());
} else if (metric instanceof Gauge) {
return ((Gauge) metric).getValue().toString();
} else if (metric instanceof Meter) {
return Double.toString(((Meter) metric).getRate());
} else if (metric instanceof Histogram) {
HistogramStatistics stats = ((Histogram) metric).getStatistics();
return String.format(
"count=%d, min=%d, max=%d, mean=%f, stddev=%f, p50=%f, p75=%f, p95=%f",
stats.size(),
stats.getMin(),
stats.getMax(),
stats.getMean(),
stats.getStdDev(),
stats.getQuantile(0.5),
stats.getQuantile(0.75),
stats.getQuantile(0.95));
} else {
throw new IllegalStateException(
String.format(
"Cannot remove unknown metric type %s. This indicates that the reporter "
+ "does not support this metric type.",
metric.getClass().getName()));
}
}
}