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

InputMessage

sealed interface InputMessage

Inheritors

Functions

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