Airbyte Kotlin Bulk CDK

0.1.92

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

TriggerPartitionsCreator

class TriggerPartitionsCreator<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(val partition: P, val partitionFactory: JdbcPartitionFactory<A, S, P>, val config: TriggerTableConfig, val deleteQuerier: DeleteQuerier) : PartitionsCreator

Concurrent Trigger-based implementation of PartitionsCreator.

Constructors

TriggerPartitionsCreator

constructor(partition: P, partitionFactory: JdbcPartitionFactory<A, S, P>, config: TriggerTableConfig, deleteQuerier: DeleteQuerier)

Types

CheckpointOnlyPartitionReader

inner class CheckpointOnlyPartitionReader : PartitionReader

Properties

val config: TriggerTableConfig

val deleteQuerier: DeleteQuerier

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