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

Interface S3Options

All Superinterfaces:

AwsOptions, HasDisplayData, PipelineOptions

public interface S3Options
extends AwsOptions

Options used to configure Amazon Web Services S3.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	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.
static class	S3Options.SSECustomerKeyFactory

Nested classes/interfaces inherited from interface org.apache.beam.sdk.io.aws2.options.AwsOptions

AwsOptions.AwsRegionFactory, AwsOptions.AwsUserCredentialsFactory

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method	Description
boolean	getBucketKeyEnabled()
Class<? extends S3ClientBuilderFactory>	getS3ClientFactoryClass()
String	getS3StorageClass()
int	getS3ThreadPoolSize()
Integer	getS3UploadBufferSizeBytes()
@Nullable String	getSSEAlgorithm()
SSECustomerKey	getSSECustomerKey()
@Nullable String	getSSEKMSKeyId()
void	setBucketKeyEnabled(boolean value)
void	setS3ClientFactoryClass(Class<? extends S3ClientBuilderFactory> s3ClientFactoryClass)
void	setS3StorageClass(String value)
void	setS3ThreadPoolSize(int value)
void	setS3UploadBufferSizeBytes(Integer value)
void	setSSEAlgorithm(String value)
void	setSSECustomerKey(SSECustomerKey sseCustomerKey)
void	setSSEKMSKeyId(String value)

Methods inherited from interface org.apache.beam.sdk.io.aws2.options.AwsOptions

getAwsCredentialsProvider, getAwsRegion, getClientBuilderFactory, getEndpoint, getHttpClientConfiguration, getProxyConfiguration, setAwsCredentialsProvider, setAwsRegion, setClientBuilderFactory, setEndpoint, setHttpClientConfiguration, setProxyConfiguration

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getGbek, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setGbek, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Method Details

getS3StorageClass

@String("STANDARD")
String getS3StorageClass()

setS3StorageClass

void setS3StorageClass(String value)

getS3UploadBufferSizeBytes

@InstanceFactory(S3UploadBufferSizeBytesFactory.class)
Integer getS3UploadBufferSizeBytes()

setS3UploadBufferSizeBytes

void setS3UploadBufferSizeBytes(Integer value)

getS3ThreadPoolSize

@Integer(50)
int getS3ThreadPoolSize()

setS3ThreadPoolSize

void setS3ThreadPoolSize(int value)

getSSEAlgorithm

@Nullable String getSSEAlgorithm()

setSSEAlgorithm

void setSSEAlgorithm(String value)

getSSECustomerKey

@InstanceFactory(SSECustomerKeyFactory.class)
SSECustomerKey getSSECustomerKey()

setSSECustomerKey

void setSSECustomerKey(SSECustomerKey sseCustomerKey)

getSSEKMSKeyId

@Nullable String getSSEKMSKeyId()

setSSEKMSKeyId

void setSSEKMSKeyId(String value)

getBucketKeyEnabled

@Boolean(false)
boolean getBucketKeyEnabled()

setBucketKeyEnabled

void setBucketKeyEnabled(boolean value)

getS3ClientFactoryClass

@Class(DefaultS3ClientBuilderFactory.class)
Class<? extends S3ClientBuilderFactory> getS3ClientFactoryClass()

setS3ClientFactoryClass

void setS3ClientFactoryClass(Class<? extends S3ClientBuilderFactory> s3ClientFactoryClass)