本文整理汇总了Java中org.HdrHistogram.Recorder类的典型用法代码示例。如果您正苦于以下问题:Java Recorder类的具体用法?Java Recorder怎么用?Java Recorder使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Recorder类属于org.HdrHistogram包,在下文中一共展示了Recorder类的13个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: ResetByChunksAccumulator
import org.HdrHistogram.Recorder; //导入依赖的package包/类
public ResetByChunksAccumulator(Supplier<Recorder> recorderSupplier, int numberHistoryChunks, long intervalBetweenResettingMillis, Clock clock, Executor backgroundExecutor) {
this.intervalBetweenResettingMillis = intervalBetweenResettingMillis;
this.clock = clock;
this.creationTimestamp = clock.currentTimeMillis();
this.backgroundExecutor = backgroundExecutor;
this.left = new Phase(recorderSupplier, creationTimestamp + intervalBetweenResettingMillis);
this.right = new Phase(recorderSupplier, Long.MAX_VALUE);
this.phases = new Phase[] {left, right};
this.currentPhaseRef = new AtomicReference<>(left);
this.historySupported = numberHistoryChunks > 0;
if (historySupported) {
this.archive = new ArchivedHistogram[numberHistoryChunks];
for (int i = 0; i < numberHistoryChunks; i++) {
Histogram archivedHistogram = HistogramUtil.createNonConcurrentCopy(left.intervalHistogram);
this.archive[i] = new ArchivedHistogram(archivedHistogram, Long.MIN_VALUE);
}
} else {
this.archive = null;
}
this.temporarySnapshotHistogram = HistogramUtil.createNonConcurrentCopy(left.intervalHistogram);
}
开发者ID:vladimir-bukhtoyarov,项目名称:rolling-metrics,代码行数:26,代码来源:ResetByChunksAccumulator.java
示例2: HdrHistogramReservoir
import org.HdrHistogram.Recorder; //导入依赖的package包/类
/**
* Create a reservoir with a user-specified recorder.
*
* @param recorder Recorder to use
*/
public HdrHistogramReservoir(Recorder recorder) {
this.recorder = recorder;
/*
* Start by flipping the recorder's interval histogram.
* - it starts our counting at zero. Arguably this might be a bad thing if you wanted to feed in
* a recorder that already had some measurements? But that seems crazy.
* - intervalHistogram can be nonnull.
* - it lets us figure out the number of significant digits to use in runningTotals.
*/
intervalHistogram = recorder.getIntervalHistogram();
runningTotals = new Histogram(intervalHistogram.getNumberOfSignificantValueDigits());
}
开发者ID:networknt,项目名称:light-4j,代码行数:19,代码来源:HdrHistogramReservoir.java
示例3: HdrHistogramResetOnSnapshotReservoir
import org.HdrHistogram.Recorder; //导入依赖的package包/类
/**
* Create a reservoir with a user-specified recorder.
*
* @param recorder Recorder to use
*/
public HdrHistogramResetOnSnapshotReservoir(Recorder recorder) {
this.recorder = recorder;
/*
* Start by flipping the recorder's interval histogram.
* - it starts our counting at zero. Arguably this might be a bad thing if you wanted to feed in
* a recorder that already had some measurements? But that seems crazy.
* - intervalHistogram can be nonnull.
*/
intervalHistogram = recorder.getIntervalHistogram();
}
开发者ID:networknt,项目名称:light-4j,代码行数:17,代码来源:HdrHistogramResetOnSnapshotReservoir.java
示例4: getReservoir
import org.HdrHistogram.Recorder; //导入依赖的package包/类
/**
* Get reservoir implementation based on the reservoir type
*
* @return The {@link Reservoir} implementation
*/
private Reservoir getReservoir() {
// The Reservoir implementation is selected using a switch statement.
// The ReservoirType enum is a part of YAML configuration
// and foreign imports are not supported by Carbon Configuration Maven Plugin.
// Therefore, the Reservoir class cannot be imported and the Reservoir
// creation logic cannot be written inside ReservoirType enum.
switch (reservoirType) {
case EXPONENTIALLY_DECAYING:
return new ExponentiallyDecayingReservoir();
case UNIFORM:
return new UniformReservoir(reservoirParametersConfig.getSize());
case SLIDING_WINDOW:
return new SlidingWindowReservoir(reservoirParametersConfig.getSize());
case SLIDING_TIME_WINDOW:
return new SlidingTimeWindowReservoir(reservoirParametersConfig.getWindow(),
reservoirParametersConfig.getWindowUnit());
case HDR_HISTOGRAM:
Recorder recorder = new Recorder(reservoirParametersConfig.getNumberOfSignificantValueDigits());
if (reservoirParametersConfig.isResetOnSnapshot()) {
return new HdrHistogramResetOnSnapshotReservoir(recorder);
} else {
return new HdrHistogramReservoir(recorder);
}
default:
throw new RuntimeException("Invalid Reservoir Type");
}
}
开发者ID:wso2,项目名称:carbon-metrics,代码行数:34,代码来源:MetricManager.java
示例5: HdrHistogramReservoir
import org.HdrHistogram.Recorder; //导入依赖的package包/类
/**
* Create a reservoir with a user-specified recorder.
*
* @param recorder {@link Recorder} to use
*/
public HdrHistogramReservoir(Recorder recorder) {
this.recorder = recorder;
// Get Interval Histogram and keep the reference to reuse later when taking a snapshot
intervalHistogram = recorder.getIntervalHistogram();
histogram = new Histogram(intervalHistogram.getNumberOfSignificantValueDigits());
}
开发者ID:wso2,项目名称:carbon-metrics,代码行数:12,代码来源:HdrHistogramReservoir.java
示例6: buildRecorder
import org.HdrHistogram.Recorder; //导入依赖的package包/类
private Recorder buildRecorder() {
if (lowestDiscernibleValue.isPresent()) {
return new Recorder(lowestDiscernibleValue.get(), highestTrackableValue.get(), numberOfSignificantValueDigits);
}
if (highestTrackableValue.isPresent()) {
return new Recorder(highestTrackableValue.get(), numberOfSignificantValueDigits);
}
return new Recorder(numberOfSignificantValueDigits);
}
开发者ID:vladimir-bukhtoyarov,项目名称:rolling-metrics,代码行数:10,代码来源:HdrBuilder.java
示例7: HdrHistogramResetOnSnapshotReservoir
import org.HdrHistogram.Recorder; //导入依赖的package包/类
/**
* Create a reservoir with a default recorder.
*/
public HdrHistogramResetOnSnapshotReservoir() {
this(new Recorder(2));
}
开发者ID:wso2,项目名称:carbon-metrics,代码行数:7,代码来源:HdrHistogramResetOnSnapshotReservoir.java
示例8: ResetOnSnapshotAccumulator
import org.HdrHistogram.Recorder; //导入依赖的package包/类
public ResetOnSnapshotAccumulator(Recorder recorder) {
this.recorder = recorder;
this.intervalHistogram = recorder.getIntervalHistogram();
}
开发者ID:vladimir-bukhtoyarov,项目名称:rolling-metrics,代码行数:5,代码来源:ResetOnSnapshotAccumulator.java
示例9: Phase
import org.HdrHistogram.Recorder; //导入依赖的package包/类
Phase(Supplier<Recorder> recorderSupplier, long proposedInvalidationTimestamp) {
this.recorder = recorderSupplier.get();
this.intervalHistogram = recorder.getIntervalHistogram();
this.totalsHistogram = intervalHistogram.copy();
this.proposedInvalidationTimestamp = proposedInvalidationTimestamp;
}
开发者ID:vladimir-bukhtoyarov,项目名称:rolling-metrics,代码行数:7,代码来源:ResetByChunksAccumulator.java
示例10: UniformAccumulator
import org.HdrHistogram.Recorder; //导入依赖的package包/类
public UniformAccumulator(Recorder recorder) {
this.recorder = recorder;
this.intervalHistogram = recorder.getIntervalHistogram();
this.uniformHistogram = HistogramUtil.createNonConcurrentCopy(intervalHistogram);
}
开发者ID:vladimir-bukhtoyarov,项目名称:rolling-metrics,代码行数:6,代码来源:UniformAccumulator.java
示例11: getRecorder
import org.HdrHistogram.Recorder; //导入依赖的package包/类
public Recorder getRecorder() {
return recorder;
}
开发者ID:hazelcast,项目名称:hazelcast-simulator,代码行数:4,代码来源:HdrProbe.java
示例12: getProbeTotalCount
import org.HdrHistogram.Recorder; //导入依赖的package包/类
private static long getProbeTotalCount(String probeName, TestContainer container) {
Map<String, Probe> probeMap = container.getProbeMap();
HdrProbe probe = (HdrProbe) probeMap.get(probeName);
Recorder recorder = probe.getRecorder();
return recorder.getIntervalHistogram().getTotalCount();
}
开发者ID:hazelcast,项目名称:hazelcast-simulator,代码行数:7,代码来源:TestContainer_TimeStep_AsyncSupportTest.java
示例13: createAccumulator
import org.HdrHistogram.Recorder; //导入依赖的package包/类
Accumulator createAccumulator(Supplier<Recorder> recorderSupplier, com.github.rollingmetrics.util.Clock clock);
开发者ID:vladimir-bukhtoyarov,项目名称:rolling-metrics,代码行数:2,代码来源:HdrBuilder.java
注:本文中的org.HdrHistogram.Recorder类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论