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

DestinationRecordSource

sealed interface DestinationRecordSource

A serialization-format agnostic wrapper for incoming DestinationRecord's. The record-level corollary to io.airbyte.cdk.load.data.AirbyteValueProxy, providing uniform access to both client data and metadata.

Inheritors

Properties

Link copied to clipboard
abstract val emittedAtMs: Long
Link copied to clipboard
abstract val fileReference: FileReference?
Link copied to clipboard
abstract val sourceMeta: Meta

Functions

Link copied to clipboard
Link copied to clipboard
abstract fun asJsonRecord(orderedSchema: Array<AirbyteValueProxy.FieldAccessor>): JsonNode