Airbyte Kotlin Bulk CDK

0.1.92

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

DestinationRecord

data class DestinationRecord(val stream: DestinationStream, val message: DestinationRecordSource, val serializedSizeBytes: Long, val checkpointId: CheckpointId? = null, val airbyteRawId: UUID) : DestinationRecordDomainMessage

Constructors

DestinationRecord

constructor(stream: DestinationStream, message: DestinationRecordSource, serializedSizeBytes: Long, checkpointId: CheckpointId? = null, airbyteRawId: UUID)

Properties

val airbyteRawId: UUID

val checkpointId: CheckpointId? = null

val message: DestinationRecordSource

serializedSizeBytes

val serializedSizeBytes: Long

open override val stream: DestinationStream

Functions

asDestinationRecordRaw

fun asDestinationRecordRaw(): DestinationRecordRaw

asProtocolMessage

open override fun asProtocolMessage(): AirbyteMessage