org.apache.beam.sdk.extensions.gcp.options

Interface GcsOptions

All Superinterfaces:

ApplicationNameOptions, GcpOptions, GoogleApiDebugOptions, HasDisplayData, PipelineOptions

public interface GcsOptions
extends ApplicationNameOptions, GcpOptions, PipelineOptions

Options used to configure Google Cloud Storage.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	GcsOptions.ExecutorServiceFactory Returns the default ExecutorService to use within the Apache Beam SDK.
static class	GcsOptions.PathValidatorFactory Creates a PathValidator object using the class specified in getPathValidatorClass().

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

GcpOptions.DefaultProjectFactory, GcpOptions.GcpTempLocationFactory, GcpOptions.GcpUserCredentialsFactory

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

GoogleApiDebugOptions.GoogleApiTracer

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

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

Method Summary

Modifier and Type	Method and Description
ExecutorService	getExecutorService() The ExecutorService instance to use to create threads, can be overridden to specify an ExecutorService that is compatible with the users environment.
String	getGcsEndpoint() GCS endpoint to use.
Integer	getGcsUploadBufferSizeBytes() The buffer size (in bytes) to use when uploading files to GCS.
GcsUtil	getGcsUtil() The GcsUtil instance that should be used to communicate with Google Cloud Storage.
PathValidator	getPathValidator() The path validator instance that should be used to validate paths.
Class<? extends PathValidator>	getPathValidatorClass() The class of the validator that should be created and used to validate paths.
void	setExecutorService(ExecutorService value)
void	setGcsEndpoint(String value)
void	setGcsUploadBufferSizeBytes(Integer bytes)
void	setGcsUtil(GcsUtil value)
void	setPathValidator(PathValidator validator)
void	setPathValidatorClass(Class<? extends PathValidator> validatorClass)

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

getAppName, setAppName

Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

getCredentialFactoryClass, getGcpCredential, getGcpTempLocation, getProject, getZone, setCredentialFactoryClass, setGcpCredential, setGcpTempLocation, setProject, setZone

Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

getGoogleApiTrace, setGoogleApiTrace

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

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

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

populateDisplayData

Method Detail

getGcsUtil

@Default.InstanceFactory(value=GcsUtil.GcsUtilFactory.class)
 @Hidden
GcsUtil getGcsUtil()

The GcsUtil instance that should be used to communicate with Google Cloud Storage.

setGcsUtil

void setGcsUtil(GcsUtil value)

getExecutorService

@Default.InstanceFactory(value=GcsOptions.ExecutorServiceFactory.class)
 @Hidden
ExecutorService getExecutorService()

The ExecutorService instance to use to create threads, can be overridden to specify an ExecutorService that is compatible with the users environment. If unset, the default is to create an ExecutorService with an unbounded number of threads; this is compatible with Google AppEngine.

setExecutorService

void setExecutorService(ExecutorService value)

getGcsEndpoint

@Hidden
String getGcsEndpoint()

GCS endpoint to use. If unspecified, uses the default endpoint.

setGcsEndpoint

void setGcsEndpoint(String value)

getGcsUploadBufferSizeBytes

@Nullable
Integer getGcsUploadBufferSizeBytes()

The buffer size (in bytes) to use when uploading files to GCS. Please see the documentation for AbstractGoogleAsyncWriteChannel.setUploadBufferSize(int) for more information on the restrictions and performance implications of this value.

setGcsUploadBufferSizeBytes

void setGcsUploadBufferSizeBytes(@Nullable
                                 Integer bytes)

getPathValidatorClass

@Default.Class(value=GcsPathValidator.class)
Class<? extends PathValidator> getPathValidatorClass()

The class of the validator that should be created and used to validate paths. If pathValidator has not been set explicitly, an instance of this class will be constructed and used as the path validator.

setPathValidatorClass

void setPathValidatorClass(Class<? extends PathValidator> validatorClass)

getPathValidator

@Default.InstanceFactory(value=GcsOptions.PathValidatorFactory.class)
PathValidator getPathValidator()

The path validator instance that should be used to validate paths. If no path validator has been set explicitly, the default is to use the instance factory that constructs a path validator based upon the currently set pathValidatorClass.

setPathValidator

void setPathValidator(PathValidator validator)