com.eignex.kumulant/schema/runtime/VectorStatGroup

VectorStatGroup

class VectorStatGroup(stats: List<BoundStat<*, out VectorStat<*>, *>>, concurrency: Concurrency? = null) : AbstractStatGroup<VectorStat<*>> , VectorStat<GroupResult> (source)

StatGroup variant over vector inputs.

Constructors

VectorStatGroup

constructor(stats: List<BoundStat<*, out VectorStat<*>, *>>, concurrency: Concurrency? = null)(source)

constructor(vararg stats: BoundStat<*, out VectorStat<*>, *>, concurrency: Concurrency? = null)(source)

constructor(vararg stats: Pair<StatKey<*>, VectorStat<*>>, concurrency: Concurrency? = null)(source)

constructor(schema: StatSchema, concurrency: Concurrency = Concurrency.None)(source)

Properties

concurrency

override val concurrency: Concurrency

The weakest child guarantee; the requested mode applies when constructing fresh children.

Functions

create

open override fun create(concurrency: Concurrency? = null): VectorStat<GroupResult>(source)

Create an independent accumulator at the configured baseline. A null concurrency preserves this accumulator's mode; a non-null value overrides it. Modality subtypes narrow the return type to preserve the input shape.

merge

override fun merge(values: GroupResult, timestampNanos: Long = currentTimeNanos())

Fold a compatible snapshot values into this accumulator at timestampNanos. Implementations document whether the combine is exact or approximate and which state the snapshot omits. The source accumulator is unaffected.

read

override fun read(timestampNanos: Long = currentTimeNanos()): GroupResult

Return the current result evaluated at timestampNanos. Time-independent statistics ignore the timestamp. Reading does not add an observation.

reset

override fun reset()

Restore the configured baseline, including any prior seed. Preserves the configuration and concurrency.

update

open fun update(vector: Vector, weight: Double = 1.0)

Record vector with weight at the current monotonic time.

open fun update(vector: DoubleArray, weight: Double = 1.0)

Convenience overload that wraps vector as a DenseVector.

open fun update(vector: DoubleArray, timestampNanos: Long, weight: Double = 1.0)

Timestamped convenience overload that wraps vector as a DenseVector.

open override fun update(vector: Vector, timestampNanos: Long, weight: Double = 1.0)

Record vector with weight at timestampNanos.

validateMerge

override fun validateMerge(values: GroupResult)

Validate values for merge without changing accumulator state. Containers validate every child before merging any of them. Successful validation checks compatibility; it does not make a concurrent merge transactional.

update

open override fun update(vector: Vector, timestampNanos: Long, weight: Double = 1.0)(source)

Record vector with weight at timestampNanos.