Airbyte Kotlin Bulk CDK

0.1.92

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

JdbcConcurrentPartitionsCreator

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

Concurrent JDBC implementation of PartitionsCreator.

Constructors

JdbcConcurrentPartitionsCreator

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

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()

open suspend override fun run(): List<PartitionReader>

tryAcquireResources

open override fun tryAcquireResources(): PartitionsCreator.TryAcquireResourcesStatus