AdaptiveTimeWeightedBatchMeans

class AdaptiveTimeWeightedBatchMeans(initialBatchInterval: Duration = 1.milliseconds, targetBatches: Int = 32) : AdaptiveBatchMeans

For continuous metrics, weight new samples by time and do batch means.

Constructors

constructor(initialBatchInterval: Duration = 1.milliseconds, targetBatches: Int = 32)

Target number of batches to maintain after collapsing.

Returns the current number of batches.

Returns the current variance of batch means.

Returns the current overall mean across all batch means.

fun onCloseBatch(callback: () -> Unit)

Registers a callback to be invoked each time a batch is closed/finalized.

fun update(currentTime: Instant, value: Double)

Add a new value at currentTime