nullify
fun nullify(partitionKey: PartitionKey, stream: DestinationStream.Descriptor, value: EnrichedAirbyteValue, reason: AirbyteRecordMessageMetaChange.Reason = Reason.DESTINATION_SERIALIZATION_ERROR): EnrichedAirbyteValue
Nullifies the provided enriched Airbyte value by setting its value to null and recording the change. Additionally, updates the state statistics for the nullification event.
Return
The updated enriched Airbyte value with a nullified state and recorded change.
Parameters
partitionKey
The partition key associated with the record.
stream
The descriptor of the destination stream that the value belongs to.
value
The enriched Airbyte value to be nullified.
reason
The reason for nullifying the value, defaulting to DESTINATION_SERIALIZATION_ERROR.