Airbyte Kotlin Bulk CDK

0.1.92

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

JdbcPartitionsCreator

abstract class JdbcPartitionsCreator<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(val partition: P, val partitionFactory: JdbcPartitionFactory<A, S, P>) : PartitionsCreator

Base class for JDBC implementations of PartitionsCreator.

Inheritors

JdbcSequentialPartitionsCreator

JdbcConcurrentPartitionsCreator

Constructors

JdbcPartitionsCreator

constructor(partition: P, partitionFactory: JdbcPartitionFactory<A, S, P>)

Types

AcquiredResources

fun interface AcquiredResources : AutoCloseable

Calling close releases the resources acquired for the JdbcPartitionsCreator.

CheckpointOnlyPartitionReader

inner class CheckpointOnlyPartitionReader : PartitionReader

Properties

val configuration: JdbcSourceConfiguration

val partition: P

partitionFactory

val partitionFactory: JdbcPartitionFactory<A, S, P>

val selectQuerier: SelectQuerier

val sharedState: A

val stream: Stream

val streamState: S

Functions

fun <T> collectSample(recordMapper: (ObjectNode) -> T): Sample<T>

Collects a sample of rows in the unsplit partition.

ensureCursorUpperBound

fun ensureCursorUpperBound()

releaseResources

open override fun releaseResources()

abstract suspend fun run(): List<PartitionReader>

tryAcquireResources

open override fun tryAcquireResources(): PartitionsCreator.TryAcquireResourcesStatus