DestinationRecordAirbyteValue

data class DestinationRecordAirbyteValue(val stream: DestinationStream, val data: AirbyteValue, val emittedAtMs: Long, val meta: Meta?, val serializedSizeBytes: Long = 0)

Represents a record both deserialized AND marshaled to airbyte value. The marshaling

Constructors

Link copied to clipboard
constructor(stream: DestinationStream, data: AirbyteValue, emittedAtMs: Long, meta: Meta?, serializedSizeBytes: Long = 0)

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val meta: Meta?
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
fun DestinationRecordAirbyteValue.dataWithAirbyteMeta(stream: DestinationStream, flatten: Boolean = false, extractedAtAsTimestampWithTimezone: Boolean = false, airbyteRawId: UUID): ObjectValue