JdbcSplittablePartition

Properties

Link copied to clipboard

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

Link copied to clipboard

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

Link copied to clipboard
abstract val streamState: S

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

Functions

Link copied to clipboard
abstract fun incompleteState(lastRecord: ObjectNode): OpaqueStateValue

State value to emit when the partition is read up to (and including) lastRecord.

Link copied to clipboard
abstract fun resumableQuery(limit: Long): SelectQuery

Query which produces a subset of records at the beginning of the partition.

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

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

Link copied to clipboard