org.apache.paimon.client

Interface ClientPool<C,E extends Exception>

All Known Implementing Classes:

CachedClientPool, ClientPool.ClientPoolImpl, HiveClientPool, JdbcClientPool

public interface ClientPool<C,E extends Exception>

Client pool for using multiple clients to execute actions.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ClientPool.Action<R,C,E extends Exception> Action interface with return object for client.
static class	ClientPool.ClientPoolImpl<C,E extends Exception> Default implementation for ClientPool.
static interface	ClientPool.ExecuteAction<C,E extends Exception> Action interface with return void for client.

Method Summary

Modifier and Type	Method and Description
void	execute(ClientPool.ExecuteAction<C,E> action)
void	execute(ClientPool.ExecuteAction<C,E> action, boolean retry)
<R> R	run(ClientPool.Action<R,C,E> action)
<R> R	run(ClientPool.Action<R,C,E> action, boolean retry)

Method Detail

run

<R> R run(ClientPool.Action<R,C,E> action)
   throws E extends Exception,
          InterruptedException

Throws:

E extends Exception

InterruptedException

run

<R> R run(ClientPool.Action<R,C,E> action,
          boolean retry)
   throws E extends Exception,
          InterruptedException

Throws:

E extends Exception

InterruptedException

execute

void execute(ClientPool.ExecuteAction<C,E> action)
      throws E extends Exception,
             InterruptedException

Throws:

E extends Exception

InterruptedException

execute

void execute(ClientPool.ExecuteAction<C,E> action,
             boolean retry)
      throws E extends Exception,
             InterruptedException

Throws:

E extends Exception

InterruptedException