bulk-cdk-toolkit-load-dlq/io.airbyte.cdk.load.pipeline.dlq/PassThroughPartitioner

PassThroughPartitioner

class PassThroughPartitioner : OutputPartitioner<StreamKey, DestinationRecordRaw, StreamKey, DlqStepOutput>

A partitioner that echoes the same partition as provided on the input.

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun getOutputKey(inputKey: StreamKey, output: DlqStepOutput): StreamKey
Link copied to clipboard
open override fun getPart(outputKey: StreamKey, inputPart: Int, numParts: Int): Int