bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.input/JsonDestinationMessageInputFlow

JsonDestinationMessageInputFlow

class JsonDestinationMessageInputFlow(inputStream: InputStream, deserializer: ProtocolMessageDeserializer) : Flow<DestinationMessage>

Takes bytes and emits DestinationMessages

Constructors

Link copied to clipboard
constructor(inputStream: InputStream, deserializer: ProtocolMessageDeserializer)

Properties

Link copied to clipboard
val log: KLogger

Functions

Link copied to clipboard
open suspend override fun collect(collector: FlowCollector<DestinationMessage>)