Airbyte Kotlin Bulk CDK

0.1.92

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

TriggerCursorPartition

sealed class TriggerCursorPartition : TriggerSplittablePartition, JdbcCursorPartition<TriggerStreamState>

Default implementation of a JdbcPartition for a splittable partition involving cursor columns.

Inheritors

TriggerSplittableSnapshotWithCursorPartition

TriggerCursorIncrementalPartition

Properties

checkpointColumns

val checkpointColumns: List<Field>

abstract val completeState: OpaqueStateValue

val cursor: Field

cursorUpperBound

val cursorUpperBound: JsonNode

cursorUpperBoundFrom

val cursorUpperBoundFrom: From

cursorUpperBoundQuery

open override val cursorUpperBoundQuery: SelectQuery

cursorUpperBoundQuerySpec

val cursorUpperBoundQuerySpec: SelectQuerySpec

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