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

create

open override fun create(stream: DestinationStream): MapperPipeline