com.google.cloud.dataflow.sdk.options

Interface GcsOptions

All Superinterfaces:

ApplicationNameOptions, GcpOptions, PipelineOptions

All Known Subinterfaces:

BlockingDataflowPipelineOptions, DataflowPipelineOptions, DataflowWorkerHarnessOptions, DirectPipelineOptions, TestDataflowPipelineOptions

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 Dataflow SDK.

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.GcpOptions

GcpOptions.CredentialDirFactory, GcpOptions.GcpUserCredentialsFactory

Method Summary

Methods

Modifier and Type	Method and Description
java.util.concurrent.ExecutorService	getExecutorService()
com.google.cloud.dataflow.sdk.util.GcsUtil	getGcsUtil() Alternative GcsUtil instance.
void	setExecutorService(java.util.concurrent.ExecutorService value)
void	setGcsUtil(com.google.cloud.dataflow.sdk.util.GcsUtil value)

Methods inherited from interface com.google.cloud.dataflow.sdk.options.ApplicationNameOptions

getAppName, setAppName

Methods inherited from interface com.google.cloud.dataflow.sdk.options.GcpOptions

getCredentialDir, getCredentialId, getGCloudPath, getGcpCredential, getProject, getSecretsFile, getServiceAccountKeyfile, getServiceAccountName, setCredentialDir, setCredentialId, setGCloudPath, setGcpCredential, setProject, setSecretsFile, setServiceAccountKeyfile, setServiceAccountName

Methods inherited from interface com.google.cloud.dataflow.sdk.options.PipelineOptions

as, getRunner, setRunner

Method Detail

getGcsUtil

com.google.cloud.dataflow.sdk.util.GcsUtil getGcsUtil()

Alternative GcsUtil instance.

setGcsUtil

void setGcsUtil(com.google.cloud.dataflow.sdk.util.GcsUtil value)

getExecutorService

java.util.concurrent.ExecutorService getExecutorService()

setExecutorService

void setExecutorService(java.util.concurrent.ExecutorService value)