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

InputFile

data class InputFile(val file: DestinationFile) : InputMessage(source)

Constructors

constructor(file: DestinationFile)

constructor(stream: DestinationStream, emittedAtMs: Long, fileMessage: DestinationFile.AirbyteRecordMessageFile)

Properties

val file: DestinationFile

Functions

open fun asProtobuf(): AirbyteMessage.AirbyteMessageProtobuf

asProtocolMessage

open override fun asProtocolMessage(): AirbyteMessage

writeProtocolMessage

open fun writeProtocolMessage(dataChannelFormat: DataChannelFormat = DataChannelFormat.JSONL, outputStream: OutputStream)