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

Package ai.whylabs.services.whylogs.persistent

Types

interface BufferedPersistentMap<BufferedItems, MapKeyType, MapValueType>

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.

QueueBufferedPersistentMapConfig

data class QueueBufferedPersistentMapConfig<BufferedItems, MapKeyType, MapValueType>( val queue: PersistentQueue<BufferedItems>, val map: PersistentMap<MapKeyType, MapValueType>, val groupByBlock: (BufferedItems) -> MapKeyType, val defaultValue: (MapKeyType) -> MapValueType, val mergeBlock: (MapValueType, BufferedItems) -> MapValueType, val delay: Long, val buffer: Boolean = false)

Serializer

interface Serializer<T>

Serializer interface used by the persistent data structures to write files to disk.

Functions

serializer

inline fun <T> serializer(): Serializer<T>

Convenience delegator to create serializers that use jackson.