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

TriggerSplittableSnapshotWithCursorPartition

class TriggerSplittableSnapshotWithCursorPartition(selectQueryGenerator: SelectQueryGenerator, streamState: TriggerStreamState, config: TriggerTableConfig, primaryKey: List<EmittedField>, triggerCdcPartitionState: TriggerCdcPartitionState? = null, val lowerBound: List<JsonNode>?, val upperBound: List<JsonNode>?, cursor: EmittedField, cursorUpperBound: JsonNode?) : TriggerCursorPartition(source)

Trigger-based implementation of a JdbcPartition for a splittable snapshot partition preceding a cursor-based incremental sync.

Constructors

TriggerSplittableSnapshotWithCursorPartition

constructor(selectQueryGenerator: SelectQueryGenerator, streamState: TriggerStreamState, config: TriggerTableConfig, primaryKey: List<EmittedField>, triggerCdcPartitionState: TriggerCdcPartitionState? = null, lowerBound: List<JsonNode>?, upperBound: List<JsonNode>?, cursor: EmittedField, cursorUpperBound: JsonNode?)

Properties

checkpointColumns

val checkpointColumns: List<EmittedField>

open override val completeState: OpaqueStateValue

val cursor: EmittedField

cursorUpperBound

val cursorUpperBound: JsonNode

cursorUpperBoundFrom

val cursorUpperBoundFrom: From

cursorUpperBoundQuery

open override val cursorUpperBoundQuery: SelectQuery

cursorUpperBoundQuerySpec

val cursorUpperBoundQuerySpec: SelectQuerySpec

isLowerBoundIncluded

open val isLowerBoundIncluded: Boolean = false

open override val lowerBound: List<JsonNode>?

nonResumableQuery

open override val nonResumableQuery: SelectQuery

nonResumableQuerySpec

val nonResumableQuerySpec: SelectQuerySpec

queryTableColumns

val queryTableColumns: List<EmittedField>

val queryTableFrom: From

selectQueryGenerator

val selectQueryGenerator: SelectQueryGenerator

val stream: Stream

override val streamState: TriggerStreamState

triggerCdcPartitionState

val triggerCdcPartitionState: TriggerCdcPartitionState?

triggerTableName

val triggerTableName: String

open override val upperBound: List<JsonNode>?

val where: Where

Functions

incompleteState

open override fun incompleteState(lastRecord: SelectQuerier.ResultRow): 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>?