Package com.google.dataflow.v1beta3

Class FlexTemplateRuntimeEnvironment.Builder

    • Method Detail

      • getDescriptor

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

      • internalGetMapField

        protected com.google.protobuf.MapField internalGetMapField​(int number)
        Overrides:
        internalGetMapField in class com.google.protobuf.GeneratedMessageV3.Builder<FlexTemplateRuntimeEnvironment.Builder>

      • internalGetMutableMapField

        protected com.google.protobuf.MapField internalGetMutableMapField​(int number)
        Overrides:
        internalGetMutableMapField in class com.google.protobuf.GeneratedMessageV3.Builder<FlexTemplateRuntimeEnvironment.Builder>

      • internalGetFieldAccessorTable

        protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
        Specified by:
        internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3.Builder<FlexTemplateRuntimeEnvironment.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.GeneratedMessageV3.Builder<FlexTemplateRuntimeEnvironment.Builder>

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • isInitialized

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

      • setNumWorkers

        public FlexTemplateRuntimeEnvironment.Builder setNumWorkers​(int value)
         The initial number of Google Compute Engine instances for the job.
        int32 num_workers = 1;
        Parameters:
        value - The numWorkers to set.
        Returns:
        This builder for chaining.

      • clearNumWorkers

        public FlexTemplateRuntimeEnvironment.Builder clearNumWorkers()
         The initial number of Google Compute Engine instances for the job.
        int32 num_workers = 1;
        Returns:
        This builder for chaining.

      • getMaxWorkers

        public int getMaxWorkers()
         The maximum number of Google Compute Engine instances to be made
 available to your pipeline during execution, from 1 to 1000.
        int32 max_workers = 2;
        Specified by:
        getMaxWorkers in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The maxWorkers.

      • setMaxWorkers

        public FlexTemplateRuntimeEnvironment.Builder setMaxWorkers​(int value)
         The maximum number of Google Compute Engine instances to be made
 available to your pipeline during execution, from 1 to 1000.
        int32 max_workers = 2;
        Parameters:
        value - The maxWorkers to set.
        Returns:
        This builder for chaining.

      • clearMaxWorkers

        public FlexTemplateRuntimeEnvironment.Builder clearMaxWorkers()
         The maximum number of Google Compute Engine instances to be made
 available to your pipeline during execution, from 1 to 1000.
        int32 max_workers = 2;
        Returns:
        This builder for chaining.

      • getZone

        public String getZone()
         The Compute Engine [availability
 zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones)
 for launching worker instances to run your pipeline.
 In the future, worker_zone will take precedence.
        string zone = 3;
        Specified by:
        getZone in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The zone.

      • getZoneBytes

        public com.google.protobuf.ByteString getZoneBytes()
         The Compute Engine [availability
 zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones)
 for launching worker instances to run your pipeline.
 In the future, worker_zone will take precedence.
        string zone = 3;
        Specified by:
        getZoneBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for zone.

      • setZone

        public FlexTemplateRuntimeEnvironment.Builder setZone​(String value)
         The Compute Engine [availability
 zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones)
 for launching worker instances to run your pipeline.
 In the future, worker_zone will take precedence.
        string zone = 3;
        Parameters:
        value - The zone to set.
        Returns:
        This builder for chaining.

      • clearZone

        public FlexTemplateRuntimeEnvironment.Builder clearZone()
         The Compute Engine [availability
 zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones)
 for launching worker instances to run your pipeline.
 In the future, worker_zone will take precedence.
        string zone = 3;
        Returns:
        This builder for chaining.

      • setZoneBytes

        public FlexTemplateRuntimeEnvironment.Builder setZoneBytes​(com.google.protobuf.ByteString value)
         The Compute Engine [availability
 zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones)
 for launching worker instances to run your pipeline.
 In the future, worker_zone will take precedence.
        string zone = 3;
        Parameters:
        value - The bytes for zone to set.
        Returns:
        This builder for chaining.

      • getServiceAccountEmailBytes

        public com.google.protobuf.ByteString getServiceAccountEmailBytes()
         The email address of the service account to run the job as.
        string service_account_email = 4;
        Specified by:
        getServiceAccountEmailBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for serviceAccountEmail.

      • setServiceAccountEmail

        public FlexTemplateRuntimeEnvironment.Builder setServiceAccountEmail​(String value)
         The email address of the service account to run the job as.
        string service_account_email = 4;
        Parameters:
        value - The serviceAccountEmail to set.
        Returns:
        This builder for chaining.

      • clearServiceAccountEmail

        public FlexTemplateRuntimeEnvironment.Builder clearServiceAccountEmail()
         The email address of the service account to run the job as.
        string service_account_email = 4;
        Returns:
        This builder for chaining.

      • setServiceAccountEmailBytes

        public FlexTemplateRuntimeEnvironment.Builder setServiceAccountEmailBytes​(com.google.protobuf.ByteString value)
         The email address of the service account to run the job as.
        string service_account_email = 4;
        Parameters:
        value - The bytes for serviceAccountEmail to set.
        Returns:
        This builder for chaining.

      • getTempLocationBytes

        public com.google.protobuf.ByteString getTempLocationBytes()
         The Cloud Storage path to use for temporary files.
 Must be a valid Cloud Storage URL, beginning with `gs://`.
        string temp_location = 5;
        Specified by:
        getTempLocationBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for tempLocation.

      • setTempLocation

        public FlexTemplateRuntimeEnvironment.Builder setTempLocation​(String value)
         The Cloud Storage path to use for temporary files.
 Must be a valid Cloud Storage URL, beginning with `gs://`.
        string temp_location = 5;
        Parameters:
        value - The tempLocation to set.
        Returns:
        This builder for chaining.

      • clearTempLocation

        public FlexTemplateRuntimeEnvironment.Builder clearTempLocation()
         The Cloud Storage path to use for temporary files.
 Must be a valid Cloud Storage URL, beginning with `gs://`.
        string temp_location = 5;
        Returns:
        This builder for chaining.

      • setTempLocationBytes

        public FlexTemplateRuntimeEnvironment.Builder setTempLocationBytes​(com.google.protobuf.ByteString value)
         The Cloud Storage path to use for temporary files.
 Must be a valid Cloud Storage URL, beginning with `gs://`.
        string temp_location = 5;
        Parameters:
        value - The bytes for tempLocation to set.
        Returns:
        This builder for chaining.

      • getMachineTypeBytes

        public com.google.protobuf.ByteString getMachineTypeBytes()
         The machine type to use for the job. Defaults to the value from the
 template if not specified.
        string machine_type = 6;
        Specified by:
        getMachineTypeBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for machineType.

      • setMachineType

        public FlexTemplateRuntimeEnvironment.Builder setMachineType​(String value)
         The machine type to use for the job. Defaults to the value from the
 template if not specified.
        string machine_type = 6;
        Parameters:
        value - The machineType to set.
        Returns:
        This builder for chaining.

      • clearMachineType

        public FlexTemplateRuntimeEnvironment.Builder clearMachineType()
         The machine type to use for the job. Defaults to the value from the
 template if not specified.
        string machine_type = 6;
        Returns:
        This builder for chaining.

      • setMachineTypeBytes

        public FlexTemplateRuntimeEnvironment.Builder setMachineTypeBytes​(com.google.protobuf.ByteString value)
         The machine type to use for the job. Defaults to the value from the
 template if not specified.
        string machine_type = 6;
        Parameters:
        value - The bytes for machineType to set.
        Returns:
        This builder for chaining.

      • getAdditionalExperimentsList

        public com.google.protobuf.ProtocolStringList getAdditionalExperimentsList()
         Additional experiment flags for the job.
        repeated string additional_experiments = 7;
        Specified by:
        getAdditionalExperimentsList in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        A list containing the additionalExperiments.

      • getAdditionalExperiments

        public String getAdditionalExperiments​(int index)
         Additional experiment flags for the job.
        repeated string additional_experiments = 7;
        Specified by:
        getAdditionalExperiments in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Parameters:
        index - The index of the element to return.
        Returns:
        The additionalExperiments at the given index.

      • getAdditionalExperimentsBytes

        public com.google.protobuf.ByteString getAdditionalExperimentsBytes​(int index)
         Additional experiment flags for the job.
        repeated string additional_experiments = 7;
        Specified by:
        getAdditionalExperimentsBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Parameters:
        index - The index of the value to return.
        Returns:
        The bytes of the additionalExperiments at the given index.

      • setAdditionalExperiments

        public FlexTemplateRuntimeEnvironment.Builder setAdditionalExperiments​(int index,
                                                                       String value)
         Additional experiment flags for the job.
        repeated string additional_experiments = 7;
        Parameters:
        index - The index to set the value at.
        value - The additionalExperiments to set.
        Returns:
        This builder for chaining.

      • addAdditionalExperiments

        public FlexTemplateRuntimeEnvironment.Builder addAdditionalExperiments​(String value)
         Additional experiment flags for the job.
        repeated string additional_experiments = 7;
        Parameters:
        value - The additionalExperiments to add.
        Returns:
        This builder for chaining.

      • addAllAdditionalExperiments

        public FlexTemplateRuntimeEnvironment.Builder addAllAdditionalExperiments​(Iterable<String> values)
         Additional experiment flags for the job.
        repeated string additional_experiments = 7;
        Parameters:
        values - The additionalExperiments to add.
        Returns:
        This builder for chaining.

      • clearAdditionalExperiments

        public FlexTemplateRuntimeEnvironment.Builder clearAdditionalExperiments()
         Additional experiment flags for the job.
        repeated string additional_experiments = 7;
        Returns:
        This builder for chaining.

      • addAdditionalExperimentsBytes

        public FlexTemplateRuntimeEnvironment.Builder addAdditionalExperimentsBytes​(com.google.protobuf.ByteString value)
         Additional experiment flags for the job.
        repeated string additional_experiments = 7;
        Parameters:
        value - The bytes of the additionalExperiments to add.
        Returns:
        This builder for chaining.

      • getNetworkBytes

        public com.google.protobuf.ByteString getNetworkBytes()
         Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
        string network = 8;
        Specified by:
        getNetworkBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for network.

      • setNetwork

        public FlexTemplateRuntimeEnvironment.Builder setNetwork​(String value)
         Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
        string network = 8;
        Parameters:
        value - The network to set.
        Returns:
        This builder for chaining.

      • clearNetwork

        public FlexTemplateRuntimeEnvironment.Builder clearNetwork()
         Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
        string network = 8;
        Returns:
        This builder for chaining.

      • setNetworkBytes

        public FlexTemplateRuntimeEnvironment.Builder setNetworkBytes​(com.google.protobuf.ByteString value)
         Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
        string network = 8;
        Parameters:
        value - The bytes for network to set.
        Returns:
        This builder for chaining.

      • getSubnetwork

        public String getSubnetwork()
         Subnetwork to which VMs will be assigned, if desired. You can specify a
 subnetwork using either a complete URL or an abbreviated path. Expected to
 be of the form
 "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK"
 or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in
 a Shared VPC network, you must use the complete URL.
        string subnetwork = 9;
        Specified by:
        getSubnetwork in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The subnetwork.

      • getSubnetworkBytes

        public com.google.protobuf.ByteString getSubnetworkBytes()
         Subnetwork to which VMs will be assigned, if desired. You can specify a
 subnetwork using either a complete URL or an abbreviated path. Expected to
 be of the form
 "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK"
 or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in
 a Shared VPC network, you must use the complete URL.
        string subnetwork = 9;
        Specified by:
        getSubnetworkBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for subnetwork.

      • setSubnetwork

        public FlexTemplateRuntimeEnvironment.Builder setSubnetwork​(String value)
         Subnetwork to which VMs will be assigned, if desired. You can specify a
 subnetwork using either a complete URL or an abbreviated path. Expected to
 be of the form
 "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK"
 or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in
 a Shared VPC network, you must use the complete URL.
        string subnetwork = 9;
        Parameters:
        value - The subnetwork to set.
        Returns:
        This builder for chaining.

      • clearSubnetwork

        public FlexTemplateRuntimeEnvironment.Builder clearSubnetwork()
         Subnetwork to which VMs will be assigned, if desired. You can specify a
 subnetwork using either a complete URL or an abbreviated path. Expected to
 be of the form
 "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK"
 or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in
 a Shared VPC network, you must use the complete URL.
        string subnetwork = 9;
        Returns:
        This builder for chaining.

      • setSubnetworkBytes

        public FlexTemplateRuntimeEnvironment.Builder setSubnetworkBytes​(com.google.protobuf.ByteString value)
         Subnetwork to which VMs will be assigned, if desired. You can specify a
 subnetwork using either a complete URL or an abbreviated path. Expected to
 be of the form
 "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK"
 or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in
 a Shared VPC network, you must use the complete URL.
        string subnetwork = 9;
        Parameters:
        value - The bytes for subnetwork to set.
        Returns:
        This builder for chaining.

      • getAdditionalUserLabelsCount

        public int getAdditionalUserLabelsCount()
        Description copied from interface: FlexTemplateRuntimeEnvironmentOrBuilder
         Additional user labels to be specified for the job.
 Keys and values must follow the restrictions specified in the [labeling
 restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
 page.
 An object containing a list of "key": value pairs.
 Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
        map<string, string> additional_user_labels = 10;
        Specified by:
        getAdditionalUserLabelsCount in interface FlexTemplateRuntimeEnvironmentOrBuilder

      • containsAdditionalUserLabels

        public boolean containsAdditionalUserLabels​(String key)
         Additional user labels to be specified for the job.
 Keys and values must follow the restrictions specified in the [labeling
 restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
 page.
 An object containing a list of "key": value pairs.
 Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
        map<string, string> additional_user_labels = 10;
        Specified by:
        containsAdditionalUserLabels in interface FlexTemplateRuntimeEnvironmentOrBuilder

      • getAdditionalUserLabelsMap

        public Map<String,​String> getAdditionalUserLabelsMap()
         Additional user labels to be specified for the job.
 Keys and values must follow the restrictions specified in the [labeling
 restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
 page.
 An object containing a list of "key": value pairs.
 Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
        map<string, string> additional_user_labels = 10;
        Specified by:
        getAdditionalUserLabelsMap in interface FlexTemplateRuntimeEnvironmentOrBuilder

      • getAdditionalUserLabelsOrDefault

        public String getAdditionalUserLabelsOrDefault​(String key,
                                               String defaultValue)
         Additional user labels to be specified for the job.
 Keys and values must follow the restrictions specified in the [labeling
 restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
 page.
 An object containing a list of "key": value pairs.
 Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
        map<string, string> additional_user_labels = 10;
        Specified by:
        getAdditionalUserLabelsOrDefault in interface FlexTemplateRuntimeEnvironmentOrBuilder

      • getAdditionalUserLabelsOrThrow

        public String getAdditionalUserLabelsOrThrow​(String key)
         Additional user labels to be specified for the job.
 Keys and values must follow the restrictions specified in the [labeling
 restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
 page.
 An object containing a list of "key": value pairs.
 Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
        map<string, string> additional_user_labels = 10;
        Specified by:
        getAdditionalUserLabelsOrThrow in interface FlexTemplateRuntimeEnvironmentOrBuilder

      • removeAdditionalUserLabels

        public FlexTemplateRuntimeEnvironment.Builder removeAdditionalUserLabels​(String key)
         Additional user labels to be specified for the job.
 Keys and values must follow the restrictions specified in the [labeling
 restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
 page.
 An object containing a list of "key": value pairs.
 Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
        map<string, string> additional_user_labels = 10;

      • getMutableAdditionalUserLabels

        @Deprecated
public Map<String,​String> getMutableAdditionalUserLabels()
        Deprecated.
        Use alternate mutation accessors instead.

      • putAdditionalUserLabels

        public FlexTemplateRuntimeEnvironment.Builder putAdditionalUserLabels​(String key,
                                                                      String value)
         Additional user labels to be specified for the job.
 Keys and values must follow the restrictions specified in the [labeling
 restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
 page.
 An object containing a list of "key": value pairs.
 Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
        map<string, string> additional_user_labels = 10;

      • putAllAdditionalUserLabels

        public FlexTemplateRuntimeEnvironment.Builder putAllAdditionalUserLabels​(Map<String,​String> values)
         Additional user labels to be specified for the job.
 Keys and values must follow the restrictions specified in the [labeling
 restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
 page.
 An object containing a list of "key": value pairs.
 Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
        map<string, string> additional_user_labels = 10;

      • getKmsKeyName

        public String getKmsKeyName()
         Name for the Cloud KMS key for the job.
 Key format is:
 projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
        string kms_key_name = 11;
        Specified by:
        getKmsKeyName in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The kmsKeyName.

      • getKmsKeyNameBytes

        public com.google.protobuf.ByteString getKmsKeyNameBytes()
         Name for the Cloud KMS key for the job.
 Key format is:
 projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
        string kms_key_name = 11;
        Specified by:
        getKmsKeyNameBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for kmsKeyName.

      • setKmsKeyName

        public FlexTemplateRuntimeEnvironment.Builder setKmsKeyName​(String value)
         Name for the Cloud KMS key for the job.
 Key format is:
 projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
        string kms_key_name = 11;
        Parameters:
        value - The kmsKeyName to set.
        Returns:
        This builder for chaining.

      • clearKmsKeyName

        public FlexTemplateRuntimeEnvironment.Builder clearKmsKeyName()
         Name for the Cloud KMS key for the job.
 Key format is:
 projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
        string kms_key_name = 11;
        Returns:
        This builder for chaining.

      • setKmsKeyNameBytes

        public FlexTemplateRuntimeEnvironment.Builder setKmsKeyNameBytes​(com.google.protobuf.ByteString value)
         Name for the Cloud KMS key for the job.
 Key format is:
 projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
        string kms_key_name = 11;
        Parameters:
        value - The bytes for kmsKeyName to set.
        Returns:
        This builder for chaining.

      • getIpConfigurationValue

        public int getIpConfigurationValue()
         Configuration for VM IPs.
        .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
        Specified by:
        getIpConfigurationValue in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The enum numeric value on the wire for ipConfiguration.

      • setIpConfigurationValue

        public FlexTemplateRuntimeEnvironment.Builder setIpConfigurationValue​(int value)
         Configuration for VM IPs.
        .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
        Parameters:
        value - The enum numeric value on the wire for ipConfiguration to set.
        Returns:
        This builder for chaining.

      • clearIpConfiguration

        public FlexTemplateRuntimeEnvironment.Builder clearIpConfiguration()
         Configuration for VM IPs.
        .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
        Returns:
        This builder for chaining.

      • getWorkerRegion

        public String getWorkerRegion()
         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;
        Specified by:
        getWorkerRegion in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The workerRegion.

      • getWorkerRegionBytes

        public com.google.protobuf.ByteString getWorkerRegionBytes()
         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;
        Specified by:
        getWorkerRegionBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for workerRegion.

      • setWorkerRegion

        public FlexTemplateRuntimeEnvironment.Builder setWorkerRegion​(String value)
         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;
        Parameters:
        value - The workerRegion to set.
        Returns:
        This builder for chaining.

      • clearWorkerRegion

        public FlexTemplateRuntimeEnvironment.Builder clearWorkerRegion()
         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;
        Returns:
        This builder for chaining.

      • setWorkerRegionBytes

        public FlexTemplateRuntimeEnvironment.Builder setWorkerRegionBytes​(com.google.protobuf.ByteString value)
         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;
        Parameters:
        value - The bytes for workerRegion to set.
        Returns:
        This builder for chaining.

      • getWorkerZone

        public String getWorkerZone()
         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.
 If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
        string worker_zone = 14;
        Specified by:
        getWorkerZone in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The workerZone.

      • getWorkerZoneBytes

        public com.google.protobuf.ByteString getWorkerZoneBytes()
         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.
 If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
        string worker_zone = 14;
        Specified by:
        getWorkerZoneBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for workerZone.

      • setWorkerZone

        public FlexTemplateRuntimeEnvironment.Builder setWorkerZone​(String value)
         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.
 If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
        string worker_zone = 14;
        Parameters:
        value - The workerZone to set.
        Returns:
        This builder for chaining.

      • clearWorkerZone

        public FlexTemplateRuntimeEnvironment.Builder clearWorkerZone()
         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.
 If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
        string worker_zone = 14;
        Returns:
        This builder for chaining.

      • setWorkerZoneBytes

        public FlexTemplateRuntimeEnvironment.Builder setWorkerZoneBytes​(com.google.protobuf.ByteString value)
         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.
 If both `worker_zone` and `zone` are set, `worker_zone` takes precedence.
        string worker_zone = 14;
        Parameters:
        value - The bytes for workerZone to set.
        Returns:
        This builder for chaining.

      • setEnableStreamingEngine

        public FlexTemplateRuntimeEnvironment.Builder setEnableStreamingEngine​(boolean value)
         Whether to enable Streaming Engine for the job.
        bool enable_streaming_engine = 15;
        Parameters:
        value - The enableStreamingEngine to set.
        Returns:
        This builder for chaining.

      • clearEnableStreamingEngine

        public FlexTemplateRuntimeEnvironment.Builder clearEnableStreamingEngine()
         Whether to enable Streaming Engine for the job.
        bool enable_streaming_engine = 15;
        Returns:
        This builder for chaining.

      • getFlexrsGoalValue

        public int getFlexrsGoalValue()
         Set FlexRS goal for the job.
 https://cloud.google.com/dataflow/docs/guides/flexrs
        .google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
        Specified by:
        getFlexrsGoalValue in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The enum numeric value on the wire for flexrsGoal.

      • setFlexrsGoalValue

        public FlexTemplateRuntimeEnvironment.Builder setFlexrsGoalValue​(int value)
         Set FlexRS goal for the job.
 https://cloud.google.com/dataflow/docs/guides/flexrs
        .google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
        Parameters:
        value - The enum numeric value on the wire for flexrsGoal to set.
        Returns:
        This builder for chaining.

      • setFlexrsGoal

        public FlexTemplateRuntimeEnvironment.Builder setFlexrsGoal​(FlexResourceSchedulingGoal value)
         Set FlexRS goal for the job.
 https://cloud.google.com/dataflow/docs/guides/flexrs
        .google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
        Parameters:
        value - The flexrsGoal to set.
        Returns:
        This builder for chaining.

      • clearFlexrsGoal

        public FlexTemplateRuntimeEnvironment.Builder clearFlexrsGoal()
         Set FlexRS goal for the job.
 https://cloud.google.com/dataflow/docs/guides/flexrs
        .google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
        Returns:
        This builder for chaining.

      • getStagingLocationBytes

        public com.google.protobuf.ByteString getStagingLocationBytes()
         The Cloud Storage path for staging local files.
 Must be a valid Cloud Storage URL, beginning with `gs://`.
        string staging_location = 17;
        Specified by:
        getStagingLocationBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for stagingLocation.

      • setStagingLocation

        public FlexTemplateRuntimeEnvironment.Builder setStagingLocation​(String value)
         The Cloud Storage path for staging local files.
 Must be a valid Cloud Storage URL, beginning with `gs://`.
        string staging_location = 17;
        Parameters:
        value - The stagingLocation to set.
        Returns:
        This builder for chaining.

      • clearStagingLocation

        public FlexTemplateRuntimeEnvironment.Builder clearStagingLocation()
         The Cloud Storage path for staging local files.
 Must be a valid Cloud Storage URL, beginning with `gs://`.
        string staging_location = 17;
        Returns:
        This builder for chaining.

      • setStagingLocationBytes

        public FlexTemplateRuntimeEnvironment.Builder setStagingLocationBytes​(com.google.protobuf.ByteString value)
         The Cloud Storage path for staging local files.
 Must be a valid Cloud Storage URL, beginning with `gs://`.
        string staging_location = 17;
        Parameters:
        value - The bytes for stagingLocation to set.
        Returns:
        This builder for chaining.

      • getSdkContainerImage

        public String getSdkContainerImage()
         Docker registry location of container image to use for the 'worker harness.
 Default is the container for the version of the SDK. Note this field is
 only valid for portable pipelines.
        string sdk_container_image = 18;
        Specified by:
        getSdkContainerImage in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The sdkContainerImage.

      • getSdkContainerImageBytes

        public com.google.protobuf.ByteString getSdkContainerImageBytes()
         Docker registry location of container image to use for the 'worker harness.
 Default is the container for the version of the SDK. Note this field is
 only valid for portable pipelines.
        string sdk_container_image = 18;
        Specified by:
        getSdkContainerImageBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for sdkContainerImage.

      • setSdkContainerImage

        public FlexTemplateRuntimeEnvironment.Builder setSdkContainerImage​(String value)
         Docker registry location of container image to use for the 'worker harness.
 Default is the container for the version of the SDK. Note this field is
 only valid for portable pipelines.
        string sdk_container_image = 18;
        Parameters:
        value - The sdkContainerImage to set.
        Returns:
        This builder for chaining.

      • clearSdkContainerImage

        public FlexTemplateRuntimeEnvironment.Builder clearSdkContainerImage()
         Docker registry location of container image to use for the 'worker harness.
 Default is the container for the version of the SDK. Note this field is
 only valid for portable pipelines.
        string sdk_container_image = 18;
        Returns:
        This builder for chaining.

      • setSdkContainerImageBytes

        public FlexTemplateRuntimeEnvironment.Builder setSdkContainerImageBytes​(com.google.protobuf.ByteString value)
         Docker registry location of container image to use for the 'worker harness.
 Default is the container for the version of the SDK. Note this field is
 only valid for portable pipelines.
        string sdk_container_image = 18;
        Parameters:
        value - The bytes for sdkContainerImage to set.
        Returns:
        This builder for chaining.

      • setDiskSizeGb

        public FlexTemplateRuntimeEnvironment.Builder setDiskSizeGb​(int value)
         Worker disk size, in gigabytes.
        int32 disk_size_gb = 20;
        Parameters:
        value - The diskSizeGb to set.
        Returns:
        This builder for chaining.

      • getAutoscalingAlgorithmValue

        public int getAutoscalingAlgorithmValue()
         The algorithm to use for autoscaling
        .google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
        Specified by:
        getAutoscalingAlgorithmValue in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The enum numeric value on the wire for autoscalingAlgorithm.

      • setAutoscalingAlgorithmValue

        public FlexTemplateRuntimeEnvironment.Builder setAutoscalingAlgorithmValue​(int value)
         The algorithm to use for autoscaling
        .google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
        Parameters:
        value - The enum numeric value on the wire for autoscalingAlgorithm to set.
        Returns:
        This builder for chaining.

      • setAutoscalingAlgorithm

        public FlexTemplateRuntimeEnvironment.Builder setAutoscalingAlgorithm​(AutoscalingAlgorithm value)
         The algorithm to use for autoscaling
        .google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
        Parameters:
        value - The autoscalingAlgorithm to set.
        Returns:
        This builder for chaining.

      • clearAutoscalingAlgorithm

        public FlexTemplateRuntimeEnvironment.Builder clearAutoscalingAlgorithm()
         The algorithm to use for autoscaling
        .google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
        Returns:
        This builder for chaining.

      • getDumpHeapOnOom

        public boolean getDumpHeapOnOom()
         If true, save a heap dump before killing a thread or process which is GC
 thrashing or out of memory. The location of the heap file will either be
 echoed back to the user, or the user will be given the opportunity to
 download the heap file.
        bool dump_heap_on_oom = 22;
        Specified by:
        getDumpHeapOnOom in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The dumpHeapOnOom.

      • setDumpHeapOnOom

        public FlexTemplateRuntimeEnvironment.Builder setDumpHeapOnOom​(boolean value)
         If true, save a heap dump before killing a thread or process which is GC
 thrashing or out of memory. The location of the heap file will either be
 echoed back to the user, or the user will be given the opportunity to
 download the heap file.
        bool dump_heap_on_oom = 22;
        Parameters:
        value - The dumpHeapOnOom to set.
        Returns:
        This builder for chaining.

      • clearDumpHeapOnOom

        public FlexTemplateRuntimeEnvironment.Builder clearDumpHeapOnOom()
         If true, save a heap dump before killing a thread or process which is GC
 thrashing or out of memory. The location of the heap file will either be
 echoed back to the user, or the user will be given the opportunity to
 download the heap file.
        bool dump_heap_on_oom = 22;
        Returns:
        This builder for chaining.

      • getSaveHeapDumpsToGcsPath

        public String getSaveHeapDumpsToGcsPath()
         Cloud Storage bucket (directory) to upload heap dumps to the given
 location. Enabling this implies that heap dumps should be generated on OOM
 (dump_heap_on_oom is set to true).
        string save_heap_dumps_to_gcs_path = 23;
        Specified by:
        getSaveHeapDumpsToGcsPath in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The saveHeapDumpsToGcsPath.

      • getSaveHeapDumpsToGcsPathBytes

        public com.google.protobuf.ByteString getSaveHeapDumpsToGcsPathBytes()
         Cloud Storage bucket (directory) to upload heap dumps to the given
 location. Enabling this implies that heap dumps should be generated on OOM
 (dump_heap_on_oom is set to true).
        string save_heap_dumps_to_gcs_path = 23;
        Specified by:
        getSaveHeapDumpsToGcsPathBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for saveHeapDumpsToGcsPath.

      • setSaveHeapDumpsToGcsPath

        public FlexTemplateRuntimeEnvironment.Builder setSaveHeapDumpsToGcsPath​(String value)
         Cloud Storage bucket (directory) to upload heap dumps to the given
 location. Enabling this implies that heap dumps should be generated on OOM
 (dump_heap_on_oom is set to true).
        string save_heap_dumps_to_gcs_path = 23;
        Parameters:
        value - The saveHeapDumpsToGcsPath to set.
        Returns:
        This builder for chaining.

      • clearSaveHeapDumpsToGcsPath

        public FlexTemplateRuntimeEnvironment.Builder clearSaveHeapDumpsToGcsPath()
         Cloud Storage bucket (directory) to upload heap dumps to the given
 location. Enabling this implies that heap dumps should be generated on OOM
 (dump_heap_on_oom is set to true).
        string save_heap_dumps_to_gcs_path = 23;
        Returns:
        This builder for chaining.

      • setSaveHeapDumpsToGcsPathBytes

        public FlexTemplateRuntimeEnvironment.Builder setSaveHeapDumpsToGcsPathBytes​(com.google.protobuf.ByteString value)
         Cloud Storage bucket (directory) to upload heap dumps to the given
 location. Enabling this implies that heap dumps should be generated on OOM
 (dump_heap_on_oom is set to true).
        string save_heap_dumps_to_gcs_path = 23;
        Parameters:
        value - The bytes for saveHeapDumpsToGcsPath to set.
        Returns:
        This builder for chaining.

      • getLauncherMachineTypeBytes

        public com.google.protobuf.ByteString getLauncherMachineTypeBytes()
         The machine type to use for launching the job. The default is
 n1-standard-1.
        string launcher_machine_type = 24;
        Specified by:
        getLauncherMachineTypeBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
        Returns:
        The bytes for launcherMachineType.

      • setLauncherMachineType

        public FlexTemplateRuntimeEnvironment.Builder setLauncherMachineType​(String value)
         The machine type to use for launching the job. The default is
 n1-standard-1.
        string launcher_machine_type = 24;
        Parameters:
        value - The launcherMachineType to set.
        Returns:
        This builder for chaining.

      • clearLauncherMachineType

        public FlexTemplateRuntimeEnvironment.Builder clearLauncherMachineType()
         The machine type to use for launching the job. The default is
 n1-standard-1.
        string launcher_machine_type = 24;
        Returns:
        This builder for chaining.

      • setLauncherMachineTypeBytes

        public FlexTemplateRuntimeEnvironment.Builder setLauncherMachineTypeBytes​(com.google.protobuf.ByteString value)
         The machine type to use for launching the job. The default is
 n1-standard-1.
        string launcher_machine_type = 24;
        Parameters:
        value - The bytes for launcherMachineType to set.
        Returns:
        This builder for chaining.