bulk-cdk-core-load/io.airbyte.cdk.load.message/InputMessageOther

InputMessageOther

data class InputMessageOther(val airbyteMessage: AirbyteMessage) : InputMessage

Constructors

Link copied to clipboard
constructor(airbyteMessage: AirbyteMessage)

Properties

Link copied to clipboard
val airbyteMessage: AirbyteMessage

Functions

Link copied to clipboard
open fun asProtobuf(): AirbyteMessage.AirbyteMessageProtobuf
Link copied to clipboard
open override fun asProtocolMessage(): AirbyteMessage
Link copied to clipboard
open fun writeProtocolMessage(dataChannelFormat: DataChannelFormat = DataChannelFormat.JSONL, outputStream: OutputStream)