Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.state/Histogram

Histogram

open class Histogram<T>(map: ConcurrentMap<T, Double> = ConcurrentHashMap())

Constructors

constructor(map: ConcurrentMap<T, Double> = ConcurrentHashMap())

Functions

fun get(key: T): Double?

fun increment(key: T, quantity: Double): Histogram<T>

fun merge(other: Histogram<T>): Histogram<T>

fun remove(key: T): Double?

fun toMap(): Map<T, Double>