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

DestinationRecordProtobufSource

@JvmInline
value class DestinationRecordProtobufSource(val source: AirbyteMessage.AirbyteMessageProtobuf) : DestinationRecordSource

Constructors

Link copied to clipboard
constructor(source: AirbyteMessage.AirbyteMessageProtobuf)

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.AirbyteMessageProtobuf
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