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

DefaultJdbcSharedState

@Singleton
class DefaultJdbcSharedState(val configuration: JdbcSourceConfiguration, val selectQuerier: SelectQuerier, val constants: DefaultJdbcConstants, val concurrencyResource: ConcurrencyResource, val resourceAcquirer: ResourceAcquirer) : JdbcSharedState

Default implementation of JdbcSharedState.

Constructors

Link copied to clipboard
constructor(configuration: JdbcSourceConfiguration, selectQuerier: SelectQuerier, constants: DefaultJdbcConstants, concurrencyResource: ConcurrencyResource, resourceAcquirer: ResourceAcquirer)

Properties

Link copied to clipboard
Link copied to clipboard
open override val configuration: JdbcSourceConfiguration

Configuration for the JDBC source connector.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override val maxSampleSize: Int

Sample size limit.

Link copied to clipboard
Link copied to clipboard
open override val selectQuerier: SelectQuerier

Queries the database.

Link copied to clipboard
open override val snapshotReadStartTime: Instant

Keeping the time when the read operation started.

Link copied to clipboard
open override val targetPartitionByteSize: Long

Targeted memory footprint of a partition, in bytes.

Link copied to clipboard
open override val withSampling: Boolean

Is sampling the streams a good idea?

Functions

Link copied to clipboard
open override fun jdbcFetchSizeEstimator(): JdbcSharedState.JdbcFetchSizeEstimator

Creates a new instance of a JdbcFetchSizeEstimator.

Link copied to clipboard
open override fun rowByteSizeEstimator(): JdbcSharedState.RowByteSizeEstimator

Creates a new instance of a RowByteSizeEstimator.

Link copied to clipboard
open override fun tryAcquireResourcesForCreator(): JdbcPartitionsCreator.AcquiredResources?

Tries to acquire global resources for JdbcPartitionsCreator.

Link copied to clipboard
open override fun tryAcquireResourcesForReader(resourcesTypes: List<ResourceType>): Map<ResourceType, JdbcPartitionReader.AcquiredResource>?

Tries to acquire global resources for JdbcPartitionReader.