bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.transform.medium/ConversionInput

ConversionInput

data class ConversionInput(val msg: DestinationRecordRaw, val partitionKey: PartitionKey)

Represents the input required for a conversion process.

This data class encapsulates a set of necessary attributes:

  • A raw destination record containing data to be converted.

  • A partition key to associate the record with a specific partition.

  • An optional source specifying the record's protocol buffer source.

Constructors

Link copied to clipboard
constructor(msg: DestinationRecordRaw, partitionKey: PartitionKey)

Properties

Link copied to clipboard
val msg: DestinationRecordRaw

The raw destination record containing the stream, data, and metadata.

Link copied to clipboard
val partitionKey: PartitionKey

The partition key defining the record's association with a partition.