whylogs-container/ai.whylabs.services.whylogs.persistent/QueueBufferedPersistentMap

QueueBufferedPersistentMap

class QueueBufferedPersistentMap<BufferItems, MayKeyType, MapValueType>(config: QueueBufferedPersistentMapConfig<BufferItems, MayKeyType, MapValueType>) : BufferedPersistentMap<BufferItems, MayKeyType, MapValueType>

An implementation of BufferedPersistentMap that uses a queue to buffer items of a certain type, Q, before periodically merging them into the main map, transforming them into a V. The types and how to map them are supplied in the configuration.

Constructors

fun <BufferItems, MayKeyType, MapValueType> QueueBufferedPersistentMap(config: QueueBufferedPersistentMapConfig<BufferItems, MayKeyType, MapValueType>)

Functions

merge

open suspend override fun merge(item: BufferItems)

mergeBuffered

open suspend override fun mergeBuffered(increment: PopSize, done: CompletableDeferred<Unit>?)

Properties

map

open override val map: PersistentMap<MayKeyType, MapValueType>