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

ProtobufConverter

@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.

Constructors

Link copied to clipboard
constructor(coercer: ValueCoercer, validationResultHandler: ValidationResultHandler)

Functions

Link copied to clipboard
open override fun convert(input: ConversionInput): Map<String, AirbyteValue>

Converts the given {@link ConversionInput} into a map representation containing transformed data.