org.apache.beam.sdk.io.aws.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/interfaces inherited from interface org.apache.beam.sdk.io.aws.options.AwsOptions

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 and Description
java.lang.String	getS3StorageClass()
int	getS3ThreadPoolSize()
java.lang.Integer	getS3UploadBufferSizeBytes()
void	setS3StorageClass(java.lang.String value)
void	setS3ThreadPoolSize(int value)
void	setS3UploadBufferSizeBytes(java.lang.Integer value)

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

getAwsCredentialsProvider, getAwsRegion, getAwsServiceEndpoint, setAwsCredentialsProvider, setAwsRegion, setAwsServiceEndpoint

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

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

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

populateDisplayData

Method Detail

getS3StorageClass

@Default.String(value="STANDARD")
java.lang.String getS3StorageClass()

setS3StorageClass

void setS3StorageClass(java.lang.String value)

getS3UploadBufferSizeBytes

@Nullable
java.lang.Integer getS3UploadBufferSizeBytes()

setS3UploadBufferSizeBytes

void setS3UploadBufferSizeBytes(java.lang.Integer value)

getS3ThreadPoolSize

@Default.Integer(value=50)
int getS3ThreadPoolSize()

setS3ThreadPoolSize

void setS3ThreadPoolSize(int value)