Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.read/JdbcPartitionReader

JdbcPartitionReader

sealed class JdbcPartitionReader<P : JdbcPartition<*>> : PartitionReader

Base class for JDBC implementations of PartitionReader.

Inheritors

JdbcNonResumablePartitionReader

JdbcResumablePartitionReader

Types

AcquiredResource

interface AcquiredResource : AutoCloseable

Calling close releases the resources acquired for the JdbcPartitionReader.

Properties

outputMessageRouter

lateinit var outputMessageRouter: OutputMessageRouter

lateinit var outputRoute: (NativeRecordPayload, Map<Field, 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