bulk-cdk-core-load/io.airbyte.cdk.load.pipeline/OutputPartitioner

OutputPartitioner

interface OutputPartitioner<K1 : WithStream, T, K2 : WithStream, U>

Used internally by the CDK to determine how to partition data passed between steps. The dev should not implement this directly, but via specialized child classes provided for each loader type.

Functions

Link copied to clipboard
abstract fun getOutputKey(inputKey: K1, output: U): K2
Link copied to clipboard
abstract fun getPart(outputKey: K2, inputPart: Int, numParts: Int): Int