bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.jdbc/DefaultJdbcConstants

DefaultJdbcConstants

@ConfigurationProperties(value = "airbyte.connector.extract.jdbc")
data class DefaultJdbcConstants(val withSampling: Boolean = WITH_SAMPLING, val maxSampleSize: Int = TABLE_SAMPLE_SIZE, val expectedThroughputBytesPerSecond: Long = THROUGHPUT_BYTES_PER_SECOND, val minFetchSize: Int = FETCH_SIZE_LOWER_BOUND, val defaultFetchSize: Int = DEFAULT_FETCH_SIZE, val maxFetchSize: Int = FETCH_SIZE_UPPER_BOUND, val memoryCapacityRatio: Double = MEM_CAPACITY_RATIO, val estimatedRecordOverheadBytes: Long = RECORD_OVERHEAD_BYTES, val estimatedFieldOverheadBytes: Long = FIELD_OVERHEAD_BYTES, val maxMemoryBytesForTesting: Long? = null, val namespaceKind: DefaultJdbcConstants.NamespaceKind = NamespaceKind.SCHEMA)

Constructors

Link copied to clipboard
constructor(withSampling: Boolean = WITH_SAMPLING, maxSampleSize: Int = TABLE_SAMPLE_SIZE, expectedThroughputBytesPerSecond: Long = THROUGHPUT_BYTES_PER_SECOND, minFetchSize: Int = FETCH_SIZE_LOWER_BOUND, defaultFetchSize: Int = DEFAULT_FETCH_SIZE, maxFetchSize: Int = FETCH_SIZE_UPPER_BOUND, memoryCapacityRatio: Double = MEM_CAPACITY_RATIO, estimatedRecordOverheadBytes: Long = RECORD_OVERHEAD_BYTES, estimatedFieldOverheadBytes: Long = FIELD_OVERHEAD_BYTES, maxMemoryBytesForTesting: Long? = null, namespaceKind: DefaultJdbcConstants.NamespaceKind = NamespaceKind.SCHEMA)

Types

Link copied to clipboard
object Companion
Link copied to clipboard

Properties

Link copied to clipboard
val defaultFetchSize: Int

Default fetchSize value, in absence of any other estimate.

Link copied to clipboard
val estimatedFieldOverheadBytes: Long

Estimated bytes used as overhead for each column value in a java.sql.ResultSet.

Link copied to clipboard
val estimatedRecordOverheadBytes: Long

Estimated bytes used as overhead for each row in a java.sql.ResultSet.

Link copied to clipboard
val expectedThroughputBytesPerSecond: Long

How many bytes per second we can expect the database to send to the connector.

Link copied to clipboard
val maxFetchSize: Int

Largest possible fetchSize value.

Link copied to clipboard
val maxMemoryBytesForTesting: Long? = null

Overrides the JVM heap capacity to provide determinism in tests.

Link copied to clipboard
Link copied to clipboard
val memoryCapacityRatio: Double

How much of the JVM heap can we fill up with java.sql.ResultSet data.

Link copied to clipboard
val minFetchSize: Int

Smallest possible fetchSize value.

Link copied to clipboard
val namespaceKind: DefaultJdbcConstants.NamespaceKind

Whether the namespace field denotes a JDBC schema or a JDBC catalog.

Link copied to clipboard