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

FileCompletedOutputPartitioner

@Singleton
@Named(value = "fileCompletedOutputPartitioner")
class FileCompletedOutputPartitioner<K : WithStream, T : RemoteObject<*>> : ObjectLoaderCompletedUploadPartitioner<K, ObjectLoaderPartLoader.PartResult<T>, StreamKey, T>

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun getOutputKey(inputKey: K, output: ObjectLoaderUploadCompleter.UploadResult<T>): StreamKey
Link copied to clipboard
open override fun getPart(outputKey: StreamKey, inputPart: Int, numParts: Int): Int