bulk-cdk-toolkit-legacy-task-loader/io.airbyte.cdk.load.message/InputStreamComplete

InputStreamComplete

data class InputStreamComplete(val streamComplete: DestinationRecordStreamComplete) : InputMessage(source)

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)
Generated by Dokka
© 2026 Copyright