JdbcCursorPartition
A JdbcPartition which allows cursor-based incremental reads.
Inheritors
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
Query which produces all records in the partition in no particular order.
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.