bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.factory.object_storage/ObjectLoaderStepBeanFactory/recordPartFormatter

recordPartFormatter

@Named(value = "recordPartFormatterStep")
@Singleton
fun <T : OutputStream> recordPartFormatter(@Named(value = "numInputPartitions") numInputPartitions: Int, partFormatter: ObjectLoaderPartFormatter<T>, @Named(value = "dataChannelInputFlows") inputFlows: Array<Flow<PipelineEvent<StreamKey, DestinationRecordRaw>>>, @Named(value = "objectLoaderPartQueue") outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, taskFactory: LoadPipelineStepTaskFactory, flushStrategy: PipelineFlushStrategy): ObjectLoaderPartFormatterStep