ports/com.group7.metrics.batchmeans/AdaptiveBatchMeans

AdaptiveBatchMeans

abstract class AdaptiveBatchMeans(val targetBatches: Int)

Does batch means on data as new values come in by:

storing data into up to 2 * targetBatches batches, and report the mean of each of these
when 2 * targetBatches is reached, squash pairs of batches into one batch to get targetBatches batches.

Inheritors

AdaptiveRateBatchMeans

AdaptiveTimeWeightedBatchMeans

Constructors

AdaptiveBatchMeans

constructor(targetBatches: Int)

Properties

val targetBatches: Int

Target number of batches to maintain after collapsing.

Functions

fun batchCount(): Int

Returns the current number of batches.

fun batchVariance(): Double

Returns the current variance of batch means.

fun mean(): Double

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.