dataChannelInputFlows

@Singleton

@Named(value = "dataChannelInputFlows")

fun dataChannelInputFlows(catalog: DestinationCatalog, @Named(value = "globalMemoryManager") queueMemoryManager: ReservationManager, @Named(value = "_pipelineInputQueue") pipelineInputQueue: PartitionedQueue<PipelineInputEvent>? = null, dataChannelMedium: DataChannelMedium, dataChannelReader: DataChannelReader, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter, @Named(value = "dataChannelSocketPaths") socketPaths: List<String>, @Value(value = "${airbyte.destination.core.data-channel.socket-buffer-size-bytes}") bufferSizeBytes: Int, @Value(value = "${airbyte.destination.core.data-channel.socket-connection-timeout-ms}") socketConnectionTimeoutMs: Long, @Named(value = "logPerNRecords") logPerNRecords: Long): Array<Flow<PipelineInputEvent>>

The input flows from which the pipeline will read. The size of the array will always be equal to @Named("numInputPartitions")numInputPartitions.