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

InputStreamComplete

data class InputStreamComplete(val streamComplete: DestinationRecordStreamComplete) : InputMessage

Constructors

Link copied to clipboard
constructor(streamComplete: DestinationRecordStreamComplete)

Properties

Link copied to clipboard

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)