Package com.google.dataflow.v1beta3

Class Environment.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<Environment.Builder>
com.google.dataflow.v1beta3.Environment.Builder
All Implemented Interfaces:
EnvironmentOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
Environment
public static final class Environment.Builder extends com.google.protobuf.GeneratedMessage.Builder<Environment.Builder> implements EnvironmentOrBuilder
 Describes the environment in which a Dataflow Job runs.
Protobuf type google.dataflow.v1beta3.Environment

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<Environment.Builder>

    • clear

      public Environment.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<Environment.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<Environment.Builder>

    • getDefaultInstanceForType

      public Environment getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

    • build

      public Environment build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public Environment buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public Environment.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<Environment.Builder>

    • mergeFrom

      public Environment.Builder mergeFrom(Environment other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<Environment.Builder>

    • mergeFrom

      public Environment.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<Environment.Builder>
      Throws:
      IOException

    • getTempStoragePrefix

      public String getTempStoragePrefix()
       The prefix of the resources the system should use for temporary
 storage.  The system will append the suffix "/temp-{JOBNAME} to
 this resource prefix, where {JOBNAME} is the value of the
 job_name field.  The resulting bucket and object prefix is used
 as the prefix of the resources used to store temporary data
 needed during the job execution.  NOTE: This will override the
 value in taskrunner_settings.
 The supported resource type is:

 Google Cloud Storage:

 storage.googleapis.com/{bucket}/{object}
 bucket.storage.googleapis.com/{object}
      string temp_storage_prefix = 1;
      Specified by:
      getTempStoragePrefix in interface EnvironmentOrBuilder
      Returns:
      The tempStoragePrefix.

    • getTempStoragePrefixBytes

      public com.google.protobuf.ByteString getTempStoragePrefixBytes()
       The prefix of the resources the system should use for temporary
 storage.  The system will append the suffix "/temp-{JOBNAME} to
 this resource prefix, where {JOBNAME} is the value of the
 job_name field.  The resulting bucket and object prefix is used
 as the prefix of the resources used to store temporary data
 needed during the job execution.  NOTE: This will override the
 value in taskrunner_settings.
 The supported resource type is:

 Google Cloud Storage:

 storage.googleapis.com/{bucket}/{object}
 bucket.storage.googleapis.com/{object}
      string temp_storage_prefix = 1;
      Specified by:
      getTempStoragePrefixBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for tempStoragePrefix.

    • setTempStoragePrefix

      public Environment.Builder setTempStoragePrefix(String value)
       The prefix of the resources the system should use for temporary
 storage.  The system will append the suffix "/temp-{JOBNAME} to
 this resource prefix, where {JOBNAME} is the value of the
 job_name field.  The resulting bucket and object prefix is used
 as the prefix of the resources used to store temporary data
 needed during the job execution.  NOTE: This will override the
 value in taskrunner_settings.
 The supported resource type is:

 Google Cloud Storage:

 storage.googleapis.com/{bucket}/{object}
 bucket.storage.googleapis.com/{object}
      string temp_storage_prefix = 1;
      Parameters:
      value - The tempStoragePrefix to set.
      Returns:
      This builder for chaining.

    • clearTempStoragePrefix

      public Environment.Builder clearTempStoragePrefix()
       The prefix of the resources the system should use for temporary
 storage.  The system will append the suffix "/temp-{JOBNAME} to
 this resource prefix, where {JOBNAME} is the value of the
 job_name field.  The resulting bucket and object prefix is used
 as the prefix of the resources used to store temporary data
 needed during the job execution.  NOTE: This will override the
 value in taskrunner_settings.
 The supported resource type is:

 Google Cloud Storage:

 storage.googleapis.com/{bucket}/{object}
 bucket.storage.googleapis.com/{object}
      string temp_storage_prefix = 1;
      Returns:
      This builder for chaining.

    • setTempStoragePrefixBytes

      public Environment.Builder setTempStoragePrefixBytes(com.google.protobuf.ByteString value)
       The prefix of the resources the system should use for temporary
 storage.  The system will append the suffix "/temp-{JOBNAME} to
 this resource prefix, where {JOBNAME} is the value of the
 job_name field.  The resulting bucket and object prefix is used
 as the prefix of the resources used to store temporary data
 needed during the job execution.  NOTE: This will override the
 value in taskrunner_settings.
 The supported resource type is:

 Google Cloud Storage:

 storage.googleapis.com/{bucket}/{object}
 bucket.storage.googleapis.com/{object}
      string temp_storage_prefix = 1;
      Parameters:
      value - The bytes for tempStoragePrefix to set.
      Returns:
      This builder for chaining.

    • getClusterManagerApiService

      public String getClusterManagerApiService()
       The type of cluster manager API to use.  If unknown or
 unspecified, the service will attempt to choose a reasonable
 default.  This should be in the form of the API service name,
 e.g. "compute.googleapis.com".
      string cluster_manager_api_service = 2;
      Specified by:
      getClusterManagerApiService in interface EnvironmentOrBuilder
      Returns:
      The clusterManagerApiService.

    • getClusterManagerApiServiceBytes

      public com.google.protobuf.ByteString getClusterManagerApiServiceBytes()
       The type of cluster manager API to use.  If unknown or
 unspecified, the service will attempt to choose a reasonable
 default.  This should be in the form of the API service name,
 e.g. "compute.googleapis.com".
      string cluster_manager_api_service = 2;
      Specified by:
      getClusterManagerApiServiceBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for clusterManagerApiService.

    • setClusterManagerApiService

      public Environment.Builder setClusterManagerApiService(String value)
       The type of cluster manager API to use.  If unknown or
 unspecified, the service will attempt to choose a reasonable
 default.  This should be in the form of the API service name,
 e.g. "compute.googleapis.com".
      string cluster_manager_api_service = 2;
      Parameters:
      value - The clusterManagerApiService to set.
      Returns:
      This builder for chaining.

    • clearClusterManagerApiService

      public Environment.Builder clearClusterManagerApiService()
       The type of cluster manager API to use.  If unknown or
 unspecified, the service will attempt to choose a reasonable
 default.  This should be in the form of the API service name,
 e.g. "compute.googleapis.com".
      string cluster_manager_api_service = 2;
      Returns:
      This builder for chaining.

    • setClusterManagerApiServiceBytes

      public Environment.Builder setClusterManagerApiServiceBytes(com.google.protobuf.ByteString value)
       The type of cluster manager API to use.  If unknown or
 unspecified, the service will attempt to choose a reasonable
 default.  This should be in the form of the API service name,
 e.g. "compute.googleapis.com".
      string cluster_manager_api_service = 2;
      Parameters:
      value - The bytes for clusterManagerApiService to set.
      Returns:
      This builder for chaining.

    • getExperimentsList

      public com.google.protobuf.ProtocolStringList getExperimentsList()
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Specified by:
      getExperimentsList in interface EnvironmentOrBuilder
      Returns:
      A list containing the experiments.

    • getExperimentsCount

      public int getExperimentsCount()
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Specified by:
      getExperimentsCount in interface EnvironmentOrBuilder
      Returns:
      The count of experiments.

    • getExperiments

      public String getExperiments(int index)
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Specified by:
      getExperiments in interface EnvironmentOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The experiments at the given index.

    • getExperimentsBytes

      public com.google.protobuf.ByteString getExperimentsBytes(int index)
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Specified by:
      getExperimentsBytes in interface EnvironmentOrBuilder
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the experiments at the given index.

    • setExperiments

      public Environment.Builder setExperiments(int index, String value)
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Parameters:
      index - The index to set the value at.
      value - The experiments to set.
      Returns:
      This builder for chaining.

    • addExperiments

      public Environment.Builder addExperiments(String value)
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Parameters:
      value - The experiments to add.
      Returns:
      This builder for chaining.

    • addAllExperiments

      public Environment.Builder addAllExperiments(Iterable<String> values)
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Parameters:
      values - The experiments to add.
      Returns:
      This builder for chaining.

    • clearExperiments

      public Environment.Builder clearExperiments()
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Returns:
      This builder for chaining.

    • addExperimentsBytes

      public Environment.Builder addExperimentsBytes(com.google.protobuf.ByteString value)
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Parameters:
      value - The bytes of the experiments to add.
      Returns:
      This builder for chaining.

    • getServiceOptionsList

      public com.google.protobuf.ProtocolStringList getServiceOptionsList()
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceOptionsList in interface EnvironmentOrBuilder
      Returns:
      A list containing the serviceOptions.

    • getServiceOptionsCount

      public int getServiceOptionsCount()
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceOptionsCount in interface EnvironmentOrBuilder
      Returns:
      The count of serviceOptions.

    • getServiceOptions

      public String getServiceOptions(int index)
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceOptions in interface EnvironmentOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The serviceOptions at the given index.

    • getServiceOptionsBytes

      public com.google.protobuf.ByteString getServiceOptionsBytes(int index)
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceOptionsBytes in interface EnvironmentOrBuilder
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the serviceOptions at the given index.

    • setServiceOptions

      public Environment.Builder setServiceOptions(int index, String value)
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      index - The index to set the value at.
      value - The serviceOptions to set.
      Returns:
      This builder for chaining.

    • addServiceOptions

      public Environment.Builder addServiceOptions(String value)
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The serviceOptions to add.
      Returns:
      This builder for chaining.

    • addAllServiceOptions

      public Environment.Builder addAllServiceOptions(Iterable<String> values)
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      values - The serviceOptions to add.
      Returns:
      This builder for chaining.

    • clearServiceOptions

      public Environment.Builder clearServiceOptions()
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • addServiceOptionsBytes

      public Environment.Builder addServiceOptionsBytes(com.google.protobuf.ByteString value)
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The bytes of the serviceOptions to add.
      Returns:
      This builder for chaining.

    • getServiceKmsKeyName

      public String getServiceKmsKeyName()
       Optional. If set, contains the Cloud KMS key identifier used to encrypt
 data at rest, AKA a Customer Managed Encryption Key (CMEK).

 Format:
 projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
      string service_kms_key_name = 12 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceKmsKeyName in interface EnvironmentOrBuilder
      Returns:
      The serviceKmsKeyName.

    • getServiceKmsKeyNameBytes

      public com.google.protobuf.ByteString getServiceKmsKeyNameBytes()
       Optional. If set, contains the Cloud KMS key identifier used to encrypt
 data at rest, AKA a Customer Managed Encryption Key (CMEK).

 Format:
 projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
      string service_kms_key_name = 12 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceKmsKeyNameBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for serviceKmsKeyName.

    • setServiceKmsKeyName

      public Environment.Builder setServiceKmsKeyName(String value)
       Optional. If set, contains the Cloud KMS key identifier used to encrypt
 data at rest, AKA a Customer Managed Encryption Key (CMEK).

 Format:
 projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
      string service_kms_key_name = 12 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The serviceKmsKeyName to set.
      Returns:
      This builder for chaining.

    • clearServiceKmsKeyName

      public Environment.Builder clearServiceKmsKeyName()
       Optional. If set, contains the Cloud KMS key identifier used to encrypt
 data at rest, AKA a Customer Managed Encryption Key (CMEK).

 Format:
 projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
      string service_kms_key_name = 12 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • setServiceKmsKeyNameBytes

      public Environment.Builder setServiceKmsKeyNameBytes(com.google.protobuf.ByteString value)
       Optional. If set, contains the Cloud KMS key identifier used to encrypt
 data at rest, AKA a Customer Managed Encryption Key (CMEK).

 Format:
 projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
      string service_kms_key_name = 12 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The bytes for serviceKmsKeyName to set.
      Returns:
      This builder for chaining.

    • getWorkerPoolsList

      public List<WorkerPool> getWorkerPoolsList()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPoolsList in interface EnvironmentOrBuilder

    • getWorkerPoolsCount

      public int getWorkerPoolsCount()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPoolsCount in interface EnvironmentOrBuilder

    • getWorkerPools

      public WorkerPool getWorkerPools(int index)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPools in interface EnvironmentOrBuilder

    • setWorkerPools

      public Environment.Builder setWorkerPools(int index, WorkerPool value)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • setWorkerPools

      public Environment.Builder setWorkerPools(int index, WorkerPool.Builder builderForValue)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • addWorkerPools

      public Environment.Builder addWorkerPools(WorkerPool value)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • addWorkerPools

      public Environment.Builder addWorkerPools(int index, WorkerPool value)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • addWorkerPools

      public Environment.Builder addWorkerPools(WorkerPool.Builder builderForValue)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • addWorkerPools

      public Environment.Builder addWorkerPools(int index, WorkerPool.Builder builderForValue)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • addAllWorkerPools

      public Environment.Builder addAllWorkerPools(Iterable<? extends WorkerPool> values)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • clearWorkerPools

      public Environment.Builder clearWorkerPools()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • removeWorkerPools

      public Environment.Builder removeWorkerPools(int index)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • getWorkerPoolsBuilder

      public WorkerPool.Builder getWorkerPoolsBuilder(int index)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • getWorkerPoolsOrBuilder

      public WorkerPoolOrBuilder getWorkerPoolsOrBuilder(int index)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPoolsOrBuilder in interface EnvironmentOrBuilder

    • getWorkerPoolsOrBuilderList

      public List<? extends WorkerPoolOrBuilder> getWorkerPoolsOrBuilderList()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPoolsOrBuilderList in interface EnvironmentOrBuilder

    • addWorkerPoolsBuilder

      public WorkerPool.Builder addWorkerPoolsBuilder()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • addWorkerPoolsBuilder

      public WorkerPool.Builder addWorkerPoolsBuilder(int index)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • getWorkerPoolsBuilderList

      public List<WorkerPool.Builder> getWorkerPoolsBuilderList()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;

    • hasUserAgent

      public boolean hasUserAgent()
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      hasUserAgent in interface EnvironmentOrBuilder
      Returns:
      Whether the userAgent field is set.

    • getUserAgent

      public com.google.protobuf.Struct getUserAgent()
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getUserAgent in interface EnvironmentOrBuilder
      Returns:
      The userAgent.

    • setUserAgent

      public Environment.Builder setUserAgent(com.google.protobuf.Struct value)
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];

    • setUserAgent

      public Environment.Builder setUserAgent(com.google.protobuf.Struct.Builder builderForValue)
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];

    • mergeUserAgent

      public Environment.Builder mergeUserAgent(com.google.protobuf.Struct value)
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];

    • clearUserAgent

      public Environment.Builder clearUserAgent()
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];

    • getUserAgentBuilder

      public com.google.protobuf.Struct.Builder getUserAgentBuilder()
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];

    • getUserAgentOrBuilder

      public com.google.protobuf.StructOrBuilder getUserAgentOrBuilder()
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getUserAgentOrBuilder in interface EnvironmentOrBuilder

    • hasVersion

      public boolean hasVersion()
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;
      Specified by:
      hasVersion in interface EnvironmentOrBuilder
      Returns:
      Whether the version field is set.

    • getVersion

      public com.google.protobuf.Struct getVersion()
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;
      Specified by:
      getVersion in interface EnvironmentOrBuilder
      Returns:
      The version.

    • setVersion

      public Environment.Builder setVersion(com.google.protobuf.Struct value)
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;

    • setVersion

      public Environment.Builder setVersion(com.google.protobuf.Struct.Builder builderForValue)
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;

    • mergeVersion

      public Environment.Builder mergeVersion(com.google.protobuf.Struct value)
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;

    • clearVersion

      public Environment.Builder clearVersion()
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;

    • getVersionBuilder

      public com.google.protobuf.Struct.Builder getVersionBuilder()
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;

    • getVersionOrBuilder

      public com.google.protobuf.StructOrBuilder getVersionOrBuilder()
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;
      Specified by:
      getVersionOrBuilder in interface EnvironmentOrBuilder

    • getDataset

      public String getDataset()
       Optional. The dataset for the current project where various workflow
 related tables are stored.

 The supported resource type is:

 Google BigQuery:
 bigquery.googleapis.com/{dataset}
      string dataset = 7 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDataset in interface EnvironmentOrBuilder
      Returns:
      The dataset.

    • getDatasetBytes

      public com.google.protobuf.ByteString getDatasetBytes()
       Optional. The dataset for the current project where various workflow
 related tables are stored.

 The supported resource type is:

 Google BigQuery:
 bigquery.googleapis.com/{dataset}
      string dataset = 7 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDatasetBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for dataset.

    • setDataset

      public Environment.Builder setDataset(String value)
       Optional. The dataset for the current project where various workflow
 related tables are stored.

 The supported resource type is:

 Google BigQuery:
 bigquery.googleapis.com/{dataset}
      string dataset = 7 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The dataset to set.
      Returns:
      This builder for chaining.

    • clearDataset

      public Environment.Builder clearDataset()
       Optional. The dataset for the current project where various workflow
 related tables are stored.

 The supported resource type is:

 Google BigQuery:
 bigquery.googleapis.com/{dataset}
      string dataset = 7 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • setDatasetBytes

      public Environment.Builder setDatasetBytes(com.google.protobuf.ByteString value)
       Optional. The dataset for the current project where various workflow
 related tables are stored.

 The supported resource type is:

 Google BigQuery:
 bigquery.googleapis.com/{dataset}
      string dataset = 7 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The bytes for dataset to set.
      Returns:
      This builder for chaining.

    • hasSdkPipelineOptions

      public boolean hasSdkPipelineOptions()
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;
      Specified by:
      hasSdkPipelineOptions in interface EnvironmentOrBuilder
      Returns:
      Whether the sdkPipelineOptions field is set.

    • getSdkPipelineOptions

      public com.google.protobuf.Struct getSdkPipelineOptions()
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;
      Specified by:
      getSdkPipelineOptions in interface EnvironmentOrBuilder
      Returns:
      The sdkPipelineOptions.

    • setSdkPipelineOptions

      public Environment.Builder setSdkPipelineOptions(com.google.protobuf.Struct value)
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;

    • setSdkPipelineOptions

      public Environment.Builder setSdkPipelineOptions(com.google.protobuf.Struct.Builder builderForValue)
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;

    • mergeSdkPipelineOptions

      public Environment.Builder mergeSdkPipelineOptions(com.google.protobuf.Struct value)
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;

    • clearSdkPipelineOptions

      public Environment.Builder clearSdkPipelineOptions()
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;

    • getSdkPipelineOptionsBuilder

      public com.google.protobuf.Struct.Builder getSdkPipelineOptionsBuilder()
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;

    • getSdkPipelineOptionsOrBuilder

      public com.google.protobuf.StructOrBuilder getSdkPipelineOptionsOrBuilder()
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;
      Specified by:
      getSdkPipelineOptionsOrBuilder in interface EnvironmentOrBuilder

    • hasInternalExperiments

      public boolean hasInternalExperiments()
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;
      Specified by:
      hasInternalExperiments in interface EnvironmentOrBuilder
      Returns:
      Whether the internalExperiments field is set.

    • getInternalExperiments

      public com.google.protobuf.Any getInternalExperiments()
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;
      Specified by:
      getInternalExperiments in interface EnvironmentOrBuilder
      Returns:
      The internalExperiments.

    • setInternalExperiments

      public Environment.Builder setInternalExperiments(com.google.protobuf.Any value)
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;

    • setInternalExperiments

      public Environment.Builder setInternalExperiments(com.google.protobuf.Any.Builder builderForValue)
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;

    • mergeInternalExperiments

      public Environment.Builder mergeInternalExperiments(com.google.protobuf.Any value)
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;

    • clearInternalExperiments

      public Environment.Builder clearInternalExperiments()
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;

    • getInternalExperimentsBuilder

      public com.google.protobuf.Any.Builder getInternalExperimentsBuilder()
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;

    • getInternalExperimentsOrBuilder

      public com.google.protobuf.AnyOrBuilder getInternalExperimentsOrBuilder()
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;
      Specified by:
      getInternalExperimentsOrBuilder in interface EnvironmentOrBuilder

    • getServiceAccountEmail

      public String getServiceAccountEmail()
       Optional. Identity to run virtual machines as. Defaults to the default
 account.
      string service_account_email = 10 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceAccountEmail in interface EnvironmentOrBuilder
      Returns:
      The serviceAccountEmail.

    • getServiceAccountEmailBytes

      public com.google.protobuf.ByteString getServiceAccountEmailBytes()
       Optional. Identity to run virtual machines as. Defaults to the default
 account.
      string service_account_email = 10 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceAccountEmailBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for serviceAccountEmail.

    • setServiceAccountEmail

      public Environment.Builder setServiceAccountEmail(String value)
       Optional. Identity to run virtual machines as. Defaults to the default
 account.
      string service_account_email = 10 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The serviceAccountEmail to set.
      Returns:
      This builder for chaining.

    • clearServiceAccountEmail

      public Environment.Builder clearServiceAccountEmail()
       Optional. Identity to run virtual machines as. Defaults to the default
 account.
      string service_account_email = 10 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • setServiceAccountEmailBytes

      public Environment.Builder setServiceAccountEmailBytes(com.google.protobuf.ByteString value)
       Optional. Identity to run virtual machines as. Defaults to the default
 account.
      string service_account_email = 10 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The bytes for serviceAccountEmail to set.
      Returns:
      This builder for chaining.

    • getFlexResourceSchedulingGoalValue

      public int getFlexResourceSchedulingGoalValue()
       Optional. Which Flexible Resource Scheduling mode to run in.
      .google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getFlexResourceSchedulingGoalValue in interface EnvironmentOrBuilder
      Returns:
      The enum numeric value on the wire for flexResourceSchedulingGoal.

    • setFlexResourceSchedulingGoalValue

      public Environment.Builder setFlexResourceSchedulingGoalValue(int value)
       Optional. Which Flexible Resource Scheduling mode to run in.
      .google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The enum numeric value on the wire for flexResourceSchedulingGoal to set.
      Returns:
      This builder for chaining.

    • getFlexResourceSchedulingGoal

      public FlexResourceSchedulingGoal getFlexResourceSchedulingGoal()
       Optional. Which Flexible Resource Scheduling mode to run in.
      .google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getFlexResourceSchedulingGoal in interface EnvironmentOrBuilder
      Returns:
      The flexResourceSchedulingGoal.

    • setFlexResourceSchedulingGoal

      public Environment.Builder setFlexResourceSchedulingGoal(FlexResourceSchedulingGoal value)
       Optional. Which Flexible Resource Scheduling mode to run in.
      .google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The flexResourceSchedulingGoal to set.
      Returns:
      This builder for chaining.

    • clearFlexResourceSchedulingGoal

      public Environment.Builder clearFlexResourceSchedulingGoal()
       Optional. Which Flexible Resource Scheduling mode to run in.
      .google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • getWorkerRegion

      public String getWorkerRegion()
       Optional. The Compute Engine region
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1". Mutually exclusive
 with worker_zone. If neither worker_region nor worker_zone is specified,
 default to the control plane's region.
      string worker_region = 13 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getWorkerRegion in interface EnvironmentOrBuilder
      Returns:
      The workerRegion.

    • getWorkerRegionBytes

      public com.google.protobuf.ByteString getWorkerRegionBytes()
       Optional. The Compute Engine region
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1". Mutually exclusive
 with worker_zone. If neither worker_region nor worker_zone is specified,
 default to the control plane's region.
      string worker_region = 13 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getWorkerRegionBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for workerRegion.

    • setWorkerRegion

      public Environment.Builder setWorkerRegion(String value)
       Optional. The Compute Engine region
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1". Mutually exclusive
 with worker_zone. If neither worker_region nor worker_zone is specified,
 default to the control plane's region.
      string worker_region = 13 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The workerRegion to set.
      Returns:
      This builder for chaining.

    • clearWorkerRegion

      public Environment.Builder clearWorkerRegion()
       Optional. The Compute Engine region
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1". Mutually exclusive
 with worker_zone. If neither worker_region nor worker_zone is specified,
 default to the control plane's region.
      string worker_region = 13 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • setWorkerRegionBytes

      public Environment.Builder setWorkerRegionBytes(com.google.protobuf.ByteString value)
       Optional. The Compute Engine region
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1". Mutually exclusive
 with worker_zone. If neither worker_region nor worker_zone is specified,
 default to the control plane's region.
      string worker_region = 13 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The bytes for workerRegion to set.
      Returns:
      This builder for chaining.

    • getWorkerZone

      public String getWorkerZone()
       Optional. The Compute Engine zone
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1-a". Mutually exclusive
 with worker_region. If neither worker_region nor worker_zone is specified,
 a zone in the control plane's region is chosen based on available capacity.
      string worker_zone = 14 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getWorkerZone in interface EnvironmentOrBuilder
      Returns:
      The workerZone.

    • getWorkerZoneBytes

      public com.google.protobuf.ByteString getWorkerZoneBytes()
       Optional. The Compute Engine zone
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1-a". Mutually exclusive
 with worker_region. If neither worker_region nor worker_zone is specified,
 a zone in the control plane's region is chosen based on available capacity.
      string worker_zone = 14 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getWorkerZoneBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for workerZone.

    • setWorkerZone

      public Environment.Builder setWorkerZone(String value)
       Optional. The Compute Engine zone
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1-a". Mutually exclusive
 with worker_region. If neither worker_region nor worker_zone is specified,
 a zone in the control plane's region is chosen based on available capacity.
      string worker_zone = 14 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The workerZone to set.
      Returns:
      This builder for chaining.

    • clearWorkerZone

      public Environment.Builder clearWorkerZone()
       Optional. The Compute Engine zone
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1-a". Mutually exclusive
 with worker_region. If neither worker_region nor worker_zone is specified,
 a zone in the control plane's region is chosen based on available capacity.
      string worker_zone = 14 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • setWorkerZoneBytes

      public Environment.Builder setWorkerZoneBytes(com.google.protobuf.ByteString value)
       Optional. The Compute Engine zone
 (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
 which worker processing should occur, e.g. "us-west1-a". Mutually exclusive
 with worker_region. If neither worker_region nor worker_zone is specified,
 a zone in the control plane's region is chosen based on available capacity.
      string worker_zone = 14 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The bytes for workerZone to set.
      Returns:
      This builder for chaining.

    • getShuffleModeValue

      public int getShuffleModeValue()
       Output only. The shuffle mode used for the job.
      .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getShuffleModeValue in interface EnvironmentOrBuilder
      Returns:
      The enum numeric value on the wire for shuffleMode.

    • setShuffleModeValue

      public Environment.Builder setShuffleModeValue(int value)
       Output only. The shuffle mode used for the job.
      .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Parameters:
      value - The enum numeric value on the wire for shuffleMode to set.
      Returns:
      This builder for chaining.

    • getShuffleMode

      public ShuffleMode getShuffleMode()
       Output only. The shuffle mode used for the job.
      .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getShuffleMode in interface EnvironmentOrBuilder
      Returns:
      The shuffleMode.

    • setShuffleMode

      public Environment.Builder setShuffleMode(ShuffleMode value)
       Output only. The shuffle mode used for the job.
      .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Parameters:
      value - The shuffleMode to set.
      Returns:
      This builder for chaining.

    • clearShuffleMode

      public Environment.Builder clearShuffleMode()
       Output only. The shuffle mode used for the job.
      .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Returns:
      This builder for chaining.

    • hasDebugOptions

      public boolean hasDebugOptions()
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      hasDebugOptions in interface EnvironmentOrBuilder
      Returns:
      Whether the debugOptions field is set.

    • getDebugOptions

      public DebugOptions getDebugOptions()
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDebugOptions in interface EnvironmentOrBuilder
      Returns:
      The debugOptions.

    • setDebugOptions

      public Environment.Builder setDebugOptions(DebugOptions value)
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];

    • setDebugOptions

      public Environment.Builder setDebugOptions(DebugOptions.Builder builderForValue)
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];

    • mergeDebugOptions

      public Environment.Builder mergeDebugOptions(DebugOptions value)
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];

    • clearDebugOptions

      public Environment.Builder clearDebugOptions()
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];

    • getDebugOptionsBuilder

      public DebugOptions.Builder getDebugOptionsBuilder()
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];

    • getDebugOptionsOrBuilder

      public DebugOptionsOrBuilder getDebugOptionsOrBuilder()
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDebugOptionsOrBuilder in interface EnvironmentOrBuilder

    • getUseStreamingEngineResourceBasedBilling

      public boolean getUseStreamingEngineResourceBasedBilling()
       Output only. Whether the job uses the Streaming Engine resource-based
 billing model.
      bool use_streaming_engine_resource_based_billing = 18 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getUseStreamingEngineResourceBasedBilling in interface EnvironmentOrBuilder
      Returns:
      The useStreamingEngineResourceBasedBilling.

    • setUseStreamingEngineResourceBasedBilling

      public Environment.Builder setUseStreamingEngineResourceBasedBilling(boolean value)
       Output only. Whether the job uses the Streaming Engine resource-based
 billing model.
      bool use_streaming_engine_resource_based_billing = 18 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Parameters:
      value - The useStreamingEngineResourceBasedBilling to set.
      Returns:
      This builder for chaining.

    • clearUseStreamingEngineResourceBasedBilling

      public Environment.Builder clearUseStreamingEngineResourceBasedBilling()
       Output only. Whether the job uses the Streaming Engine resource-based
 billing model.
      bool use_streaming_engine_resource_based_billing = 18 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Returns:
      This builder for chaining.

    • getStreamingModeValue

      public int getStreamingModeValue()
       Optional. Specifies the Streaming Engine message processing guarantees.
 Reduces cost and latency but might result in duplicate messages committed
 to storage. Designed to run simple mapping streaming ETL jobs at the lowest
 cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use
 case. For more information, see
 [Set the pipeline streaming
 mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
      .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getStreamingModeValue in interface EnvironmentOrBuilder
      Returns:
      The enum numeric value on the wire for streamingMode.

    • setStreamingModeValue

      public Environment.Builder setStreamingModeValue(int value)
       Optional. Specifies the Streaming Engine message processing guarantees.
 Reduces cost and latency but might result in duplicate messages committed
 to storage. Designed to run simple mapping streaming ETL jobs at the lowest
 cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use
 case. For more information, see
 [Set the pipeline streaming
 mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
      .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The enum numeric value on the wire for streamingMode to set.
      Returns:
      This builder for chaining.

    • getStreamingMode

      public StreamingMode getStreamingMode()
       Optional. Specifies the Streaming Engine message processing guarantees.
 Reduces cost and latency but might result in duplicate messages committed
 to storage. Designed to run simple mapping streaming ETL jobs at the lowest
 cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use
 case. For more information, see
 [Set the pipeline streaming
 mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
      .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getStreamingMode in interface EnvironmentOrBuilder
      Returns:
      The streamingMode.

    • setStreamingMode

      public Environment.Builder setStreamingMode(StreamingMode value)
       Optional. Specifies the Streaming Engine message processing guarantees.
 Reduces cost and latency but might result in duplicate messages committed
 to storage. Designed to run simple mapping streaming ETL jobs at the lowest
 cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use
 case. For more information, see
 [Set the pipeline streaming
 mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
      .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The streamingMode to set.
      Returns:
      This builder for chaining.

    • clearStreamingMode

      public Environment.Builder clearStreamingMode()
       Optional. Specifies the Streaming Engine message processing guarantees.
 Reduces cost and latency but might result in duplicate messages committed
 to storage. Designed to run simple mapping streaming ETL jobs at the lowest
 cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use
 case. For more information, see
 [Set the pipeline streaming
 mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
      .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • getUsePublicIps

      public boolean getUsePublicIps()
       Optional. True when any worker pool that uses public IPs is present.
      bool use_public_ips = 20 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getUsePublicIps in interface EnvironmentOrBuilder
      Returns:
      The usePublicIps.

    • setUsePublicIps

      public Environment.Builder setUsePublicIps(boolean value)
       Optional. True when any worker pool that uses public IPs is present.
      bool use_public_ips = 20 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The usePublicIps to set.
      Returns:
      This builder for chaining.

    • clearUsePublicIps

      public Environment.Builder clearUsePublicIps()
       Optional. True when any worker pool that uses public IPs is present.
      bool use_public_ips = 20 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.