DefaultJdbcFetchSizeEstimator

class DefaultJdbcFetchSizeEstimator(val maxMemoryBytes: Long, val maxConcurrency: Int, val minFetchSize: Int, val defaultFetchSize: Int, val maxFetchSize: Int, val memoryCapacityRatio: Double) : JdbcSharedState.JdbcFetchSizeEstimator

FetchSizeEstimator is used to estimate the value of the JDBC fetchSize parameter to fill up a portion of the JVM heap defined by MEM_CAPACITY_RATIO.

Constructors

constructor(maxMemoryBytes: Long, maxConcurrency: Int, minFetchSize: Int, defaultFetchSize: Int, maxFetchSize: Int, memoryCapacityRatio: Double)

open override fun apply(rowByteSizeSample: Sample<Long>): Int

Estimates a good JDBC fetchSize value based on a rowByteSizeSample.