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

TriggerUnsplittableSnapshotPartition

class TriggerUnsplittableSnapshotPartition(selectQueryGenerator: SelectQueryGenerator, streamState: TriggerStreamState, config: TriggerTableConfig) : TriggerUnsplittablePartition(source)

Trigger-based implementation of a JdbcPartition for an unsplittable snapshot partition.

Constructors

TriggerUnsplittableSnapshotPartition

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

Properties

open override val completeState: OpaqueStateValue

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>?