bulk-cdk-core-extract/io.airbyte.cdk.discover/MetaFieldDecorator

MetaFieldDecorator

interface MetaFieldDecorator

MetaField schema definition and utilities, to be implemented by each source connector.

Properties

Link copied to clipboard
abstract val globalCursor: FieldOrMetaField?

MetaField to use as a global cursor, if applicable.

Link copied to clipboard
abstract val globalMetaFields: Set<MetaField>

All MetaFields to be found in Global stream records.

Functions

Link copied to clipboard
open fun decorateAirbyteStream(airbyteStream: AirbyteStream)

Convenience function for AirbyteStreamFactory.

Link copied to clipboard
abstract fun decorateRecordData(timestamp: OffsetDateTime, globalStateValue: OpaqueStateValue?, stream: Stream, recordData: ObjectNode)

Modifies recordData by setting all MetaField values in global Stream feeds.

abstract fun decorateRecordData(timestamp: OffsetDateTime, globalStateValue: OpaqueStateValue?, stream: Stream, recordData: NativeRecordPayload)