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

DestinationRecordJsonSource

@JvmInline
value class DestinationRecordJsonSource(val source: AirbyteMessage) : DestinationRecordSource

Constructors

Link copied to clipboard
constructor(source: AirbyteMessage)

Properties

Link copied to clipboard
open override val emittedAtMs: Long
Link copied to clipboard
open override val fileReference: FileReference?
Link copied to clipboard
val source: AirbyteMessage
Link copied to clipboard
open override val sourceMeta: Meta

Functions

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