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

TriggerCursorIncrementalPartition

class TriggerCursorIncrementalPartition(selectQueryGenerator: SelectQueryGenerator, streamState: TriggerStreamState, config: TriggerTableConfig, cursor: EmittedField, triggerCdcPartitionState: TriggerCdcPartitionState? = null, val cursorLowerBound: JsonNode, val isLowerBoundIncluded: Boolean, cursorUpperBound: JsonNode?) : TriggerCursorPartition(source)

Trigger-based implementation of a JdbcPartition for a cursor incremental partition. These are always splittable.

Constructors

TriggerCursorIncrementalPartition

constructor(selectQueryGenerator: SelectQueryGenerator, streamState: TriggerStreamState, config: TriggerTableConfig, cursor: EmittedField, triggerCdcPartitionState: TriggerCdcPartitionState? = null, cursorLowerBound: JsonNode, isLowerBoundIncluded: Boolean, cursorUpperBound: JsonNode?)

Properties

checkpointColumns

val checkpointColumns: List<EmittedField>

open override val completeState: OpaqueStateValue

val cursor: EmittedField

cursorLowerBound

val cursorLowerBound: JsonNode

cursorUpperBound

val cursorUpperBound: JsonNode

cursorUpperBoundFrom

val cursorUpperBoundFrom: From

cursorUpperBoundQuery

open override val cursorUpperBoundQuery: SelectQuery

cursorUpperBoundQuerySpec

val cursorUpperBoundQuerySpec: SelectQuerySpec

isLowerBoundIncluded

open override val isLowerBoundIncluded: Boolean

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