MCPcopy Create free account
hub / github.com/apache/amoro / run

Method run

amoro-common/src/main/java/org/apache/amoro/client/ClientPool.java:29–29  ·  view source on GitHub ↗
(C client)

Source from the content-addressed store, hash-verified

27public interface ClientPool<C, E extends Exception> {
28 interface Action<R, C, E extends Exception> {
29 R run(C client) throws E;
30 }
31
32 <R> R run(Action<R, C, E> action) throws E, InterruptedException;

Callers 15

listDatabasesMethod · 0.65
databaseExistsMethod · 0.65
createDatabaseMethod · 0.65
dropDatabaseMethod · 0.65
dropTableMethod · 0.65
listTablesMethod · 0.65
loadHoodieHiveTableMethod · 0.65
acquireMethod · 0.65
deleteFilesMethod · 0.65
abortMethod · 0.65
commitTransactionMethod · 0.65
runMethod · 0.65

Implementers 15

Toucheramoro-ams/src/test/java/org/apache/amo
TestUnKeyedContinuousOptimizingamoro-ams/src/test/java/org/apache/amo
TestKeyedContinuousOptimizingamoro-ams/src/test/java/org/apache/amo
OptimizerKeeperamoro-ams/src/main/java/org/apache/amo
OptimizingConfigWatcheramoro-ams/src/main/java/org/apache/amo
SessionCleanTaskamoro-ams/src/main/java/org/apache/amo
OutputBufferThreadamoro-ams/src/main/java/org/apache/amo
FlinkToucheramoro-optimizer/amoro-optimizer-flink/
MockAmoroManagementServeramoro-common/src/test/java/org/apache/
ClientPoolImplamoro-common/src/main/java/org/apache/
MakeAccessibleamoro-common/src/main/java/org/apache/
CachedHiveClientPoolamoro-common/src/main/java/org/apache/

Calls

no outgoing calls

Tested by 11

triggerFailoverMethod · 0.52
triggerJobManagerFailoverMethod · 0.52
restartTaskManagerMethod · 0.52
assertAvailableFutureMethod · 0.52
compileClassMethod · 0.52
testUnPartitionTableSyncInIcebergMethod · 0.52
testUnPartitionTableSyncNotInIcebergMethod · 0.52
testSyncOnlyInIcebergMethod · 0.52
testSyncOnlyInHiveCreateByMixedHiveTableMethod · 0.52
testSyncOnlyInHiveCreateNotByMixedHiveTableMethod · 0.52
testSyncInBothMethod · 0.52