Airbyte Kotlin Bulk CDK

1.0.4

bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.command/JdbcSourceConfiguration

JdbcSourceConfiguration

interface JdbcSourceConfiguration : SourceConfiguration

Subtype of SourceConfiguration for JDBC sources.

Types

object Companion

Properties

checkpointTargetInterval

abstract val checkpointTargetInterval: Duration

checkPrivileges

open val checkPrivileges: Boolean

When set, each table is queried individually to check for SELECT privileges.

abstract val global: Boolean

abstract val jdbcProperties: Map<String, String>

Properties map (with username, password, etc.) passed along to the JDBC driver.

abstract val jdbcUrlFmt: String

JDBC URL format string with placeholders for the host and port. These are dynamically assigned by SSH tunnel port forwarding, if applicable.

abstract val maxConcurrency: Int

maxSnapshotReadDuration

abstract val maxSnapshotReadDuration: Duration?

abstract val namespaces: Set<String>

Namespaces for the connector to consider. Empty means all namespaces.

abstract val realHost: String

abstract val realPort: Int

resourceAcquisitionHeartbeat

abstract val resourceAcquisitionHeartbeat: Duration

sshConnectionOptions

abstract val sshConnectionOptions: SshConnectionOptions

abstract val sshTunnel: SshTunnelMethodConfiguration?

open val tableFilters: List<TableFilter>

Optional table filtering configuration for fine-grained table selection.

Functions

open fun isCdc(): Boolean