Airbyte Kotlin Bulk CDK

1.0.2

bulk-cdk-toolkit-legacy-task-load-db/io.airbyte.cdk.load.write.db/BulkLoaderFactory

BulkLoaderFactory

interface BulkLoaderFactory<K : WithStream, T : RemoteObject<*>> : ObjectLoader

Properties

inputPartitions

open override val inputPartitions: Int

maxMemoryRatioReservedForParts

open val maxMemoryRatioReservedForParts: Double

maxNumConcurrentLoads

abstract val maxNumConcurrentLoads: Int

open val numPartWorkers: Int

numUploadCompleters

open val numUploadCompleters: Int

numUploadWorkers

open val numUploadWorkers: Int

objectSizeBytes

open val objectSizeBytes: Long

open val partSizeBytes: Long

stateAfterUpload

open override val stateAfterUpload: BatchState

Functions

abstract fun create(key: K, partition: Int): BulkLoader<T>

socketPartSizeBytes

open fun socketPartSizeBytes(numberOfSockets: Int): Long

socketUploadParallelism

open fun socketUploadParallelism(numberOfSockets: Int): Int