StateWithCounts
data class StateWithCounts<S : AutoCloseable>(val accumulatorState: S, val checkpointCounts: MutableMap<CheckpointId, CheckpointValue> = mutableMapOf(), val inputCount: Long = 0, val createdAtMs: Long = System.currentTimeMillis()) : AutoCloseable
Accumulator state with the checkpoint counts (Checkpoint Id -> Records Seen) seen since the state was created.
Includes a count of the inputs seen since the state was created.
Constructors
Link copied to clipboard
constructor(accumulatorState: S, checkpointCounts: MutableMap<CheckpointId, CheckpointValue> = mutableMapOf(), inputCount: Long = 0, createdAtMs: Long = System.currentTimeMillis())