bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.pipline.object_storage/ObjectLoaderLoadedPartPartitioner

ObjectLoaderLoadedPartPartitioner

class ObjectLoaderLoadedPartPartitioner<K : WithStream, T, U : RemoteObject<*>> : OutputPartitioner<K, T, ObjectKey, ObjectLoaderPartLoader.PartResult<U>>

The technically correct partitioning is round-robin, but since we use io.airbyte.cdk.load.message.SinglePartitionQueueWithMultiPartitionBroadcast, the partition is immaterial, so it's simpler just to return 0 here.

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun getOutputKey(inputKey: K, output: ObjectLoaderPartLoader.PartResult<U>): ObjectKey
Link copied to clipboard
open override fun getPart(outputKey: ObjectKey, inputPart: Int, numParts: Int): Int