bulk-cdk-toolkit-legacy-task-loader/io.airbyte.cdk.load.file/JSONLDataChannelReader

JSONLDataChannelReader

class JSONLDataChannelReader(destinationMessageFactory: DestinationMessageFactory) : DataChannelReader

Constructors

Link copied to clipboard
constructor(destinationMessageFactory: DestinationMessageFactory)

Functions

Link copied to clipboard
open override fun read(inputStream: InputStream): Sequence<DestinationMessage>