Airbyte Kotlin Bulk CDK

0.1.92

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

DefaultJdbcUnsplittableSnapshotPartition

class DefaultJdbcUnsplittableSnapshotPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: DefaultJdbcStreamState) : DefaultJdbcUnsplittablePartition

Default implementation of a JdbcPartition for an unsplittable snapshot partition.

Constructors

DefaultJdbcUnsplittableSnapshotPartition

constructor(selectQueryGenerator: SelectQueryGenerator, streamState: DefaultJdbcStreamState)

Properties

open override val completeState: OpaqueStateValue

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

nonResumableQuery

open override val nonResumableQuery: SelectQuery

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

nonResumableQuerySpec

val nonResumableQuerySpec: SelectQuerySpec

selectQueryGenerator

val selectQueryGenerator: SelectQueryGenerator

val stream: Stream

override val streamState: DefaultJdbcStreamState

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

Functions

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.