bulk-cdk-core-load/io.airbyte.cdk.load.data/MapperPipelineFactory

MapperPipelineFactory

interface MapperPipelineFactory

Deprecated

Use DestinationRecordRaw.asEnrichedDestinationRecordAirbyteValue() logic instead

Functions

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