Package org.apache.beam.sdk.io.aws2.common

Class ObjectPool.ClientPool<ClientT extends SdkClient>

java.lang.Object

org.apache.beam.sdk.io.aws2.common.ObjectPool<Pair<AwsOptions,ClientConfiguration>,ClientT>

org.apache.beam.sdk.io.aws2.common.ObjectPool.ClientPool<ClientT>

Enclosing class:

ObjectPool<KeyT extends @NonNull Object,ObjectT extends @NonNull Object>

public static class ObjectPool.ClientPool<ClientT extends SdkClient>
extends ObjectPool<Pair<AwsOptions,ClientConfiguration>,ClientT>

Client pool to easily share AWS clients per configuration.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.io.aws2.common.ObjectPool

ObjectPool.ClientPool<ClientT extends SdkClient>

Method Summary

Modifier and Type	Method	Description
ClientT	retain(AwsOptions provider, ClientConfiguration config)	Retain a reference to a shared client instance.

Methods inherited from class org.apache.beam.sdk.io.aws2.common.ObjectPool

pooledClientFactory, release, releaseByKey, retain

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

retain

public ClientT retain(AwsOptions provider,
 ClientConfiguration config)

Retain a reference to a shared client instance. If not available, an instance is created.