create

open override fun create(stream: DestinationStream): MapperPipeline