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

Interface GcpOptions

All Superinterfaces:

GoogleApiDebugOptions, HasDisplayData, PipelineOptions

All Known Subinterfaces:

BigQueryOptions, CloudResourceManagerOptions, DataflowPipelineOptions, DataflowWorkerHarnessOptions, GcsOptions, PubsubOptions, TestDataflowPipelineOptions

public interface GcpOptions
extends GoogleApiDebugOptions, PipelineOptions

Options used to configure Google Cloud Platform specific options such as the project and credentials.

These options defer to the application default credentials for authentication. See the Google Auth Library for alternative mechanisms for creating credentials.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	GcpOptions.DefaultProjectFactory Attempts to infer the default project based upon the environment this application is executing within.
static class	GcpOptions.GcpTempLocationFactory Returns PipelineOptions.getTempLocation() as the default GCP temp location.
static class	GcpOptions.GcpUserCredentialsFactory Attempts to load the GCP credentials.

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, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method and Description
java.lang.Class<? extends CredentialFactory>	getCredentialFactoryClass() The class of the credential factory that should be created and used to create credentials.
com.google.auth.Credentials	getGcpCredential() The credential instance that should be used to authenticate against GCP services.
java.lang.String	getGcpTempLocation() A GCS path for storing temporary files in GCP.
java.lang.String	getProject() Project id to use when launching jobs.
java.lang.String	getZone() GCP availability zone for operations.
void	setCredentialFactoryClass(java.lang.Class<? extends CredentialFactory> credentialFactoryClass)
void	setGcpCredential(com.google.auth.Credentials value)
void	setGcpTempLocation(java.lang.String value)
void	setProject(java.lang.String value)
void	setZone(java.lang.String value)

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, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

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

populateDisplayData

Method Detail

getProject

@Default.InstanceFactory(value=GcpOptions.DefaultProjectFactory.class)
java.lang.String getProject()

Project id to use when launching jobs.

setProject

void setProject(java.lang.String value)

getZone

java.lang.String getZone()

GCP availability zone for operations.

Default is set on a per-service basis.

setZone

void setZone(java.lang.String value)

getCredentialFactoryClass

@Default.Class(value=GcpCredentialFactory.class)
java.lang.Class<? extends CredentialFactory> getCredentialFactoryClass()

The class of the credential factory that should be created and used to create credentials. If gcpCredential has not been set explicitly, an instance of this class will be constructed and used as a credential factory.

setCredentialFactoryClass

void setCredentialFactoryClass(java.lang.Class<? extends CredentialFactory> credentialFactoryClass)

getGcpCredential

@Default.InstanceFactory(value=GcpOptions.GcpUserCredentialsFactory.class)
com.google.auth.Credentials getGcpCredential()

The credential instance that should be used to authenticate against GCP services. If no credential has been set explicitly, the default is to use the instance factory that constructs a credential based upon the currently set credentialFactoryClass.

setGcpCredential

void setGcpCredential(com.google.auth.Credentials value)

getGcpTempLocation

@Default.InstanceFactory(value=GcpOptions.GcpTempLocationFactory.class)
 @Nullable
java.lang.String getGcpTempLocation()

A GCS path for storing temporary files in GCP.

Its default to PipelineOptions.getTempLocation().

setGcpTempLocation

void setGcpTempLocation(java.lang.String value)