Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.read/JdbcSharedState

JdbcSharedState

@DefaultImplementation(value = DefaultJdbcSharedState::class)

interface JdbcSharedState

Encapsulates database-specific state, both constant or transient, common to all partitions.

Implementations should be thread-safe.

Inheritors

DefaultJdbcSharedState

Types

JdbcFetchSizeEstimator

fun interface JdbcFetchSizeEstimator

RowByteSizeEstimator

fun interface RowByteSizeEstimator

Properties

abstract val configuration: JdbcSourceConfiguration

Configuration for the JDBC source connector.

abstract val maxSampleSize: Int

Sample size limit.

abstract val selectQuerier: SelectQuerier

Queries the database.

snapshotReadStartTime

abstract val snapshotReadStartTime: Instant

Keeping the time when the read operation started.

targetPartitionByteSize

abstract val targetPartitionByteSize: Long

Targeted memory footprint of a partition, in bytes.

abstract val withSampling: Boolean

Is sampling the streams a good idea?

Functions

jdbcFetchSizeEstimator

abstract fun jdbcFetchSizeEstimator(): JdbcSharedState.JdbcFetchSizeEstimator

Creates a new instance of a JdbcFetchSizeEstimator.

rowByteSizeEstimator

abstract fun rowByteSizeEstimator(): JdbcSharedState.RowByteSizeEstimator

Creates a new instance of a RowByteSizeEstimator.

tryAcquireResourcesForCreator

abstract fun tryAcquireResourcesForCreator(): JdbcPartitionsCreator.AcquiredResources?

Tries to acquire global resources for JdbcPartitionsCreator.

tryAcquireResourcesForReader

abstract fun tryAcquireResourcesForReader(resourcesTypes: List<ResourceType>): Map<ResourceType, JdbcPartitionReader.AcquiredResource>?

Tries to acquire global resources for JdbcPartitionReader.