- GcpCredentialFactory - Class in org.apache.beam.sdk.extensions.gcp.auth
-
Construct an oauth credential to be used by the SDK and the SDK workers.
- GcpCredentialFactory() - Constructor for class org.apache.beam.sdk.extensions.gcp.auth.GcpCredentialFactory
-
- GcpOptions - Interface in org.apache.beam.sdk.extensions.gcp.options
-
Options used to configure Google Cloud Platform specific options such as the project
and credentials.
- GcpOptions.DefaultProjectFactory - Class in org.apache.beam.sdk.extensions.gcp.options
-
Attempts to infer the default project based upon the environment this application
is executing within.
- GcpOptions.GcpTempLocationFactory - Class in org.apache.beam.sdk.extensions.gcp.options
-
- GcpOptions.GcpUserCredentialsFactory - Class in org.apache.beam.sdk.extensions.gcp.options
-
Attempts to load the GCP credentials.
- GcpPipelineOptionsRegistrar - Class in org.apache.beam.sdk.extensions.gcp.options
-
A registrar containing the default GCP options.
- GcpPipelineOptionsRegistrar() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GcpPipelineOptionsRegistrar
-
- GcpTempLocationFactory() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpTempLocationFactory
-
- GcpUserCredentialsFactory() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpUserCredentialsFactory
-
- GCS_URI - Static variable in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
Pattern that is used to parse a GCS URL.
- GcsIOChannelFactory - Class in org.apache.beam.sdk.util
-
Implements IOChannelFactory for GCS.
- GcsIOChannelFactoryRegistrar - Class in org.apache.beam.sdk.util
-
- GcsIOChannelFactoryRegistrar() - Constructor for class org.apache.beam.sdk.util.GcsIOChannelFactoryRegistrar
-
- GcsOptions - Interface in org.apache.beam.sdk.extensions.gcp.options
-
Options used to configure Google Cloud Storage.
- GcsOptions.ExecutorServiceFactory - Class in org.apache.beam.sdk.extensions.gcp.options
-
- GcsOptions.PathValidatorFactory - Class in org.apache.beam.sdk.extensions.gcp.options
-
- GcsPath - Class in org.apache.beam.sdk.util.gcsfs
-
Implements the Java NIO
Path API for Google Cloud Storage paths.
- GcsPath(FileSystem, String, String) - Constructor for class org.apache.beam.sdk.util.gcsfs.GcsPath
-
Constructs a GcsPath.
- GcsPathValidator - Class in org.apache.beam.sdk.util
-
- GcsUtil - Class in org.apache.beam.sdk.util
-
Provides operations on GCS.
- GcsUtil.GcsUtilFactory - Class in org.apache.beam.sdk.util
-
- GcsUtil.StorageObjectOrIOException - Class in org.apache.beam.sdk.util
-
A class that holds either a
StorageObject or an
IOException.
- GcsUtilFactory() - Constructor for class org.apache.beam.sdk.util.GcsUtil.GcsUtilFactory
-
- getBucket() - Method in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
Returns the bucket name associated with this GCS path, or an empty string
if this is a relative path component.
- getCredential() - Method in interface org.apache.beam.sdk.extensions.gcp.auth.CredentialFactory
-
- getCredential() - Method in class org.apache.beam.sdk.extensions.gcp.auth.GcpCredentialFactory
-
Returns a default GCP Credentials or null when it fails.
- getCredential() - Method in class org.apache.beam.sdk.extensions.gcp.auth.NoopCredentialFactory
-
- getCredentialFactoryClass() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions
-
The class of the credential factory that should be created and used to create
credentials.
- getExecutorService() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions
-
The ExecutorService instance to use to create threads, can be overridden to specify an
ExecutorService that is compatible with the users environment.
- getFileName() - Method in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
- getFileSystem() - Method in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
- getGcpCredential() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions
-
The credential instance that should be used to authenticate against GCP services.
- getGcpTempLocation() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions
-
A GCS path for storing temporary files in GCP.
- getGcsEndpoint() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions
-
GCS endpoint to use.
- getGcsUploadBufferSizeBytes() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions
-
The buffer size (in bytes) to use when uploading files to GCS.
- getGcsUtil() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions
-
The GcsUtil instance that should be used to communicate with Google Cloud Storage.
- getGlobPrefix(String) - Static method in class org.apache.beam.sdk.util.GcsUtil
-
Returns the prefix portion of the glob that doesn't contain wildcards.
- getGoogleApiTrace() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions
-
This option enables tracing of API calls to Google services used within the Apache
Beam SDK.
- getJsonFactory() - Static method in class org.apache.beam.sdk.util.Transport
-
- getName(int) - Method in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
- getNameCount() - Method in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
- getObject() - Method in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
Returns the object name associated with this GCS path, or an empty string
if no object is specified.
- getObject(GcsPath) - Method in class org.apache.beam.sdk.util.GcsUtil
-
Returns the
StorageObject for the given
GcsPath.
- getObjects(List<GcsPath>) - Method in class org.apache.beam.sdk.util.GcsUtil
-
- getParent() - Method in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
Returns the parent path, or null if this path does not
have a parent.
- getPathValidator() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions
-
The path validator instance that should be used to validate paths.
- getPathValidatorClass() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions
-
The class of the validator that should be created and used to validate paths.
- getPipelineOptions() - Method in class org.apache.beam.sdk.extensions.gcp.options.GcpPipelineOptionsRegistrar
-
- getProject() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions
-
Project id to use when launching jobs.
- getRoot() - Method in class org.apache.beam.sdk.util.gcsfs.GcsPath
-
- getScheme() - Method in class org.apache.beam.sdk.util.GcsIOChannelFactoryRegistrar
-
- getSizeBytes(String) - Method in class org.apache.beam.sdk.util.GcsIOChannelFactory
-
- getTransport() - Static method in class org.apache.beam.sdk.util.Transport
-
- getZone() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions
-
- globToRegexp(String) - Static method in class org.apache.beam.sdk.util.GcsUtil
-
Expands glob expressions to regular expressions.
- GoogleApiDebugOptions - Interface in org.apache.beam.sdk.extensions.gcp.options
-
These options configure debug settings for Google API clients created within the Apache Beam SDK.
- GoogleApiDebugOptions.GoogleApiTracer - Class in org.apache.beam.sdk.extensions.gcp.options
-
A GoogleClientRequestInitializer that adds the trace destination to Google API calls.
- GoogleApiTracer() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer
-