Airbyte Kotlin Bulk CDK

0.1.92

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

TriggerNonResumablePartitionReader

class TriggerNonResumablePartitionReader<P : JdbcPartition<*>>(partition: P, config: TriggerTableConfig, val deleteQuerier: DeleteQuerier) : TriggerPartitionReader<P>

Trigger-based implementation of PartitionReader which reads the partition in its entirety.

Constructors

TriggerNonResumablePartitionReader

constructor(partition: P, config: TriggerTableConfig, deleteQuerier: DeleteQuerier)

Properties

val deleteQuerier: DeleteQuerier

val numRecords: AtomicLong

outputMessageRouter

lateinit var outputMessageRouter: OutputMessageRouter

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

val partition: P

val runComplete: AtomicBoolean

val selectQuerier: SelectQuerier

val sharedState: JdbcSharedState

val stream: Stream

val streamState: JdbcStreamState<*>

Functions

open override fun checkpoint(): PartitionReadCheckpoint

fun out(row: SelectQuerier.ResultRow)

releaseResources

open override fun releaseResources()

open suspend override fun run()

tryAcquireResources

open override fun tryAcquireResources(): PartitionReader.TryAcquireResourcesStatus