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

DestinationFile

data class DestinationFile(val stream: DestinationStream, val emittedAtMs: Long, val fileMessage: DestinationFile.AirbyteRecordMessageFile) : DestinationFileDomainMessage

Constructors

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

Types

Link copied to clipboard
class AirbyteRecordMessageFile

Convenience constructor, primarily intended for use in tests.

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override val stream: DestinationStream

Functions

Link copied to clipboard
open override fun asProtocolMessage(): AirbyteMessage