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

MapperPipeline

class MapperPipeline(inputSchema: AirbyteType, schemaValueMapperPairs: List<Pair<AirbyteSchemaMapper, AirbyteValueMapper>>)

Deprecated

Use DestinationRecordRaw.asEnrichedDestinationRecordAirbyteValue() logic instead

Constructors

Link copied to clipboard
constructor(inputSchema: AirbyteType, schemaValueMapperPairs: List<Pair<AirbyteSchemaMapper, AirbyteValueMapper>>)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
fun map(data: AirbyteValue, changes: List<Meta.Change>? = null): Pair<AirbyteValue, List<Meta.Change>>