DefaultJdbcUnsplittableSnapshotWithCursorPartition
class DefaultJdbcUnsplittableSnapshotWithCursorPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: DefaultJdbcStreamState, val cursor: Field) : DefaultJdbcUnsplittablePartition, JdbcCursorPartition<DefaultJdbcStreamState>
Default implementation of a JdbcPartition for an unsplittable snapshot partition preceding a cursor-based incremental sync.
Constructors
Link copied to clipboard
constructor(selectQueryGenerator: SelectQueryGenerator, streamState: DefaultJdbcStreamState, cursor: Field)
Properties
Link copied to clipboard
State value to emit when the partition is read in its entirety.
Link copied to clipboard
Query which produces the current maximum cursor value in the stream.
Link copied to clipboard
Link copied to clipboard
Query which produces all records in the partition in no particular order.
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
The partition's stream's transient state, including parameters like fetchSize, etc.
Functions
Link copied to clipboard
Query which samples records in the partition at the rate of 2^-sampleRateInvPow2.
Link copied to clipboard
Tries to acquire resources for JdbcPartitionsCreator.
Link copied to clipboard
open fun tryAcquireResourcesForReader(resourceTypes: List<ResourceType>): Map<ResourceType, JdbcPartitionReader.AcquiredResource>?
Tries to acquire resources for JdbcPartitionReader.