public interface S3Options extends AwsOptions
Modifier and Type | Interface and Description |
---|---|
static class |
S3Options.S3UploadBufferSizeBytesFactory
Provide the default s3 upload buffer size in bytes: 64MB if more than 512MB in RAM are
available and 5MB otherwise.
|
AwsOptions.AwsUserCredentialsFactory, AwsOptions.ClientConfigurationFactory
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.NoOpMetricsSink, PipelineOptions.UserAgentFactory
Modifier and Type | Method and Description |
---|---|
java.lang.Class<? extends S3ClientBuilderFactory> |
getS3ClientFactoryClass() |
java.lang.String |
getS3StorageClass() |
int |
getS3ThreadPoolSize() |
java.lang.Integer |
getS3UploadBufferSizeBytes() |
java.lang.String |
getSSEAlgorithm() |
com.amazonaws.services.s3.model.SSEAwsKeyManagementParams |
getSSEAwsKeyManagementParams() |
com.amazonaws.services.s3.model.SSECustomerKey |
getSSECustomerKey() |
void |
setS3ClientFactoryClass(java.lang.Class<? extends S3ClientBuilderFactory> s3ClientFactoryClass) |
void |
setS3StorageClass(java.lang.String value) |
void |
setS3ThreadPoolSize(int value) |
void |
setS3UploadBufferSizeBytes(java.lang.Integer value) |
void |
setSSEAlgorithm(java.lang.String value) |
void |
setSSEAwsKeyManagementParams(com.amazonaws.services.s3.model.SSEAwsKeyManagementParams value) |
void |
setSSECustomerKey(com.amazonaws.services.s3.model.SSECustomerKey value) |
getAwsCredentialsProvider, getAwsRegion, getAwsServiceEndpoint, getClientConfiguration, setAwsCredentialsProvider, setAwsRegion, setAwsServiceEndpoint, setClientConfiguration
as, getJobName, getMetricsGraphiteHost, getMetricsGraphitePort, getMetricsHttpSinkUrl, getMetricsPushPeriod, getMetricsSink, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setMetricsGraphiteHost, setMetricsGraphitePort, setMetricsHttpSinkUrl, setMetricsPushPeriod, setMetricsSink, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
@Default.String(value="STANDARD") java.lang.String getS3StorageClass()
void setS3StorageClass(java.lang.String value)
@Default.InstanceFactory(value=S3Options.S3UploadBufferSizeBytesFactory.class) java.lang.Integer getS3UploadBufferSizeBytes()
void setS3UploadBufferSizeBytes(java.lang.Integer value)
@Default.Integer(value=50) int getS3ThreadPoolSize()
void setS3ThreadPoolSize(int value)
@Nullable java.lang.String getSSEAlgorithm()
void setSSEAlgorithm(java.lang.String value)
@Nullable com.amazonaws.services.s3.model.SSECustomerKey getSSECustomerKey()
void setSSECustomerKey(com.amazonaws.services.s3.model.SSECustomerKey value)
@Nullable com.amazonaws.services.s3.model.SSEAwsKeyManagementParams getSSEAwsKeyManagementParams()
void setSSEAwsKeyManagementParams(com.amazonaws.services.s3.model.SSEAwsKeyManagementParams value)
@Default.Class(value=DefaultS3ClientBuilderFactory.class) java.lang.Class<? extends S3ClientBuilderFactory> getS3ClientFactoryClass()
void setS3ClientFactoryClass(java.lang.Class<? extends S3ClientBuilderFactory> s3ClientFactoryClass)