JdbcPartition

Encapsulates database-specific aspects relating to a JDBC stream partition, consumed by JdbcPartitionReader and friends.

Properties

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

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

abstract val streamState: S

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

abstract fun samplingQuery(sampleRateInvPow2: Int): SelectQuery

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

Tries to acquire resources for JdbcPartitionsCreator.

Tries to acquire resources for JdbcPartitionReader.