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

InputFile

data class InputFile(val file: DestinationFile) : InputMessage

Constructors

Link copied to clipboard
constructor(stream: DestinationStream, emittedAtMs: Long, fileMessage: DestinationFile.AirbyteRecordMessageFile)
constructor(file: DestinationFile)

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)