Airbyte Kotlin Bulk CDK

0.1.92

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

TriggerSplittablePartition

sealed class TriggerSplittablePartition : TriggerPartition, JdbcSplittablePartition<TriggerStreamState>

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

Inheritors

TriggerSplittableSnapshotPartition

TriggerCursorPartition

Properties

checkpointColumns

val checkpointColumns: List<Field>

abstract val completeState: OpaqueStateValue

isLowerBoundIncluded

open val isLowerBoundIncluded: Boolean = false

abstract val lowerBound: List<JsonNode>?

nonResumableQuery

open override val nonResumableQuery: SelectQuery

nonResumableQuerySpec

val nonResumableQuerySpec: SelectQuerySpec

queryTableColumns

val queryTableColumns: List<Field>

val queryTableFrom: From

selectQueryGenerator

val selectQueryGenerator: SelectQueryGenerator

val stream: Stream

override val streamState: TriggerStreamState

triggerCdcPartitionState

val triggerCdcPartitionState: TriggerCdcPartitionState? = null

triggerTableName

val triggerTableName: String

abstract val upperBound: List<JsonNode>?

val where: Where

Functions

incompleteState

abstract fun incompleteState(lastRecord: ObjectNode): OpaqueStateValue

open override fun resumableQuery(limit: Long): SelectQuery

open override fun samplingQuery(sampleRateInvPow2: Int): SelectQuery

tryAcquireResourcesForCreator

open fun tryAcquireResourcesForCreator(): JdbcPartitionsCreator.AcquiredResources?

tryAcquireResourcesForReader

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