bulk-cdk-core-load/io.airbyte.cdk.load.config/DataChannelBeanFactory/numInputPartitions

numInputPartitions

@Singleton

@Named(value = "numInputPartitions")

fun numInputPartitions(loadStrategy: LoadStrategy? = null, @Named(value = "isFileTransfer") isFileTransfer: Boolean = false, dataChannelMedium: DataChannelMedium, @Named(value = "dataChannelSocketPaths") dataChannelSocketPaths: List<String>): Int

The number of input partitions used by the pipeline. For STDIO syncs, this is the number of partitions to which the input stream is split. For SOCKETS syncs, this will be the number of socket flows.