Contents

package org.embulk.output.s3_parquet.aws


import java.util.Optional

import com.amazonaws.ClientConfiguration
import com.amazonaws.client.builder.AwsClientBuilder
import org.embulk.config.{Config, ConfigDefault}
import org.embulk.output.s3_parquet.aws.AwsClientConfiguration.Task


object AwsClientConfiguration
{

    trait Task
    {

        @Config("http_proxy")
        @ConfigDefault("null")
        def getHttpProxy: Optional[HttpProxy.Task]

    }

    def apply(task: Task): AwsClientConfiguration =
    {
        new AwsClientConfiguration(task)
    }
}

class AwsClientConfiguration(task: Task)
{

    def configureAwsClientBuilder[S <: AwsClientBuilder[S, T], T](builder: AwsClientBuilder[S, T]): Unit =
    {
        task.getHttpProxy.ifPresent { v =>
            val cc = new ClientConfiguration
            HttpProxy(v).configureClientConfiguration(cc)
            builder.setClientConfiguration(cc)
        }
    }

}

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
embulk-output-s3_parquet-0.1.0	src/main/scala/org/embulk/output/s3_parquet/aws/AwsClientConfiguration.scala
embulk-output-s3_parquet-0.0.3	src/main/scala/org/embulk/output/s3_parquet/aws/AwsClientConfiguration.scala