Class DeephavenAwsClientFactory

java.lang.Object
io.deephaven.iceberg.util.DeephavenAwsClientFactory
All Implemented Interfaces:
Serializable, org.apache.iceberg.aws.AwsClientFactory

public class DeephavenAwsClientFactory extends Object implements org.apache.iceberg.aws.AwsClientFactory
Deephaven’s default AwsClientFactory implementation. This class internally delegates to Iceberg's default AWS client factory using AwsClientFactories.from(java.util.Map<java.lang.String, java.lang.String>) and serves as the central place for DH-specific injection-fixes. For example, we use this to configure additional AsyncHttpClientProperties for the async s3 client,
See Also:
  • Constructor Details

    • DeephavenAwsClientFactory

      public DeephavenAwsClientFactory()
  • Method Details

    • initialize

      public void initialize(Map<String,String> properties)
      Specified by:
      initialize in interface org.apache.iceberg.aws.AwsClientFactory
    • s3

      public software.amazon.awssdk.services.s3.S3Client s3()
      Specified by:
      s3 in interface org.apache.iceberg.aws.AwsClientFactory
    • glue

      public software.amazon.awssdk.services.glue.GlueClient glue()
      Specified by:
      glue in interface org.apache.iceberg.aws.AwsClientFactory
    • kms

      public software.amazon.awssdk.services.kms.KmsClient kms()
      Specified by:
      kms in interface org.apache.iceberg.aws.AwsClientFactory
    • dynamo

      public software.amazon.awssdk.services.dynamodb.DynamoDbClient dynamo()
      Specified by:
      dynamo in interface org.apache.iceberg.aws.AwsClientFactory
    • s3Async

      public software.amazon.awssdk.services.s3.S3AsyncClient s3Async()
      Specified by:
      s3Async in interface org.apache.iceberg.aws.AwsClientFactory