bulk-cdk-toolkit-extract-trigger/io.airbyte.cdk/TriggerPartitionReader

TriggerPartitionReader

abstract class TriggerPartitionReader<P : JdbcPartition<*>>(val partition: P, config: TriggerTableConfig) : UnlimitedTimePartitionReader(source)

Base class for Trigger-based CDC implementations of PartitionReader using JDBC.

Inheritors

TriggerNonResumablePartitionReader

Constructors

TriggerPartitionReader

constructor(partition: P, config: TriggerTableConfig)

Properties

outputMessageRouter

lateinit var outputMessageRouter: OutputMessageRouter

lateinit var outputRoute: (NativeRecordPayload, Map<EmittedField, FieldValueChange>?) -> Unit

val partition: P

val selectQuerier: SelectQuerier

val sharedState: JdbcSharedState

val stream: Stream

val streamState: JdbcStreamState<*>

Functions

abstract fun checkpoint(): PartitionReadCheckpoint

fun out(row: SelectQuerier.ResultRow)

releaseResources

open override fun releaseResources()

abstract suspend fun run()

tryAcquireResources

open override fun tryAcquireResources(): PartitionReader.TryAcquireResourcesStatus