pipelineInputQueue

@Singleton

@Named(value = "_pipelineInputQueue")

@Requires(property = "airbyte.destination.core.data-channel.medium", value = "STDIO")

fun pipelineInputQueue(@Named(value = "numInputPartitions") numInputPartitions: Int): PartitionedQueue<PipelineInputEvent>

PRIVATE: Do not use outside this factory.

A record queue containing all streams, partitioned, for use in routing from smaller- cardinality input sources (ie, STDIN pipe.)

NOTE: The platform is sending STDOUT to both connectors to mean: "use standard streams"