DestinationRecordRaw
data class DestinationRecordRaw(val stream: DestinationStream, val rawData: DestinationRecordSource, val serializedSizeBytes: Long, val checkpointId: CheckpointId? = null, val airbyteRawId: UUID)
Constructors
Link copied to clipboard
constructor(stream: DestinationStream, rawData: DestinationRecordSource, serializedSizeBytes: Long, checkpointId: CheckpointId? = null, airbyteRawId: UUID)
Properties
Functions
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun asEnrichedDestinationRecordAirbyteValue(extractedAtAsTimestampWithTimezone: Boolean = false, respectLegacyUnions: Boolean = false): EnrichedDestinationRecordAirbyteValue
Convert this record to an EnrichedRecord. Crucially, after this conversion, all entries in EnrichedDestinationRecordAirbyteValue.allTypedFields are guaranteed to have EnrichedAirbyteValue.abValue either be NullValue, or match EnrichedAirbyteValue.type (e.g. if type is TimestampTypeWithTimezone, then value is either NullValue, or TimestampWithTimezoneValue).
Link copied to clipboard
DEPRECATED: Now that we support multiple formats for speed, this is no longer an optimization.