JdbcCursorPartition

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
abstract val streamState: S

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

Functions

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