bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.read/DefaultUnsplittableJdbcCursorIncrementalPartition

DefaultUnsplittableJdbcCursorIncrementalPartition

class DefaultUnsplittableJdbcCursorIncrementalPartition(val selectQueryGenerator: SelectQueryGenerator, streamState: DefaultJdbcStreamState, val cursor: EmittedField, val cursorLowerBound: JsonNode, val isLowerBoundIncluded: Boolean, val explicitCursorUpperBound: JsonNode?) : DefaultJdbcUnsplittablePartition, JdbcCursorPartition<DefaultJdbcStreamState>

Constructors

constructor(selectQueryGenerator: SelectQueryGenerator, streamState: DefaultJdbcStreamState, cursor: EmittedField, cursorLowerBound: JsonNode, isLowerBoundIncluded: Boolean, explicitCursorUpperBound: JsonNode?)

Properties

checkpointColumns

val checkpointColumns: List<EmittedField>

completeState

open override val completeState: OpaqueStateValue

State value to emit when the partition is read in its entirety.

cursor

val cursor: EmittedField

cursorLowerBound

val cursorLowerBound: JsonNode

cursorUpperBound

val cursorUpperBound: JsonNode

cursorUpperBoundQuery

open override val cursorUpperBoundQuery: SelectQuery

Query which produces the current maximum cursor value in the stream.

cursorUpperBoundQuerySpec

val cursorUpperBoundQuerySpec: SelectQuerySpec

explicitCursorUpperBound

val explicitCursorUpperBound: JsonNode?

from

val from: From

isLowerBoundIncluded

val isLowerBoundIncluded: Boolean

lowerBound

val lowerBound: List<JsonNode>

nonResumableQuery

abstract val nonResumableQuery: SelectQuery

Query which produces all records in the partition in no particular order.

nonResumableQuerySpec

open override val nonResumableQuerySpec: SelectQuerySpec

selectQueryGenerator

val selectQueryGenerator: SelectQueryGenerator

stream

val stream: Stream

streamState

abstract val streamState: DefaultJdbcStreamState

The partition's stream's transient state, including parameters like fetchSize, etc.

upperBound

val upperBound: List<JsonNode>

where

val where: WhereNode

Functions

samplingQuery

open override fun samplingQuery(sampleRateInvPow2: Int): SelectQuery

Query which samples records in the partition at the rate of 2^-sampleRateInvPow2.

tryAcquireResourcesForCreator

open fun tryAcquireResourcesForCreator(): JdbcPartitionsCreator.AcquiredResources?

Tries to acquire resources for JdbcPartitionsCreator.

tryAcquireResourcesForReader

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

Tries to acquire resources for JdbcPartitionReader.