Airbyte Kotlin Bulk CDK

0.1.92

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

TriggerUnsplittableSnapshotWithCursorPartition

class TriggerUnsplittableSnapshotWithCursorPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: TriggerStreamState, val cursor: Field, config: TriggerTableConfig) : TriggerUnsplittablePartition, JdbcCursorPartition<TriggerStreamState>

Trigger-based implementation of a JdbcPartition for an unsplittable snapshot partition preceding a cursor-based incremental sync.

Constructors

TriggerUnsplittableSnapshotWithCursorPartition

constructor(selectQueryGenerator: SelectQueryGenerator, streamState: TriggerStreamState, cursor: Field, config: TriggerTableConfig)

Properties

open override val completeState: OpaqueStateValue

val cursor: Field

cursorUpperBoundQuery

open override val cursorUpperBoundQuery: SelectQuery

cursorUpperBoundQuerySpec

val cursorUpperBoundQuerySpec: SelectQuerySpec

nonResumableQuery

open override val nonResumableQuery: SelectQuery

nonResumableQuerySpec

val nonResumableQuerySpec: SelectQuerySpec

selectQueryGenerator

val selectQueryGenerator: SelectQueryGenerator

val stream: Stream

override val streamState: TriggerStreamState

Functions

open override fun samplingQuery(sampleRateInvPow2: Int): SelectQuery

tryAcquireResourcesForCreator

open fun tryAcquireResourcesForCreator(): JdbcPartitionsCreator.AcquiredResources?

tryAcquireResourcesForReader

open fun tryAcquireResourcesForReader(resourceTypes: List<ResourceType>): Map<ResourceType, JdbcPartitionReader.AcquiredResource>?