ComposableStatistic

A statistic tha could be computed separately on different blocks of data and then composed

Parameters

composeIntermediate

common

abstract suspend fun composeIntermediate(first: I, second: I): I

computeIntermediate

common

abstract suspend fun computeIntermediate(data: Buffer<T>): I

evaluate

common

open suspend override fun evaluate(data: Buffer<T>): R

toResult

common

abstract suspend fun toResult(intermediate: I): R

Mean

flow

common

fun <T, I, R> ComposableStatistic<T, I, R>.flow(flow: Flow<Buffer<T>>, dispatcher: CoroutineDispatcher = Dispatchers.Default): Flow<R>

Perform a streaming statistical analysis on a chunked data.