StateStore
data class StateStore<K1, S : AutoCloseable>(val stateWithCounts: MutableMap<K1, StateWithCounts<S>> = mutableMapOf(), val streamCounts: MutableMap<DestinationStream.Descriptor, Long> = mutableMapOf(), val streamsEnded: MutableSet<DestinationStream.Descriptor> = mutableSetOf())
Task-global state. A map of all the keys seen with associated accumulator state and bookkeeping info. Also includes a global count of inputs seen per stream and fact of stream end (it is a critical error to receive input for a stream that has ended, as it means that something is likely wrong with our bookkeeping.)
Constructors
Link copied to clipboard
constructor(stateWithCounts: MutableMap<K1, StateWithCounts<S>> = mutableMapOf(), streamCounts: MutableMap<DestinationStream.Descriptor, Long> = mutableMapOf(), streamsEnded: MutableSet<DestinationStream.Descriptor> = mutableSetOf())