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

Package-level declarations

Types

Link copied to clipboard
data class ConversionInput(val msg: DestinationRecordRaw, val partitionKey: PartitionKey)

Represents the input required for a conversion process.

Link copied to clipboard
@Singleton
class JsonConverter(coercer: ValueCoercer, validationResultHandler: ValidationResultHandler) : MediumConverter
Link copied to clipboard
interface MediumConverter

Converts raw destination records into a map of final column name to munged final value.

Link copied to clipboard
@Singleton
class ProtobufConverter(coercer: ValueCoercer, validationResultHandler: ValidationResultHandler) : MediumConverter

Converter that extracts typed values from protobuf records and converts them to EnrichedAirbyteValue with destination-specific coercion applied through the Coercer interface.