Airbyte Kotlin Bulk CDK

0.1.92

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

TriggerUnsplittablePartition

sealed class TriggerUnsplittablePartition : TriggerPartition

Base class for trigger-based implementations of JdbcPartition for unsplittable partitions.

Inheritors

TriggerUnsplittableSnapshotPartition

TriggerUnsplittableSnapshotWithCursorPartition

Properties

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