Airbyte Kotlin Bulk CDK

0.1.92

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

TriggerPartition

sealed class TriggerPartition : JdbcPartition<TriggerStreamState>

Inheritors

TriggerUnsplittablePartition

TriggerSplittablePartition

Properties

abstract val completeState: OpaqueStateValue

nonResumableQuery

abstract val nonResumableQuery: SelectQuery

selectQueryGenerator

val selectQueryGenerator: SelectQueryGenerator

val stream: Stream

override val streamState: TriggerStreamState

Functions

abstract fun samplingQuery(sampleRateInvPow2: Int): SelectQuery

tryAcquireResourcesForCreator

open fun tryAcquireResourcesForCreator(): JdbcPartitionsCreator.AcquiredResources?

tryAcquireResourcesForReader

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