Package org.apache.flink.cdc.connectors.mysql.source.connection

Interface ConnectionPools

  • All Known Implementing Classes:
    JdbcConnectionPools
    @Internal
public interface ConnectionPools
    A JDBC connection pools that consists of HikariDataSource.

    • Method Detail

      • getOrCreateConnectionPool

        com.zaxxer.hikari.HikariDataSource getOrCreateConnectionPool​(ConnectionPoolId poolId,
                                                             MySqlSourceConfig sourceConfig)
        Gets a connection pool from pools, create a new pool if the pool does not exists in the connection pools .