Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.message/ResourceReservingPartitionedQueue

ResourceReservingPartitionedQueue

class ResourceReservingPartitionedQueue<T>(val reservationManager: ReservationManager, val ratioOfTotalMemoryToReserve: Double, val numConsumers: Int, val numProducers: Int, val expectedResourceUsagePerUnit: Long) : PartitionedQueue<T>

Constructors

ResourceReservingPartitionedQueue

constructor(reservationManager: ReservationManager, ratioOfTotalMemoryToReserve: Double, numConsumers: Int, numProducers: Int, expectedResourceUsagePerUnit: Long)

Properties

clampedMessageSize

val clampedMessageSize: Long

expectedResourceUsagePerUnit

val expectedResourceUsagePerUnit: Long

val numConsumers: Int

val numProducers: Int

open override val partitions: Int

queuePartitionCapacity

@VisibleForTesting

val queuePartitionCapacity: Int

ratioOfTotalMemoryToReserve

val ratioOfTotalMemoryToReserve: Double

reservationManager

val reservationManager: ReservationManager

Functions

open fun asOrderedFlows(): Array<Flow<T>>

open suspend override fun broadcast(value: T)

open suspend override fun close()

inline suspend fun CloseableCoroutine.closeFinally(cause: Throwable?)

open override fun consume(partition: Int): Flow<T>

open suspend override fun publish(value: T, partition: Int)