bulk-cdk-toolkit-load-parquet/io.airbyte.cdk.load.data.parquet/ParquetMapperPipelineTest

ParquetMapperPipelineTest

class ParquetMapperPipelineTest : 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