Uses of Class
org.apache.paimon.jdbc.JdbcClientPool

Packages that use JdbcClientPool

Package	Description
org.apache.paimon.jdbc

Uses of JdbcClientPool in org.apache.paimon.jdbc

Methods in org.apache.paimon.jdbc that return JdbcClientPool

Modifier and Type	Method and Description
JdbcClientPool	JdbcCatalogLockContext.connections()
JdbcClientPool	JdbcCatalog.getConnections()

Methods in org.apache.paimon.jdbc with parameters of type JdbcClientPool

Modifier and Type	Method and Description
static boolean	JdbcUtils.acquire(JdbcClientPool connections, String lockId, long timeoutMillSeconds)
static void	JdbcUtils.createDistributedLockTable(JdbcClientPool connections, Options options)
void	AbstractDistributedLockDialect.createTable(JdbcClientPool connections, Options options)
void	JdbcDistributedLockDialect.createTable(JdbcClientPool connections, Options options)
static boolean	JdbcUtils.databaseExists(JdbcClientPool connections, String storeKey, String databaseName)
static int	JdbcUtils.execute(java.util.function.Consumer<SQLException> sqlErrorHandler, JdbcClientPool connections, String sql, String... args)
static int	JdbcUtils.execute(JdbcClientPool connections, String sql, String... args)
static Map<String,String>	JdbcUtils.getTable(JdbcClientPool connections, String storeKey, String databaseName, String tableName) Get paimon table metadata.
static boolean	JdbcUtils.insertProperties(JdbcClientPool connections, String storeKey, String databaseName, Map<String,String> properties)
boolean	AbstractDistributedLockDialect.lockAcquire(JdbcClientPool connections, String lockId, long timeoutMillSeconds)
boolean	JdbcDistributedLockDialect.lockAcquire(JdbcClientPool connections, String lockId, long timeoutMillSeconds)
static void	JdbcUtils.release(JdbcClientPool connections, String lockId)
boolean	AbstractDistributedLockDialect.releaseLock(JdbcClientPool connections, String lockId)
boolean	JdbcDistributedLockDialect.releaseLock(JdbcClientPool connections, String lockId)
static boolean	JdbcUtils.tableExists(JdbcClientPool connections, String storeKey, String databaseName, String tableName)
int	AbstractDistributedLockDialect.tryReleaseTimedOutLock(JdbcClientPool connections, String lockId)
int	JdbcDistributedLockDialect.tryReleaseTimedOutLock(JdbcClientPool connections, String lockId)
static void	JdbcUtils.updateTable(JdbcClientPool connections, String storeKey, Identifier fromTable, Identifier toTable)

Constructors in org.apache.paimon.jdbc with parameters of type JdbcClientPool

Constructor and Description
JdbcCatalogLock(JdbcClientPool connections, String catalogKey, long checkMaxSleep, long acquireTimeout)