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

TriggerSplittableSnapshotPartition

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

Default implementation of a JdbcPartition for a splittable snapshot partition.

Constructors

TriggerSplittableSnapshotPartition

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

Properties

checkpointColumns

val checkpointColumns: List<EmittedField>

open override val completeState: OpaqueStateValue

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