bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.discover/JdbcAirbyteStreamFactory

JdbcAirbyteStreamFactory

interface JdbcAirbyteStreamFactory : AirbyteStreamFactory, MetaFieldDecorator

JdbcAirbyteStreamFactory implements create for JDBC sources.

Properties

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

Functions

Link copied to clipboard
open override fun create(config: SourceConfiguration, discoveredStream: DiscoveredStream): AirbyteStream
Link copied to clipboard
open fun decorateAirbyteStream(airbyteStream: AirbyteStream)
Link copied to clipboard
abstract fun decorateRecordData(timestamp: OffsetDateTime, globalStateValue: OpaqueStateValue?, stream: Stream, recordData: ObjectNode)
abstract fun decorateRecordData(timestamp: OffsetDateTime, globalStateValue: OpaqueStateValue?, stream: Stream, recordData: NativeRecordPayload)
Link copied to clipboard
open fun hasPotentialCursorFields(discoveredStream: DiscoveredStream): Boolean

Does the discoveredStream have a field that could serve as a cursor?

Link copied to clipboard
open fun hasValidPrimaryKey(discoveredStream: DiscoveredStream): Boolean

Does the discoveredStream have a valid primary key declared?

Link copied to clipboard
open fun isPossibleCursor(field: Field): Boolean

Can the field be used as a cursor in a cursor-based incremental sync?

Link copied to clipboard
open fun isPossiblePrimaryKeyElement(field: Field): Boolean

Can the field be used as part of a primary key?