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

TriggerUnsplittableSnapshotPartition

class TriggerUnsplittableSnapshotPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: TriggerStreamState, config: TriggerTableConfig) : TriggerUnsplittablePartition

Trigger-based implementation of a JdbcPartition for an unsplittable snapshot partition.

Constructors

Link copied to clipboard
constructor(selectQueryGenerator: SelectQueryGenerator, streamState: TriggerStreamState, config: TriggerTableConfig)

Properties

Link copied to clipboard
open override val completeState: OpaqueStateValue
Link copied to clipboard
val from: From
Link copied to clipboard
open override val nonResumableQuery: SelectQuery
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val stream: Stream
Link copied to clipboard

Functions

Link copied to clipboard
open override fun samplingQuery(sampleRateInvPow2: Int): SelectQuery
Link copied to clipboard
Link copied to clipboard