bulk-cdk-toolkit-legacy-task-load-avro/io.airbyte.cdk.load.data.avro/AvroMapperPipelineFactory

AvroMapperPipelineFactory

class AvroMapperPipelineFactory : MapperPipelineFactory

Deprecated

Use DestinationRecordRaw.asEnrichedDestinationRecordAirbyteValue() logic instead

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun create(stream: DestinationStream): MapperPipeline