Package com.google.dataflow.v1beta3

Class FlexTemplateRuntimeEnvironment

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
com.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment
All Implemented Interfaces:
FlexTemplateRuntimeEnvironmentOrBuilder, com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable
@Generated public final class FlexTemplateRuntimeEnvironment extends com.google.protobuf.GeneratedMessage implements FlexTemplateRuntimeEnvironmentOrBuilder
 The environment values to be set at runtime for flex template.
Protobuf type google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment
See Also:

  • Field Details

    • NUM_WORKERS_FIELD_NUMBER

      public static final int NUM_WORKERS_FIELD_NUMBER
      See Also:

    • MAX_WORKERS_FIELD_NUMBER

      public static final int MAX_WORKERS_FIELD_NUMBER
      See Also:

    • ZONE_FIELD_NUMBER

      public static final int ZONE_FIELD_NUMBER
      See Also:

    • SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER

      public static final int SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
      See Also:

    • TEMP_LOCATION_FIELD_NUMBER

      public static final int TEMP_LOCATION_FIELD_NUMBER
      See Also:

    • MACHINE_TYPE_FIELD_NUMBER

      public static final int MACHINE_TYPE_FIELD_NUMBER
      See Also:

    • ADDITIONAL_EXPERIMENTS_FIELD_NUMBER

      public static final int ADDITIONAL_EXPERIMENTS_FIELD_NUMBER
      See Also:

    • NETWORK_FIELD_NUMBER

      public static final int NETWORK_FIELD_NUMBER
      See Also:

    • SUBNETWORK_FIELD_NUMBER

      public static final int SUBNETWORK_FIELD_NUMBER
      See Also:

    • ADDITIONAL_USER_LABELS_FIELD_NUMBER

      public static final int ADDITIONAL_USER_LABELS_FIELD_NUMBER
      See Also:

    • KMS_KEY_NAME_FIELD_NUMBER

      public static final int KMS_KEY_NAME_FIELD_NUMBER
      See Also:

    • IP_CONFIGURATION_FIELD_NUMBER

      public static final int IP_CONFIGURATION_FIELD_NUMBER
      See Also:

    • WORKER_REGION_FIELD_NUMBER

      public static final int WORKER_REGION_FIELD_NUMBER
      See Also:

    • WORKER_ZONE_FIELD_NUMBER

      public static final int WORKER_ZONE_FIELD_NUMBER
      See Also:

    • ENABLE_STREAMING_ENGINE_FIELD_NUMBER

      public static final int ENABLE_STREAMING_ENGINE_FIELD_NUMBER
      See Also:

    • FLEXRS_GOAL_FIELD_NUMBER

      public static final int FLEXRS_GOAL_FIELD_NUMBER
      See Also:

    • STAGING_LOCATION_FIELD_NUMBER

      public static final int STAGING_LOCATION_FIELD_NUMBER
      See Also:

    • SDK_CONTAINER_IMAGE_FIELD_NUMBER

      public static final int SDK_CONTAINER_IMAGE_FIELD_NUMBER
      See Also:

    • DISK_SIZE_GB_FIELD_NUMBER

      public static final int DISK_SIZE_GB_FIELD_NUMBER
      See Also:

    • AUTOSCALING_ALGORITHM_FIELD_NUMBER

      public static final int AUTOSCALING_ALGORITHM_FIELD_NUMBER
      See Also:

    • DUMP_HEAP_ON_OOM_FIELD_NUMBER

      public static final int DUMP_HEAP_ON_OOM_FIELD_NUMBER
      See Also:

    • SAVE_HEAP_DUMPS_TO_GCS_PATH_FIELD_NUMBER

      public static final int SAVE_HEAP_DUMPS_TO_GCS_PATH_FIELD_NUMBER
      See Also:

    • LAUNCHER_MACHINE_TYPE_FIELD_NUMBER

      public static final int LAUNCHER_MACHINE_TYPE_FIELD_NUMBER
      See Also:

    • ENABLE_LAUNCHER_VM_SERIAL_PORT_LOGGING_FIELD_NUMBER

      public static final int ENABLE_LAUNCHER_VM_SERIAL_PORT_LOGGING_FIELD_NUMBER
      See Also:

    • STREAMING_MODE_FIELD_NUMBER

      public static final int STREAMING_MODE_FIELD_NUMBER
      See Also:

    • ADDITIONAL_PIPELINE_OPTIONS_FIELD_NUMBER

      public static final int ADDITIONAL_PIPELINE_OPTIONS_FIELD_NUMBER
      See Also:

  • 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

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

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

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

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

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

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

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

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

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

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

    • 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.
      Use getAdditionalUserLabelsMap() instead.
      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

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

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

    • getIpConfiguration

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

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

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

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

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

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

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

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

    • getDiskSizeGb

      public int getDiskSizeGb()
       Worker disk size, in gigabytes.
      int32 disk_size_gb = 20;
      Specified by:
      getDiskSizeGb in interface FlexTemplateRuntimeEnvironmentOrBuilder
      Returns:
      The diskSizeGb.

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

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

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

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

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

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

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

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

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

    • isInitialized

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

    • writeTo

      public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
      Specified by:
      writeTo in interface com.google.protobuf.MessageLite
      Overrides:
      writeTo in class com.google.protobuf.GeneratedMessage
      Throws:
      IOException

    • getSerializedSize

      public int getSerializedSize()
      Specified by:
      getSerializedSize in interface com.google.protobuf.MessageLite
      Overrides:
      getSerializedSize in class com.google.protobuf.GeneratedMessage

    • equals

      public boolean equals(Object obj)
      Specified by:
      equals in interface com.google.protobuf.Message
      Overrides:
      equals in class com.google.protobuf.AbstractMessage

    • hashCode

      public int hashCode()
      Specified by:
      hashCode in interface com.google.protobuf.Message
      Overrides:
      hashCode in class com.google.protobuf.AbstractMessage

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static FlexTemplateRuntimeEnvironment parseDelimitedFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static FlexTemplateRuntimeEnvironment parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static FlexTemplateRuntimeEnvironment parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • newBuilderForType

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

    • newBuilder

      public static FlexTemplateRuntimeEnvironment.Builder newBuilder()

    • newBuilder

      public static FlexTemplateRuntimeEnvironment.Builder newBuilder(FlexTemplateRuntimeEnvironment prototype)

    • toBuilder

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

    • newBuilderForType

      protected FlexTemplateRuntimeEnvironment.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
      Overrides:
      newBuilderForType in class com.google.protobuf.AbstractMessage

    • getDefaultInstance

      public static FlexTemplateRuntimeEnvironment getDefaultInstance()

    • parser

      public static com.google.protobuf.Parser<FlexTemplateRuntimeEnvironment> parser()

    • getParserForType

      public com.google.protobuf.Parser<FlexTemplateRuntimeEnvironment> getParserForType()
      Specified by:
      getParserForType in interface com.google.protobuf.Message
      Specified by:
      getParserForType in interface com.google.protobuf.MessageLite
      Overrides:
      getParserForType in class com.google.protobuf.GeneratedMessage

    • getDefaultInstanceForType

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