bulk-cdk-toolkit-extract-trigger/io.airbyte.cdk.operations/TriggerStreamFactory

TriggerStreamFactory

@Singleton
@Primary
class TriggerStreamFactory(config: TriggerTableConfig) : JdbcAirbyteStreamFactory

Constructors

Link copied to clipboard
constructor(config: TriggerTableConfig)

Properties

Link copied to clipboard
open override val globalCursor: FieldOrMetaField
Link copied to clipboard
open override 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
open override fun decorateRecordData(timestamp: OffsetDateTime, globalStateValue: OpaqueStateValue?, stream: Stream, recordData: ObjectNode)
open override fun decorateRecordData(timestamp: OffsetDateTime, globalStateValue: OpaqueStateValue?, stream: Stream, recordData: NativeRecordPayload)
Link copied to clipboard
open fun hasPotentialCursorFields(discoveredStream: DiscoveredStream): Boolean
Link copied to clipboard
open fun hasValidPrimaryKey(discoveredStream: DiscoveredStream): Boolean
Link copied to clipboard
open fun isPossibleCursor(field: Field): Boolean
Link copied to clipboard