Class FlexTemplateRuntimeEnvironment.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
com.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment.Builder
All Implemented Interfaces:
FlexTemplateRuntimeEnvironmentOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
FlexTemplateRuntimeEnvironment

public static final class FlexTemplateRuntimeEnvironment.Builder extends com.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder> implements FlexTemplateRuntimeEnvironmentOrBuilder
 The environment values to be set at runtime for flex template.
 
Protobuf type google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment
  • Method Details

    • getDescriptor

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

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
      Overrides:
      internalGetMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
    • internalGetMutableMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
      Overrides:
      internalGetMutableMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
    • internalGetFieldAccessorTable

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

      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
    • mergeFrom

      public FlexTemplateRuntimeEnvironment.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<FlexTemplateRuntimeEnvironment.Builder>
    • mergeFrom

    • isInitialized

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

      public FlexTemplateRuntimeEnvironment.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<FlexTemplateRuntimeEnvironment.Builder>
      Throws:
      IOException
    • getNumWorkers

      public int getNumWorkers()
       The initial number of Google Compute Engine instances for the job.
       
      int32 num_workers = 1;
      Specified by:
      getNumWorkers in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The numWorkers.
    • 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

       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

       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.
    • getServiceAccountEmail

      public String getServiceAccountEmail()
       The email address of the service account to run the job as.
       
      string service_account_email = 4;
      Specified by:
      getServiceAccountEmail in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The serviceAccountEmail.
    • 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.
    • getTempLocation

      public String getTempLocation()
       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:
      getTempLocation in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The tempLocation.
    • 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.
    • getMachineType

      public String getMachineType()
       The machine type to use for the job. Defaults to the value from the
       template if not specified.
       
      string machine_type = 6;
      Specified by:
      getMachineType in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The machineType.
    • 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.
    • getAdditionalExperimentsCount

      public int getAdditionalExperimentsCount()
       Additional experiment flags for the job.
       
      repeated string additional_experiments = 7;
      Specified by:
      getAdditionalExperimentsCount in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The count of 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.
    • getNetwork

      public String getNetwork()
       Network to which VMs will be assigned.  If empty or unspecified,
       the service will use the network "default".
       
      string network = 8;
      Specified by:
      getNetwork in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The network.
    • 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

       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

       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
    • getAdditionalUserLabels

      @Deprecated public Map<String,String> getAdditionalUserLabels()
      Deprecated.
      Specified by:
      getAdditionalUserLabels 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
    • clearAdditionalUserLabels

      public FlexTemplateRuntimeEnvironment.Builder clearAdditionalUserLabels()
    • 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.
    • getIpConfiguration

      public WorkerIPAddressConfiguration getIpConfiguration()
       Configuration for VM IPs.
       
      .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
      Specified by:
      getIpConfiguration in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The ipConfiguration.
    • setIpConfiguration

       Configuration for VM IPs.
       
      .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
      Parameters:
      value - The 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.
    • getEnableStreamingEngine

      public boolean getEnableStreamingEngine()
       Whether to enable Streaming Engine for the job.
       
      bool enable_streaming_engine = 15;
      Specified by:
      getEnableStreamingEngine in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The enableStreamingEngine.
    • 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.
    • getFlexrsGoal

      public FlexResourceSchedulingGoal getFlexrsGoal()
       Set FlexRS goal for the job.
       https://cloud.google.com/dataflow/docs/guides/flexrs
       
      .google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
      Specified by:
      getFlexrsGoal in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The flexrsGoal.
    • setFlexrsGoal

       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.
    • getStagingLocation

      public String getStagingLocation()
       The Cloud Storage path for staging local files.
       Must be a valid Cloud Storage URL, beginning with `gs://`.
       
      string staging_location = 17;
      Specified by:
      getStagingLocation in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The stagingLocation.
    • 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.
    • getDiskSizeGb

      public int getDiskSizeGb()
       Worker disk size, in gigabytes.
       
      int32 disk_size_gb = 20;
      Specified by:
      getDiskSizeGb in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The diskSizeGb.
    • 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.
    • clearDiskSizeGb

      public FlexTemplateRuntimeEnvironment.Builder clearDiskSizeGb()
       Worker disk size, in gigabytes.
       
      int32 disk_size_gb = 20;
      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.
    • getAutoscalingAlgorithm

      public AutoscalingAlgorithm getAutoscalingAlgorithm()
       The algorithm to use for autoscaling
       
      .google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
      Specified by:
      getAutoscalingAlgorithm in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The autoscalingAlgorithm.
    • 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, when processing time is spent almost entirely
       on garbage collection (GC), saves a heap dump before ending the thread
       or process. If false, ends the thread or process without saving a heap
       dump. Does not save a heap dump when the Java Virtual Machine (JVM) has an
       out of memory error during processing. The location of the heap file is
       either echoed back to the user, or the user is 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, when processing time is spent almost entirely
       on garbage collection (GC), saves a heap dump before ending the thread
       or process. If false, ends the thread or process without saving a heap
       dump. Does not save a heap dump when the Java Virtual Machine (JVM) has an
       out of memory error during processing. The location of the heap file is
       either echoed back to the user, or the user is 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, when processing time is spent almost entirely
       on garbage collection (GC), saves a heap dump before ending the thread
       or process. If false, ends the thread or process without saving a heap
       dump. Does not save a heap dump when the Java Virtual Machine (JVM) has an
       out of memory error during processing. The location of the heap file is
       either echoed back to the user, or the user is 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.
       Enabling this field implies that `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.
       Enabling this field implies that `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.
       Enabling this field implies that `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.
       Enabling this field implies that `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.
       Enabling this field implies that `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.
    • getLauncherMachineType

      public String getLauncherMachineType()
       The machine type to use for launching the job. The default is
       n1-standard-1.
       
      string launcher_machine_type = 24;
      Specified by:
      getLauncherMachineType in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The launcherMachineType.
    • 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.
    • getEnableLauncherVmSerialPortLogging

      public boolean getEnableLauncherVmSerialPortLogging()
       If true serial port logging will be enabled for the launcher VM.
       
      bool enable_launcher_vm_serial_port_logging = 25;
      Specified by:
      getEnableLauncherVmSerialPortLogging in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The enableLauncherVmSerialPortLogging.
    • setEnableLauncherVmSerialPortLogging

      public FlexTemplateRuntimeEnvironment.Builder setEnableLauncherVmSerialPortLogging(boolean value)
       If true serial port logging will be enabled for the launcher VM.
       
      bool enable_launcher_vm_serial_port_logging = 25;
      Parameters:
      value - The enableLauncherVmSerialPortLogging to set.
      Returns:
      This builder for chaining.
    • clearEnableLauncherVmSerialPortLogging

      public FlexTemplateRuntimeEnvironment.Builder clearEnableLauncherVmSerialPortLogging()
       If true serial port logging will be enabled for the launcher VM.
       
      bool enable_launcher_vm_serial_port_logging = 25;
      Returns:
      This builder for chaining.
    • hasStreamingMode

      public boolean hasStreamingMode()
       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).
       
      optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      hasStreamingMode in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      Whether the streamingMode field is set.
    • 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).
       
      optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getStreamingModeValue in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The enum numeric value on the wire for streamingMode.
    • setStreamingModeValue

      public FlexTemplateRuntimeEnvironment.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).
       
      optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.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).
       
      optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getStreamingMode in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The streamingMode.
    • setStreamingMode

      public FlexTemplateRuntimeEnvironment.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).
       
      optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The streamingMode to set.
      Returns:
      This builder for chaining.
    • clearStreamingMode

      public FlexTemplateRuntimeEnvironment.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).
       
      optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.
    • getAdditionalPipelineOptionsList

      public com.google.protobuf.ProtocolStringList getAdditionalPipelineOptionsList()
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getAdditionalPipelineOptionsList in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      A list containing the additionalPipelineOptions.
    • getAdditionalPipelineOptionsCount

      public int getAdditionalPipelineOptionsCount()
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getAdditionalPipelineOptionsCount in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The count of additionalPipelineOptions.
    • getAdditionalPipelineOptions

      public String getAdditionalPipelineOptions(int index)
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getAdditionalPipelineOptions in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The additionalPipelineOptions at the given index.
    • getAdditionalPipelineOptionsBytes

      public com.google.protobuf.ByteString getAdditionalPipelineOptionsBytes(int index)
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getAdditionalPipelineOptionsBytes in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the additionalPipelineOptions at the given index.
    • setAdditionalPipelineOptions

      public FlexTemplateRuntimeEnvironment.Builder setAdditionalPipelineOptions(int index, String value)
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      index - The index to set the value at.
      value - The additionalPipelineOptions to set.
      Returns:
      This builder for chaining.
    • addAdditionalPipelineOptions

      public FlexTemplateRuntimeEnvironment.Builder addAdditionalPipelineOptions(String value)
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The additionalPipelineOptions to add.
      Returns:
      This builder for chaining.
    • addAllAdditionalPipelineOptions

      public FlexTemplateRuntimeEnvironment.Builder addAllAdditionalPipelineOptions(Iterable<String> values)
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      values - The additionalPipelineOptions to add.
      Returns:
      This builder for chaining.
    • clearAdditionalPipelineOptions

      public FlexTemplateRuntimeEnvironment.Builder clearAdditionalPipelineOptions()
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.
    • addAdditionalPipelineOptionsBytes

      public FlexTemplateRuntimeEnvironment.Builder addAdditionalPipelineOptionsBytes(com.google.protobuf.ByteString value)
       Optional. Additional pipeline option flags for the job.
       
      repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The bytes of the additionalPipelineOptions to add.
      Returns:
      This builder for chaining.