/*
 * Copyright 2020 Google LLC
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: google/dataflow/v1beta3/environment.proto

package com.google.dataflow.v1beta3;

/**
 *
 *
 * <pre>
 * Describes the environment in which a Dataflow Job runs.
 * </pre>
 *
 * Protobuf type {@code google.dataflow.v1beta3.Environment}
 */
public final class Environment extends com.google.protobuf.GeneratedMessageV3
    implements
    // @@protoc_insertion_point(message_implements:google.dataflow.v1beta3.Environment)
    EnvironmentOrBuilder {
  private static final long serialVersionUID = 0L;
  // Use Environment.newBuilder() to construct.
  private Environment(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
    super(builder);
  }

  private Environment() {
    tempStoragePrefix_ = "";
    clusterManagerApiService_ = "";
    experiments_ = com.google.protobuf.LazyStringArrayList.EMPTY;
    serviceOptions_ = com.google.protobuf.LazyStringArrayList.EMPTY;
    serviceKmsKeyName_ = "";
    workerPools_ = java.util.Collections.emptyList();
    dataset_ = "";
    serviceAccountEmail_ = "";
    flexResourceSchedulingGoal_ = 0;
    workerRegion_ = "";
    workerZone_ = "";
    shuffleMode_ = 0;
  }

  @java.lang.Override
  @SuppressWarnings({"unused"})
  protected java.lang.Object newInstance(UnusedPrivateParameter unused) {
    return new Environment();
  }

  @java.lang.Override
  public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
    return this.unknownFields;
  }

  public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
    return com.google.dataflow.v1beta3.EnvironmentProto
        .internal_static_google_dataflow_v1beta3_Environment_descriptor;
  }

  @java.lang.Override
  protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internalGetFieldAccessorTable() {
    return com.google.dataflow.v1beta3.EnvironmentProto
        .internal_static_google_dataflow_v1beta3_Environment_fieldAccessorTable
        .ensureFieldAccessorsInitialized(
            com.google.dataflow.v1beta3.Environment.class,
            com.google.dataflow.v1beta3.Environment.Builder.class);
  }

  public static final int TEMP_STORAGE_PREFIX_FIELD_NUMBER = 1;

  @SuppressWarnings("serial")
  private volatile java.lang.Object tempStoragePrefix_ = "";
  /**
   *
   *
   * <pre>
   * The prefix of the resources the system should use for temporary
   * storage.  The system will append the suffix "/temp-{JOBNAME} to
   * this resource prefix, where {JOBNAME} is the value of the
   * job_name field.  The resulting bucket and object prefix is used
   * as the prefix of the resources used to store temporary data
   * needed during the job execution.  NOTE: This will override the
   * value in taskrunner_settings.
   * The supported resource type is:
   * Google Cloud Storage:
   *   storage.googleapis.com/{bucket}/{object}
   *   bucket.storage.googleapis.com/{object}
   * </pre>
   *
   * <code>string temp_storage_prefix = 1;</code>
   *
   * @return The tempStoragePrefix.
   */
  @java.lang.Override
  public java.lang.String getTempStoragePrefix() {
    java.lang.Object ref = tempStoragePrefix_;
    if (ref instanceof java.lang.String) {
      return (java.lang.String) ref;
    } else {
      com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
      java.lang.String s = bs.toStringUtf8();
      tempStoragePrefix_ = s;
      return s;
    }
  }
  /**
   *
   *
   * <pre>
   * The prefix of the resources the system should use for temporary
   * storage.  The system will append the suffix "/temp-{JOBNAME} to
   * this resource prefix, where {JOBNAME} is the value of the
   * job_name field.  The resulting bucket and object prefix is used
   * as the prefix of the resources used to store temporary data
   * needed during the job execution.  NOTE: This will override the
   * value in taskrunner_settings.
   * The supported resource type is:
   * Google Cloud Storage:
   *   storage.googleapis.com/{bucket}/{object}
   *   bucket.storage.googleapis.com/{object}
   * </pre>
   *
   * <code>string temp_storage_prefix = 1;</code>
   *
   * @return The bytes for tempStoragePrefix.
   */
  @java.lang.Override
  public com.google.protobuf.ByteString getTempStoragePrefixBytes() {
    java.lang.Object ref = tempStoragePrefix_;
    if (ref instanceof java.lang.String) {
      com.google.protobuf.ByteString b =
          com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
      tempStoragePrefix_ = b;
      return b;
    } else {
      return (com.google.protobuf.ByteString) ref;
    }
  }

  public static final int CLUSTER_MANAGER_API_SERVICE_FIELD_NUMBER = 2;

  @SuppressWarnings("serial")
  private volatile java.lang.Object clusterManagerApiService_ = "";
  /**
   *
   *
   * <pre>
   * The type of cluster manager API to use.  If unknown or
   * unspecified, the service will attempt to choose a reasonable
   * default.  This should be in the form of the API service name,
   * e.g. "compute.googleapis.com".
   * </pre>
   *
   * <code>string cluster_manager_api_service = 2;</code>
   *
   * @return The clusterManagerApiService.
   */
  @java.lang.Override
  public java.lang.String getClusterManagerApiService() {
    java.lang.Object ref = clusterManagerApiService_;
    if (ref instanceof java.lang.String) {
      return (java.lang.String) ref;
    } else {
      com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
      java.lang.String s = bs.toStringUtf8();
      clusterManagerApiService_ = s;
      return s;
    }
  }
  /**
   *
   *
   * <pre>
   * The type of cluster manager API to use.  If unknown or
   * unspecified, the service will attempt to choose a reasonable
   * default.  This should be in the form of the API service name,
   * e.g. "compute.googleapis.com".
   * </pre>
   *
   * <code>string cluster_manager_api_service = 2;</code>
   *
   * @return The bytes for clusterManagerApiService.
   */
  @java.lang.Override
  public com.google.protobuf.ByteString getClusterManagerApiServiceBytes() {
    java.lang.Object ref = clusterManagerApiService_;
    if (ref instanceof java.lang.String) {
      com.google.protobuf.ByteString b =
          com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
      clusterManagerApiService_ = b;
      return b;
    } else {
      return (com.google.protobuf.ByteString) ref;
    }
  }

  public static final int EXPERIMENTS_FIELD_NUMBER = 3;

  @SuppressWarnings("serial")
  private com.google.protobuf.LazyStringList experiments_;
  /**
   *
   *
   * <pre>
   * The list of experiments to enable. This field should be used for SDK
   * related experiments and not for service related experiments. The proper
   * field for service related experiments is service_options.
   * </pre>
   *
   * <code>repeated string experiments = 3;</code>
   *
   * @return A list containing the experiments.
   */
  public com.google.protobuf.ProtocolStringList getExperimentsList() {
    return experiments_;
  }
  /**
   *
   *
   * <pre>
   * The list of experiments to enable. This field should be used for SDK
   * related experiments and not for service related experiments. The proper
   * field for service related experiments is service_options.
   * </pre>
   *
   * <code>repeated string experiments = 3;</code>
   *
   * @return The count of experiments.
   */
  public int getExperimentsCount() {
    return experiments_.size();
  }
  /**
   *
   *
   * <pre>
   * The list of experiments to enable. This field should be used for SDK
   * related experiments and not for service related experiments. The proper
   * field for service related experiments is service_options.
   * </pre>
   *
   * <code>repeated string experiments = 3;</code>
   *
   * @param index The index of the element to return.
   * @return The experiments at the given index.
   */
  public java.lang.String getExperiments(int index) {
    return experiments_.get(index);
  }
  /**
   *
   *
   * <pre>
   * The list of experiments to enable. This field should be used for SDK
   * related experiments and not for service related experiments. The proper
   * field for service related experiments is service_options.
   * </pre>
   *
   * <code>repeated string experiments = 3;</code>
   *
   * @param index The index of the value to return.
   * @return The bytes of the experiments at the given index.
   */
  public com.google.protobuf.ByteString getExperimentsBytes(int index) {
    return experiments_.getByteString(index);
  }

  public static final int SERVICE_OPTIONS_FIELD_NUMBER = 16;

  @SuppressWarnings("serial")
  private com.google.protobuf.LazyStringList serviceOptions_;
  /**
   *
   *
   * <pre>
   * The list of service options to enable. This field should be used for
   * service related experiments only. These experiments, when graduating to GA,
   * should be replaced by dedicated fields or become default (i.e. always on).
   * </pre>
   *
   * <code>repeated string service_options = 16;</code>
   *
   * @return A list containing the serviceOptions.
   */
  public com.google.protobuf.ProtocolStringList getServiceOptionsList() {
    return serviceOptions_;
  }
  /**
   *
   *
   * <pre>
   * The list of service options to enable. This field should be used for
   * service related experiments only. These experiments, when graduating to GA,
   * should be replaced by dedicated fields or become default (i.e. always on).
   * </pre>
   *
   * <code>repeated string service_options = 16;</code>
   *
   * @return The count of serviceOptions.
   */
  public int getServiceOptionsCount() {
    return serviceOptions_.size();
  }
  /**
   *
   *
   * <pre>
   * The list of service options to enable. This field should be used for
   * service related experiments only. These experiments, when graduating to GA,
   * should be replaced by dedicated fields or become default (i.e. always on).
   * </pre>
   *
   * <code>repeated string service_options = 16;</code>
   *
   * @param index The index of the element to return.
   * @return The serviceOptions at the given index.
   */
  public java.lang.String getServiceOptions(int index) {
    return serviceOptions_.get(index);
  }
  /**
   *
   *
   * <pre>
   * The list of service options to enable. This field should be used for
   * service related experiments only. These experiments, when graduating to GA,
   * should be replaced by dedicated fields or become default (i.e. always on).
   * </pre>
   *
   * <code>repeated string service_options = 16;</code>
   *
   * @param index The index of the value to return.
   * @return The bytes of the serviceOptions at the given index.
   */
  public com.google.protobuf.ByteString getServiceOptionsBytes(int index) {
    return serviceOptions_.getByteString(index);
  }

  public static final int SERVICE_KMS_KEY_NAME_FIELD_NUMBER = 12;

  @SuppressWarnings("serial")
  private volatile java.lang.Object serviceKmsKeyName_ = "";
  /**
   *
   *
   * <pre>
   * If set, contains the Cloud KMS key identifier used to encrypt data
   * at rest, AKA a Customer Managed Encryption Key (CMEK).
   * Format:
   *   projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
   * </pre>
   *
   * <code>string service_kms_key_name = 12;</code>
   *
   * @return The serviceKmsKeyName.
   */
  @java.lang.Override
  public java.lang.String getServiceKmsKeyName() {
    java.lang.Object ref = serviceKmsKeyName_;
    if (ref instanceof java.lang.String) {
      return (java.lang.String) ref;
    } else {
      com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
      java.lang.String s = bs.toStringUtf8();
      serviceKmsKeyName_ = s;
      return s;
    }
  }
  /**
   *
   *
   * <pre>
   * If set, contains the Cloud KMS key identifier used to encrypt data
   * at rest, AKA a Customer Managed Encryption Key (CMEK).
   * Format:
   *   projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
   * </pre>
   *
   * <code>string service_kms_key_name = 12;</code>
   *
   * @return The bytes for serviceKmsKeyName.
   */
  @java.lang.Override
  public com.google.protobuf.ByteString getServiceKmsKeyNameBytes() {
    java.lang.Object ref = serviceKmsKeyName_;
    if (ref instanceof java.lang.String) {
      com.google.protobuf.ByteString b =
          com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
      serviceKmsKeyName_ = b;
      return b;
    } else {
      return (com.google.protobuf.ByteString) ref;
    }
  }

  public static final int WORKER_POOLS_FIELD_NUMBER = 4;

  @SuppressWarnings("serial")
  private java.util.List<com.google.dataflow.v1beta3.WorkerPool> workerPools_;
  /**
   *
   *
   * <pre>
   * The worker pools. At least one "harness" worker pool must be
   * specified in order for the job to have workers.
   * </pre>
   *
   * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
   */
  @java.lang.Override
  public java.util.List<com.google.dataflow.v1beta3.WorkerPool> getWorkerPoolsList() {
    return workerPools_;
  }
  /**
   *
   *
   * <pre>
   * The worker pools. At least one "harness" worker pool must be
   * specified in order for the job to have workers.
   * </pre>
   *
   * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
   */
  @java.lang.Override
  public java.util.List<? extends com.google.dataflow.v1beta3.WorkerPoolOrBuilder>
      getWorkerPoolsOrBuilderList() {
    return workerPools_;
  }
  /**
   *
   *
   * <pre>
   * The worker pools. At least one "harness" worker pool must be
   * specified in order for the job to have workers.
   * </pre>
   *
   * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
   */
  @java.lang.Override
  public int getWorkerPoolsCount() {
    return workerPools_.size();
  }
  /**
   *
   *
   * <pre>
   * The worker pools. At least one "harness" worker pool must be
   * specified in order for the job to have workers.
   * </pre>
   *
   * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
   */
  @java.lang.Override
  public com.google.dataflow.v1beta3.WorkerPool getWorkerPools(int index) {
    return workerPools_.get(index);
  }
  /**
   *
   *
   * <pre>
   * The worker pools. At least one "harness" worker pool must be
   * specified in order for the job to have workers.
   * </pre>
   *
   * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
   */
  @java.lang.Override
  public com.google.dataflow.v1beta3.WorkerPoolOrBuilder getWorkerPoolsOrBuilder(int index) {
    return workerPools_.get(index);
  }

  public static final int USER_AGENT_FIELD_NUMBER = 5;
  private com.google.protobuf.Struct userAgent_;
  /**
   *
   *
   * <pre>
   * A description of the process that generated the request.
   * </pre>
   *
   * <code>.google.protobuf.Struct user_agent = 5;</code>
   *
   * @return Whether the userAgent field is set.
   */
  @java.lang.Override
  public boolean hasUserAgent() {
    return userAgent_ != null;
  }
  /**
   *
   *
   * <pre>
   * A description of the process that generated the request.
   * </pre>
   *
   * <code>.google.protobuf.Struct user_agent = 5;</code>
   *
   * @return The userAgent.
   */
  @java.lang.Override
  public com.google.protobuf.Struct getUserAgent() {
    return userAgent_ == null ? com.google.protobuf.Struct.getDefaultInstance() : userAgent_;
  }
  /**
   *
   *
   * <pre>
   * A description of the process that generated the request.
   * </pre>
   *
   * <code>.google.protobuf.Struct user_agent = 5;</code>
   */
  @java.lang.Override
  public com.google.protobuf.StructOrBuilder getUserAgentOrBuilder() {
    return userAgent_ == null ? com.google.protobuf.Struct.getDefaultInstance() : userAgent_;
  }

  public static final int VERSION_FIELD_NUMBER = 6;
  private com.google.protobuf.Struct version_;
  /**
   *
   *
   * <pre>
   * A structure describing which components and their versions of the service
   * are required in order to run the job.
   * </pre>
   *
   * <code>.google.protobuf.Struct version = 6;</code>
   *
   * @return Whether the version field is set.
   */
  @java.lang.Override
  public boolean hasVersion() {
    return version_ != null;
  }
  /**
   *
   *
   * <pre>
   * A structure describing which components and their versions of the service
   * are required in order to run the job.
   * </pre>
   *
   * <code>.google.protobuf.Struct version = 6;</code>
   *
   * @return The version.
   */
  @java.lang.Override
  public com.google.protobuf.Struct getVersion() {
    return version_ == null ? com.google.protobuf.Struct.getDefaultInstance() : version_;
  }
  /**
   *
   *
   * <pre>
   * A structure describing which components and their versions of the service
   * are required in order to run the job.
   * </pre>
   *
   * <code>.google.protobuf.Struct version = 6;</code>
   */
  @java.lang.Override
  public com.google.protobuf.StructOrBuilder getVersionOrBuilder() {
    return version_ == null ? com.google.protobuf.Struct.getDefaultInstance() : version_;
  }

  public static final int DATASET_FIELD_NUMBER = 7;

  @SuppressWarnings("serial")
  private volatile java.lang.Object dataset_ = "";
  /**
   *
   *
   * <pre>
   * The dataset for the current project where various workflow
   * related tables are stored.
   * The supported resource type is:
   * Google BigQuery:
   *   bigquery.googleapis.com/{dataset}
   * </pre>
   *
   * <code>string dataset = 7;</code>
   *
   * @return The dataset.
   */
  @java.lang.Override
  public java.lang.String getDataset() {
    java.lang.Object ref = dataset_;
    if (ref instanceof java.lang.String) {
      return (java.lang.String) ref;
    } else {
      com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
      java.lang.String s = bs.toStringUtf8();
      dataset_ = s;
      return s;
    }
  }
  /**
   *
   *
   * <pre>
   * The dataset for the current project where various workflow
   * related tables are stored.
   * The supported resource type is:
   * Google BigQuery:
   *   bigquery.googleapis.com/{dataset}
   * </pre>
   *
   * <code>string dataset = 7;</code>
   *
   * @return The bytes for dataset.
   */
  @java.lang.Override
  public com.google.protobuf.ByteString getDatasetBytes() {
    java.lang.Object ref = dataset_;
    if (ref instanceof java.lang.String) {
      com.google.protobuf.ByteString b =
          com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
      dataset_ = b;
      return b;
    } else {
      return (com.google.protobuf.ByteString) ref;
    }
  }

  public static final int SDK_PIPELINE_OPTIONS_FIELD_NUMBER = 8;
  private com.google.protobuf.Struct sdkPipelineOptions_;
  /**
   *
   *
   * <pre>
   * The Cloud Dataflow SDK pipeline options specified by the user. These
   * options are passed through the service and are used to recreate the
   * SDK pipeline options on the worker in a language agnostic and platform
   * independent way.
   * </pre>
   *
   * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
   *
   * @return Whether the sdkPipelineOptions field is set.
   */
  @java.lang.Override
  public boolean hasSdkPipelineOptions() {
    return sdkPipelineOptions_ != null;
  }
  /**
   *
   *
   * <pre>
   * The Cloud Dataflow SDK pipeline options specified by the user. These
   * options are passed through the service and are used to recreate the
   * SDK pipeline options on the worker in a language agnostic and platform
   * independent way.
   * </pre>
   *
   * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
   *
   * @return The sdkPipelineOptions.
   */
  @java.lang.Override
  public com.google.protobuf.Struct getSdkPipelineOptions() {
    return sdkPipelineOptions_ == null
        ? com.google.protobuf.Struct.getDefaultInstance()
        : sdkPipelineOptions_;
  }
  /**
   *
   *
   * <pre>
   * The Cloud Dataflow SDK pipeline options specified by the user. These
   * options are passed through the service and are used to recreate the
   * SDK pipeline options on the worker in a language agnostic and platform
   * independent way.
   * </pre>
   *
   * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
   */
  @java.lang.Override
  public com.google.protobuf.StructOrBuilder getSdkPipelineOptionsOrBuilder() {
    return sdkPipelineOptions_ == null
        ? com.google.protobuf.Struct.getDefaultInstance()
        : sdkPipelineOptions_;
  }

  public static final int INTERNAL_EXPERIMENTS_FIELD_NUMBER = 9;
  private com.google.protobuf.Any internalExperiments_;
  /**
   *
   *
   * <pre>
   * Experimental settings.
   * </pre>
   *
   * <code>.google.protobuf.Any internal_experiments = 9;</code>
   *
   * @return Whether the internalExperiments field is set.
   */
  @java.lang.Override
  public boolean hasInternalExperiments() {
    return internalExperiments_ != null;
  }
  /**
   *
   *
   * <pre>
   * Experimental settings.
   * </pre>
   *
   * <code>.google.protobuf.Any internal_experiments = 9;</code>
   *
   * @return The internalExperiments.
   */
  @java.lang.Override
  public com.google.protobuf.Any getInternalExperiments() {
    return internalExperiments_ == null
        ? com.google.protobuf.Any.getDefaultInstance()
        : internalExperiments_;
  }
  /**
   *
   *
   * <pre>
   * Experimental settings.
   * </pre>
   *
   * <code>.google.protobuf.Any internal_experiments = 9;</code>
   */
  @java.lang.Override
  public com.google.protobuf.AnyOrBuilder getInternalExperimentsOrBuilder() {
    return internalExperiments_ == null
        ? com.google.protobuf.Any.getDefaultInstance()
        : internalExperiments_;
  }

  public static final int SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER = 10;

  @SuppressWarnings("serial")
  private volatile java.lang.Object serviceAccountEmail_ = "";
  /**
   *
   *
   * <pre>
   * Identity to run virtual machines as. Defaults to the default account.
   * </pre>
   *
   * <code>string service_account_email = 10;</code>
   *
   * @return The serviceAccountEmail.
   */
  @java.lang.Override
  public java.lang.String getServiceAccountEmail() {
    java.lang.Object ref = serviceAccountEmail_;
    if (ref instanceof java.lang.String) {
      return (java.lang.String) ref;
    } else {
      com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
      java.lang.String s = bs.toStringUtf8();
      serviceAccountEmail_ = s;
      return s;
    }
  }
  /**
   *
   *
   * <pre>
   * Identity to run virtual machines as. Defaults to the default account.
   * </pre>
   *
   * <code>string service_account_email = 10;</code>
   *
   * @return The bytes for serviceAccountEmail.
   */
  @java.lang.Override
  public com.google.protobuf.ByteString getServiceAccountEmailBytes() {
    java.lang.Object ref = serviceAccountEmail_;
    if (ref instanceof java.lang.String) {
      com.google.protobuf.ByteString b =
          com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
      serviceAccountEmail_ = b;
      return b;
    } else {
      return (com.google.protobuf.ByteString) ref;
    }
  }

  public static final int FLEX_RESOURCE_SCHEDULING_GOAL_FIELD_NUMBER = 11;
  private int flexResourceSchedulingGoal_ = 0;
  /**
   *
   *
   * <pre>
   * Which Flexible Resource Scheduling mode to run in.
   * </pre>
   *
   * <code>.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;
   * </code>
   *
   * @return The enum numeric value on the wire for flexResourceSchedulingGoal.
   */
  @java.lang.Override
  public int getFlexResourceSchedulingGoalValue() {
    return flexResourceSchedulingGoal_;
  }
  /**
   *
   *
   * <pre>
   * Which Flexible Resource Scheduling mode to run in.
   * </pre>
   *
   * <code>.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;
   * </code>
   *
   * @return The flexResourceSchedulingGoal.
   */
  @java.lang.Override
  public com.google.dataflow.v1beta3.FlexResourceSchedulingGoal getFlexResourceSchedulingGoal() {
    com.google.dataflow.v1beta3.FlexResourceSchedulingGoal result =
        com.google.dataflow.v1beta3.FlexResourceSchedulingGoal.forNumber(
            flexResourceSchedulingGoal_);
    return result == null
        ? com.google.dataflow.v1beta3.FlexResourceSchedulingGoal.UNRECOGNIZED
        : result;
  }

  public static final int WORKER_REGION_FIELD_NUMBER = 13;

  @SuppressWarnings("serial")
  private volatile java.lang.Object workerRegion_ = "";
  /**
   *
   *
   * <pre>
   * 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.
   * </pre>
   *
   * <code>string worker_region = 13;</code>
   *
   * @return The workerRegion.
   */
  @java.lang.Override
  public java.lang.String getWorkerRegion() {
    java.lang.Object ref = workerRegion_;
    if (ref instanceof java.lang.String) {
      return (java.lang.String) ref;
    } else {
      com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
      java.lang.String s = bs.toStringUtf8();
      workerRegion_ = s;
      return s;
    }
  }
  /**
   *
   *
   * <pre>
   * 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.
   * </pre>
   *
   * <code>string worker_region = 13;</code>
   *
   * @return The bytes for workerRegion.
   */
  @java.lang.Override
  public com.google.protobuf.ByteString getWorkerRegionBytes() {
    java.lang.Object ref = workerRegion_;
    if (ref instanceof java.lang.String) {
      com.google.protobuf.ByteString b =
          com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
      workerRegion_ = b;
      return b;
    } else {
      return (com.google.protobuf.ByteString) ref;
    }
  }

  public static final int WORKER_ZONE_FIELD_NUMBER = 14;

  @SuppressWarnings("serial")
  private volatile java.lang.Object workerZone_ = "";
  /**
   *
   *
   * <pre>
   * 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.
   * </pre>
   *
   * <code>string worker_zone = 14;</code>
   *
   * @return The workerZone.
   */
  @java.lang.Override
  public java.lang.String getWorkerZone() {
    java.lang.Object ref = workerZone_;
    if (ref instanceof java.lang.String) {
      return (java.lang.String) ref;
    } else {
      com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
      java.lang.String s = bs.toStringUtf8();
      workerZone_ = s;
      return s;
    }
  }
  /**
   *
   *
   * <pre>
   * 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.
   * </pre>
   *
   * <code>string worker_zone = 14;</code>
   *
   * @return The bytes for workerZone.
   */
  @java.lang.Override
  public com.google.protobuf.ByteString getWorkerZoneBytes() {
    java.lang.Object ref = workerZone_;
    if (ref instanceof java.lang.String) {
      com.google.protobuf.ByteString b =
          com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
      workerZone_ = b;
      return b;
    } else {
      return (com.google.protobuf.ByteString) ref;
    }
  }

  public static final int SHUFFLE_MODE_FIELD_NUMBER = 15;
  private int shuffleMode_ = 0;
  /**
   *
   *
   * <pre>
   * Output only. The shuffle mode used for the job.
   * </pre>
   *
   * <code>
   * .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
   * </code>
   *
   * @return The enum numeric value on the wire for shuffleMode.
   */
  @java.lang.Override
  public int getShuffleModeValue() {
    return shuffleMode_;
  }
  /**
   *
   *
   * <pre>
   * Output only. The shuffle mode used for the job.
   * </pre>
   *
   * <code>
   * .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
   * </code>
   *
   * @return The shuffleMode.
   */
  @java.lang.Override
  public com.google.dataflow.v1beta3.ShuffleMode getShuffleMode() {
    com.google.dataflow.v1beta3.ShuffleMode result =
        com.google.dataflow.v1beta3.ShuffleMode.forNumber(shuffleMode_);
    return result == null ? com.google.dataflow.v1beta3.ShuffleMode.UNRECOGNIZED : result;
  }

  public static final int DEBUG_OPTIONS_FIELD_NUMBER = 17;
  private com.google.dataflow.v1beta3.DebugOptions debugOptions_;
  /**
   *
   *
   * <pre>
   * Any debugging options to be supplied to the job.
   * </pre>
   *
   * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
   *
   * @return Whether the debugOptions field is set.
   */
  @java.lang.Override
  public boolean hasDebugOptions() {
    return debugOptions_ != null;
  }
  /**
   *
   *
   * <pre>
   * Any debugging options to be supplied to the job.
   * </pre>
   *
   * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
   *
   * @return The debugOptions.
   */
  @java.lang.Override
  public com.google.dataflow.v1beta3.DebugOptions getDebugOptions() {
    return debugOptions_ == null
        ? com.google.dataflow.v1beta3.DebugOptions.getDefaultInstance()
        : debugOptions_;
  }
  /**
   *
   *
   * <pre>
   * Any debugging options to be supplied to the job.
   * </pre>
   *
   * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
   */
  @java.lang.Override
  public com.google.dataflow.v1beta3.DebugOptionsOrBuilder getDebugOptionsOrBuilder() {
    return debugOptions_ == null
        ? com.google.dataflow.v1beta3.DebugOptions.getDefaultInstance()
        : debugOptions_;
  }

  private byte memoizedIsInitialized = -1;

  @java.lang.Override
  public final boolean isInitialized() {
    byte isInitialized = memoizedIsInitialized;
    if (isInitialized == 1) return true;
    if (isInitialized == 0) return false;

    memoizedIsInitialized = 1;
    return true;
  }

  @java.lang.Override
  public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException {
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(tempStoragePrefix_)) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 1, tempStoragePrefix_);
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(clusterManagerApiService_)) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 2, clusterManagerApiService_);
    }
    for (int i = 0; i < experiments_.size(); i++) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 3, experiments_.getRaw(i));
    }
    for (int i = 0; i < workerPools_.size(); i++) {
      output.writeMessage(4, workerPools_.get(i));
    }
    if (userAgent_ != null) {
      output.writeMessage(5, getUserAgent());
    }
    if (version_ != null) {
      output.writeMessage(6, getVersion());
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(dataset_)) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 7, dataset_);
    }
    if (sdkPipelineOptions_ != null) {
      output.writeMessage(8, getSdkPipelineOptions());
    }
    if (internalExperiments_ != null) {
      output.writeMessage(9, getInternalExperiments());
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(serviceAccountEmail_)) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 10, serviceAccountEmail_);
    }
    if (flexResourceSchedulingGoal_
        != com.google.dataflow.v1beta3.FlexResourceSchedulingGoal.FLEXRS_UNSPECIFIED.getNumber()) {
      output.writeEnum(11, flexResourceSchedulingGoal_);
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(serviceKmsKeyName_)) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 12, serviceKmsKeyName_);
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(workerRegion_)) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 13, workerRegion_);
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(workerZone_)) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 14, workerZone_);
    }
    if (shuffleMode_
        != com.google.dataflow.v1beta3.ShuffleMode.SHUFFLE_MODE_UNSPECIFIED.getNumber()) {
      output.writeEnum(15, shuffleMode_);
    }
    for (int i = 0; i < serviceOptions_.size(); i++) {
      com.google.protobuf.GeneratedMessageV3.writeString(output, 16, serviceOptions_.getRaw(i));
    }
    if (debugOptions_ != null) {
      output.writeMessage(17, getDebugOptions());
    }
    getUnknownFields().writeTo(output);
  }

  @java.lang.Override
  public int getSerializedSize() {
    int size = memoizedSize;
    if (size != -1) return size;

    size = 0;
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(tempStoragePrefix_)) {
      size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, tempStoragePrefix_);
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(clusterManagerApiService_)) {
      size +=
          com.google.protobuf.GeneratedMessageV3.computeStringSize(2, clusterManagerApiService_);
    }
    {
      int dataSize = 0;
      for (int i = 0; i < experiments_.size(); i++) {
        dataSize += computeStringSizeNoTag(experiments_.getRaw(i));
      }
      size += dataSize;
      size += 1 * getExperimentsList().size();
    }
    for (int i = 0; i < workerPools_.size(); i++) {
      size += com.google.protobuf.CodedOutputStream.computeMessageSize(4, workerPools_.get(i));
    }
    if (userAgent_ != null) {
      size += com.google.protobuf.CodedOutputStream.computeMessageSize(5, getUserAgent());
    }
    if (version_ != null) {
      size += com.google.protobuf.CodedOutputStream.computeMessageSize(6, getVersion());
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(dataset_)) {
      size += com.google.protobuf.GeneratedMessageV3.computeStringSize(7, dataset_);
    }
    if (sdkPipelineOptions_ != null) {
      size += com.google.protobuf.CodedOutputStream.computeMessageSize(8, getSdkPipelineOptions());
    }
    if (internalExperiments_ != null) {
      size += com.google.protobuf.CodedOutputStream.computeMessageSize(9, getInternalExperiments());
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(serviceAccountEmail_)) {
      size += com.google.protobuf.GeneratedMessageV3.computeStringSize(10, serviceAccountEmail_);
    }
    if (flexResourceSchedulingGoal_
        != com.google.dataflow.v1beta3.FlexResourceSchedulingGoal.FLEXRS_UNSPECIFIED.getNumber()) {
      size +=
          com.google.protobuf.CodedOutputStream.computeEnumSize(11, flexResourceSchedulingGoal_);
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(serviceKmsKeyName_)) {
      size += com.google.protobuf.GeneratedMessageV3.computeStringSize(12, serviceKmsKeyName_);
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(workerRegion_)) {
      size += com.google.protobuf.GeneratedMessageV3.computeStringSize(13, workerRegion_);
    }
    if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(workerZone_)) {
      size += com.google.protobuf.GeneratedMessageV3.computeStringSize(14, workerZone_);
    }
    if (shuffleMode_
        != com.google.dataflow.v1beta3.ShuffleMode.SHUFFLE_MODE_UNSPECIFIED.getNumber()) {
      size += com.google.protobuf.CodedOutputStream.computeEnumSize(15, shuffleMode_);
    }
    {
      int dataSize = 0;
      for (int i = 0; i < serviceOptions_.size(); i++) {
        dataSize += computeStringSizeNoTag(serviceOptions_.getRaw(i));
      }
      size += dataSize;
      size += 2 * getServiceOptionsList().size();
    }
    if (debugOptions_ != null) {
      size += com.google.protobuf.CodedOutputStream.computeMessageSize(17, getDebugOptions());
    }
    size += getUnknownFields().getSerializedSize();
    memoizedSize = size;
    return size;
  }

  @java.lang.Override
  public boolean equals(final java.lang.Object obj) {
    if (obj == this) {
      return true;
    }
    if (!(obj instanceof com.google.dataflow.v1beta3.Environment)) {
      return super.equals(obj);
    }
    com.google.dataflow.v1beta3.Environment other = (com.google.dataflow.v1beta3.Environment) obj;

    if (!getTempStoragePrefix().equals(other.getTempStoragePrefix())) return false;
    if (!getClusterManagerApiService().equals(other.getClusterManagerApiService())) return false;
    if (!getExperimentsList().equals(other.getExperimentsList())) return false;
    if (!getServiceOptionsList().equals(other.getServiceOptionsList())) return false;
    if (!getServiceKmsKeyName().equals(other.getServiceKmsKeyName())) return false;
    if (!getWorkerPoolsList().equals(other.getWorkerPoolsList())) return false;
    if (hasUserAgent() != other.hasUserAgent()) return false;
    if (hasUserAgent()) {
      if (!getUserAgent().equals(other.getUserAgent())) return false;
    }
    if (hasVersion() != other.hasVersion()) return false;
    if (hasVersion()) {
      if (!getVersion().equals(other.getVersion())) return false;
    }
    if (!getDataset().equals(other.getDataset())) return false;
    if (hasSdkPipelineOptions() != other.hasSdkPipelineOptions()) return false;
    if (hasSdkPipelineOptions()) {
      if (!getSdkPipelineOptions().equals(other.getSdkPipelineOptions())) return false;
    }
    if (hasInternalExperiments() != other.hasInternalExperiments()) return false;
    if (hasInternalExperiments()) {
      if (!getInternalExperiments().equals(other.getInternalExperiments())) return false;
    }
    if (!getServiceAccountEmail().equals(other.getServiceAccountEmail())) return false;
    if (flexResourceSchedulingGoal_ != other.flexResourceSchedulingGoal_) return false;
    if (!getWorkerRegion().equals(other.getWorkerRegion())) return false;
    if (!getWorkerZone().equals(other.getWorkerZone())) return false;
    if (shuffleMode_ != other.shuffleMode_) return false;
    if (hasDebugOptions() != other.hasDebugOptions()) return false;
    if (hasDebugOptions()) {
      if (!getDebugOptions().equals(other.getDebugOptions())) return false;
    }
    if (!getUnknownFields().equals(other.getUnknownFields())) return false;
    return true;
  }

  @java.lang.Override
  public int hashCode() {
    if (memoizedHashCode != 0) {
      return memoizedHashCode;
    }
    int hash = 41;
    hash = (19 * hash) + getDescriptor().hashCode();
    hash = (37 * hash) + TEMP_STORAGE_PREFIX_FIELD_NUMBER;
    hash = (53 * hash) + getTempStoragePrefix().hashCode();
    hash = (37 * hash) + CLUSTER_MANAGER_API_SERVICE_FIELD_NUMBER;
    hash = (53 * hash) + getClusterManagerApiService().hashCode();
    if (getExperimentsCount() > 0) {
      hash = (37 * hash) + EXPERIMENTS_FIELD_NUMBER;
      hash = (53 * hash) + getExperimentsList().hashCode();
    }
    if (getServiceOptionsCount() > 0) {
      hash = (37 * hash) + SERVICE_OPTIONS_FIELD_NUMBER;
      hash = (53 * hash) + getServiceOptionsList().hashCode();
    }
    hash = (37 * hash) + SERVICE_KMS_KEY_NAME_FIELD_NUMBER;
    hash = (53 * hash) + getServiceKmsKeyName().hashCode();
    if (getWorkerPoolsCount() > 0) {
      hash = (37 * hash) + WORKER_POOLS_FIELD_NUMBER;
      hash = (53 * hash) + getWorkerPoolsList().hashCode();
    }
    if (hasUserAgent()) {
      hash = (37 * hash) + USER_AGENT_FIELD_NUMBER;
      hash = (53 * hash) + getUserAgent().hashCode();
    }
    if (hasVersion()) {
      hash = (37 * hash) + VERSION_FIELD_NUMBER;
      hash = (53 * hash) + getVersion().hashCode();
    }
    hash = (37 * hash) + DATASET_FIELD_NUMBER;
    hash = (53 * hash) + getDataset().hashCode();
    if (hasSdkPipelineOptions()) {
      hash = (37 * hash) + SDK_PIPELINE_OPTIONS_FIELD_NUMBER;
      hash = (53 * hash) + getSdkPipelineOptions().hashCode();
    }
    if (hasInternalExperiments()) {
      hash = (37 * hash) + INTERNAL_EXPERIMENTS_FIELD_NUMBER;
      hash = (53 * hash) + getInternalExperiments().hashCode();
    }
    hash = (37 * hash) + SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER;
    hash = (53 * hash) + getServiceAccountEmail().hashCode();
    hash = (37 * hash) + FLEX_RESOURCE_SCHEDULING_GOAL_FIELD_NUMBER;
    hash = (53 * hash) + flexResourceSchedulingGoal_;
    hash = (37 * hash) + WORKER_REGION_FIELD_NUMBER;
    hash = (53 * hash) + getWorkerRegion().hashCode();
    hash = (37 * hash) + WORKER_ZONE_FIELD_NUMBER;
    hash = (53 * hash) + getWorkerZone().hashCode();
    hash = (37 * hash) + SHUFFLE_MODE_FIELD_NUMBER;
    hash = (53 * hash) + shuffleMode_;
    if (hasDebugOptions()) {
      hash = (37 * hash) + DEBUG_OPTIONS_FIELD_NUMBER;
      hash = (53 * hash) + getDebugOptions().hashCode();
    }
    hash = (29 * hash) + getUnknownFields().hashCode();
    memoizedHashCode = hash;
    return hash;
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(java.nio.ByteBuffer data)
      throws com.google.protobuf.InvalidProtocolBufferException {
    return PARSER.parseFrom(data);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(
      java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
      throws com.google.protobuf.InvalidProtocolBufferException {
    return PARSER.parseFrom(data, extensionRegistry);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(
      com.google.protobuf.ByteString data)
      throws com.google.protobuf.InvalidProtocolBufferException {
    return PARSER.parseFrom(data);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(
      com.google.protobuf.ByteString data,
      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
      throws com.google.protobuf.InvalidProtocolBufferException {
    return PARSER.parseFrom(data, extensionRegistry);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(byte[] data)
      throws com.google.protobuf.InvalidProtocolBufferException {
    return PARSER.parseFrom(data);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(
      byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
      throws com.google.protobuf.InvalidProtocolBufferException {
    return PARSER.parseFrom(data, extensionRegistry);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(java.io.InputStream input)
      throws java.io.IOException {
    return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(
      java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
      throws java.io.IOException {
    return com.google.protobuf.GeneratedMessageV3.parseWithIOException(
        PARSER, input, extensionRegistry);
  }

  public static com.google.dataflow.v1beta3.Environment parseDelimitedFrom(
      java.io.InputStream input) throws java.io.IOException {
    return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(PARSER, input);
  }

  public static com.google.dataflow.v1beta3.Environment parseDelimitedFrom(
      java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
      throws java.io.IOException {
    return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(
        PARSER, input, extensionRegistry);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(
      com.google.protobuf.CodedInputStream input) throws java.io.IOException {
    return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input);
  }

  public static com.google.dataflow.v1beta3.Environment parseFrom(
      com.google.protobuf.CodedInputStream input,
      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
      throws java.io.IOException {
    return com.google.protobuf.GeneratedMessageV3.parseWithIOException(
        PARSER, input, extensionRegistry);
  }

  @java.lang.Override
  public Builder newBuilderForType() {
    return newBuilder();
  }

  public static Builder newBuilder() {
    return DEFAULT_INSTANCE.toBuilder();
  }

  public static Builder newBuilder(com.google.dataflow.v1beta3.Environment prototype) {
    return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
  }

  @java.lang.Override
  public Builder toBuilder() {
    return this == DEFAULT_INSTANCE ? new Builder() : new Builder().mergeFrom(this);
  }

  @java.lang.Override
  protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
    Builder builder = new Builder(parent);
    return builder;
  }
  /**
   *
   *
   * <pre>
   * Describes the environment in which a Dataflow Job runs.
   * </pre>
   *
   * Protobuf type {@code google.dataflow.v1beta3.Environment}
   */
  public static final class Builder extends com.google.protobuf.GeneratedMessageV3.Builder<Builder>
      implements
      // @@protoc_insertion_point(builder_implements:google.dataflow.v1beta3.Environment)
      com.google.dataflow.v1beta3.EnvironmentOrBuilder {
    public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
      return com.google.dataflow.v1beta3.EnvironmentProto
          .internal_static_google_dataflow_v1beta3_Environment_descriptor;
    }

    @java.lang.Override
    protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internalGetFieldAccessorTable() {
      return com.google.dataflow.v1beta3.EnvironmentProto
          .internal_static_google_dataflow_v1beta3_Environment_fieldAccessorTable
          .ensureFieldAccessorsInitialized(
              com.google.dataflow.v1beta3.Environment.class,
              com.google.dataflow.v1beta3.Environment.Builder.class);
    }

    // Construct using com.google.dataflow.v1beta3.Environment.newBuilder()
    private Builder() {}

    private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
      super(parent);
    }

    @java.lang.Override
    public Builder clear() {
      super.clear();
      bitField0_ = 0;
      tempStoragePrefix_ = "";
      clusterManagerApiService_ = "";
      experiments_ = com.google.protobuf.LazyStringArrayList.EMPTY;
      bitField0_ = (bitField0_ & ~0x00000004);
      serviceOptions_ = com.google.protobuf.LazyStringArrayList.EMPTY;
      bitField0_ = (bitField0_ & ~0x00000008);
      serviceKmsKeyName_ = "";
      if (workerPoolsBuilder_ == null) {
        workerPools_ = java.util.Collections.emptyList();
      } else {
        workerPools_ = null;
        workerPoolsBuilder_.clear();
      }
      bitField0_ = (bitField0_ & ~0x00000020);
      userAgent_ = null;
      if (userAgentBuilder_ != null) {
        userAgentBuilder_.dispose();
        userAgentBuilder_ = null;
      }
      version_ = null;
      if (versionBuilder_ != null) {
        versionBuilder_.dispose();
        versionBuilder_ = null;
      }
      dataset_ = "";
      sdkPipelineOptions_ = null;
      if (sdkPipelineOptionsBuilder_ != null) {
        sdkPipelineOptionsBuilder_.dispose();
        sdkPipelineOptionsBuilder_ = null;
      }
      internalExperiments_ = null;
      if (internalExperimentsBuilder_ != null) {
        internalExperimentsBuilder_.dispose();
        internalExperimentsBuilder_ = null;
      }
      serviceAccountEmail_ = "";
      flexResourceSchedulingGoal_ = 0;
      workerRegion_ = "";
      workerZone_ = "";
      shuffleMode_ = 0;
      debugOptions_ = null;
      if (debugOptionsBuilder_ != null) {
        debugOptionsBuilder_.dispose();
        debugOptionsBuilder_ = null;
      }
      return this;
    }

    @java.lang.Override
    public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() {
      return com.google.dataflow.v1beta3.EnvironmentProto
          .internal_static_google_dataflow_v1beta3_Environment_descriptor;
    }

    @java.lang.Override
    public com.google.dataflow.v1beta3.Environment getDefaultInstanceForType() {
      return com.google.dataflow.v1beta3.Environment.getDefaultInstance();
    }

    @java.lang.Override
    public com.google.dataflow.v1beta3.Environment build() {
      com.google.dataflow.v1beta3.Environment result = buildPartial();
      if (!result.isInitialized()) {
        throw newUninitializedMessageException(result);
      }
      return result;
    }

    @java.lang.Override
    public com.google.dataflow.v1beta3.Environment buildPartial() {
      com.google.dataflow.v1beta3.Environment result =
          new com.google.dataflow.v1beta3.Environment(this);
      buildPartialRepeatedFields(result);
      if (bitField0_ != 0) {
        buildPartial0(result);
      }
      onBuilt();
      return result;
    }

    private void buildPartialRepeatedFields(com.google.dataflow.v1beta3.Environment result) {
      if (((bitField0_ & 0x00000004) != 0)) {
        experiments_ = experiments_.getUnmodifiableView();
        bitField0_ = (bitField0_ & ~0x00000004);
      }
      result.experiments_ = experiments_;
      if (((bitField0_ & 0x00000008) != 0)) {
        serviceOptions_ = serviceOptions_.getUnmodifiableView();
        bitField0_ = (bitField0_ & ~0x00000008);
      }
      result.serviceOptions_ = serviceOptions_;
      if (workerPoolsBuilder_ == null) {
        if (((bitField0_ & 0x00000020) != 0)) {
          workerPools_ = java.util.Collections.unmodifiableList(workerPools_);
          bitField0_ = (bitField0_ & ~0x00000020);
        }
        result.workerPools_ = workerPools_;
      } else {
        result.workerPools_ = workerPoolsBuilder_.build();
      }
    }

    private void buildPartial0(com.google.dataflow.v1beta3.Environment result) {
      int from_bitField0_ = bitField0_;
      if (((from_bitField0_ & 0x00000001) != 0)) {
        result.tempStoragePrefix_ = tempStoragePrefix_;
      }
      if (((from_bitField0_ & 0x00000002) != 0)) {
        result.clusterManagerApiService_ = clusterManagerApiService_;
      }
      if (((from_bitField0_ & 0x00000010) != 0)) {
        result.serviceKmsKeyName_ = serviceKmsKeyName_;
      }
      if (((from_bitField0_ & 0x00000040) != 0)) {
        result.userAgent_ = userAgentBuilder_ == null ? userAgent_ : userAgentBuilder_.build();
      }
      if (((from_bitField0_ & 0x00000080) != 0)) {
        result.version_ = versionBuilder_ == null ? version_ : versionBuilder_.build();
      }
      if (((from_bitField0_ & 0x00000100) != 0)) {
        result.dataset_ = dataset_;
      }
      if (((from_bitField0_ & 0x00000200) != 0)) {
        result.sdkPipelineOptions_ =
            sdkPipelineOptionsBuilder_ == null
                ? sdkPipelineOptions_
                : sdkPipelineOptionsBuilder_.build();
      }
      if (((from_bitField0_ & 0x00000400) != 0)) {
        result.internalExperiments_ =
            internalExperimentsBuilder_ == null
                ? internalExperiments_
                : internalExperimentsBuilder_.build();
      }
      if (((from_bitField0_ & 0x00000800) != 0)) {
        result.serviceAccountEmail_ = serviceAccountEmail_;
      }
      if (((from_bitField0_ & 0x00001000) != 0)) {
        result.flexResourceSchedulingGoal_ = flexResourceSchedulingGoal_;
      }
      if (((from_bitField0_ & 0x00002000) != 0)) {
        result.workerRegion_ = workerRegion_;
      }
      if (((from_bitField0_ & 0x00004000) != 0)) {
        result.workerZone_ = workerZone_;
      }
      if (((from_bitField0_ & 0x00008000) != 0)) {
        result.shuffleMode_ = shuffleMode_;
      }
      if (((from_bitField0_ & 0x00010000) != 0)) {
        result.debugOptions_ =
            debugOptionsBuilder_ == null ? debugOptions_ : debugOptionsBuilder_.build();
      }
    }

    @java.lang.Override
    public Builder clone() {
      return super.clone();
    }

    @java.lang.Override
    public Builder setField(
        com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
      return super.setField(field, value);
    }

    @java.lang.Override
    public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
      return super.clearField(field);
    }

    @java.lang.Override
    public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
      return super.clearOneof(oneof);
    }

    @java.lang.Override
    public Builder setRepeatedField(
        com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
      return super.setRepeatedField(field, index, value);
    }

    @java.lang.Override
    public Builder addRepeatedField(
        com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
      return super.addRepeatedField(field, value);
    }

    @java.lang.Override
    public Builder mergeFrom(com.google.protobuf.Message other) {
      if (other instanceof com.google.dataflow.v1beta3.Environment) {
        return mergeFrom((com.google.dataflow.v1beta3.Environment) other);
      } else {
        super.mergeFrom(other);
        return this;
      }
    }

    public Builder mergeFrom(com.google.dataflow.v1beta3.Environment other) {
      if (other == com.google.dataflow.v1beta3.Environment.getDefaultInstance()) return this;
      if (!other.getTempStoragePrefix().isEmpty()) {
        tempStoragePrefix_ = other.tempStoragePrefix_;
        bitField0_ |= 0x00000001;
        onChanged();
      }
      if (!other.getClusterManagerApiService().isEmpty()) {
        clusterManagerApiService_ = other.clusterManagerApiService_;
        bitField0_ |= 0x00000002;
        onChanged();
      }
      if (!other.experiments_.isEmpty()) {
        if (experiments_.isEmpty()) {
          experiments_ = other.experiments_;
          bitField0_ = (bitField0_ & ~0x00000004);
        } else {
          ensureExperimentsIsMutable();
          experiments_.addAll(other.experiments_);
        }
        onChanged();
      }
      if (!other.serviceOptions_.isEmpty()) {
        if (serviceOptions_.isEmpty()) {
          serviceOptions_ = other.serviceOptions_;
          bitField0_ = (bitField0_ & ~0x00000008);
        } else {
          ensureServiceOptionsIsMutable();
          serviceOptions_.addAll(other.serviceOptions_);
        }
        onChanged();
      }
      if (!other.getServiceKmsKeyName().isEmpty()) {
        serviceKmsKeyName_ = other.serviceKmsKeyName_;
        bitField0_ |= 0x00000010;
        onChanged();
      }
      if (workerPoolsBuilder_ == null) {
        if (!other.workerPools_.isEmpty()) {
          if (workerPools_.isEmpty()) {
            workerPools_ = other.workerPools_;
            bitField0_ = (bitField0_ & ~0x00000020);
          } else {
            ensureWorkerPoolsIsMutable();
            workerPools_.addAll(other.workerPools_);
          }
          onChanged();
        }
      } else {
        if (!other.workerPools_.isEmpty()) {
          if (workerPoolsBuilder_.isEmpty()) {
            workerPoolsBuilder_.dispose();
            workerPoolsBuilder_ = null;
            workerPools_ = other.workerPools_;
            bitField0_ = (bitField0_ & ~0x00000020);
            workerPoolsBuilder_ =
                com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders
                    ? getWorkerPoolsFieldBuilder()
                    : null;
          } else {
            workerPoolsBuilder_.addAllMessages(other.workerPools_);
          }
        }
      }
      if (other.hasUserAgent()) {
        mergeUserAgent(other.getUserAgent());
      }
      if (other.hasVersion()) {
        mergeVersion(other.getVersion());
      }
      if (!other.getDataset().isEmpty()) {
        dataset_ = other.dataset_;
        bitField0_ |= 0x00000100;
        onChanged();
      }
      if (other.hasSdkPipelineOptions()) {
        mergeSdkPipelineOptions(other.getSdkPipelineOptions());
      }
      if (other.hasInternalExperiments()) {
        mergeInternalExperiments(other.getInternalExperiments());
      }
      if (!other.getServiceAccountEmail().isEmpty()) {
        serviceAccountEmail_ = other.serviceAccountEmail_;
        bitField0_ |= 0x00000800;
        onChanged();
      }
      if (other.flexResourceSchedulingGoal_ != 0) {
        setFlexResourceSchedulingGoalValue(other.getFlexResourceSchedulingGoalValue());
      }
      if (!other.getWorkerRegion().isEmpty()) {
        workerRegion_ = other.workerRegion_;
        bitField0_ |= 0x00002000;
        onChanged();
      }
      if (!other.getWorkerZone().isEmpty()) {
        workerZone_ = other.workerZone_;
        bitField0_ |= 0x00004000;
        onChanged();
      }
      if (other.shuffleMode_ != 0) {
        setShuffleModeValue(other.getShuffleModeValue());
      }
      if (other.hasDebugOptions()) {
        mergeDebugOptions(other.getDebugOptions());
      }
      this.mergeUnknownFields(other.getUnknownFields());
      onChanged();
      return this;
    }

    @java.lang.Override
    public final boolean isInitialized() {
      return true;
    }

    @java.lang.Override
    public Builder mergeFrom(
        com.google.protobuf.CodedInputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      if (extensionRegistry == null) {
        throw new java.lang.NullPointerException();
      }
      try {
        boolean done = false;
        while (!done) {
          int tag = input.readTag();
          switch (tag) {
            case 0:
              done = true;
              break;
            case 10:
              {
                tempStoragePrefix_ = input.readStringRequireUtf8();
                bitField0_ |= 0x00000001;
                break;
              } // case 10
            case 18:
              {
                clusterManagerApiService_ = input.readStringRequireUtf8();
                bitField0_ |= 0x00000002;
                break;
              } // case 18
            case 26:
              {
                java.lang.String s = input.readStringRequireUtf8();
                ensureExperimentsIsMutable();
                experiments_.add(s);
                break;
              } // case 26
            case 34:
              {
                com.google.dataflow.v1beta3.WorkerPool m =
                    input.readMessage(
                        com.google.dataflow.v1beta3.WorkerPool.parser(), extensionRegistry);
                if (workerPoolsBuilder_ == null) {
                  ensureWorkerPoolsIsMutable();
                  workerPools_.add(m);
                } else {
                  workerPoolsBuilder_.addMessage(m);
                }
                break;
              } // case 34
            case 42:
              {
                input.readMessage(getUserAgentFieldBuilder().getBuilder(), extensionRegistry);
                bitField0_ |= 0x00000040;
                break;
              } // case 42
            case 50:
              {
                input.readMessage(getVersionFieldBuilder().getBuilder(), extensionRegistry);
                bitField0_ |= 0x00000080;
                break;
              } // case 50
            case 58:
              {
                dataset_ = input.readStringRequireUtf8();
                bitField0_ |= 0x00000100;
                break;
              } // case 58
            case 66:
              {
                input.readMessage(
                    getSdkPipelineOptionsFieldBuilder().getBuilder(), extensionRegistry);
                bitField0_ |= 0x00000200;
                break;
              } // case 66
            case 74:
              {
                input.readMessage(
                    getInternalExperimentsFieldBuilder().getBuilder(), extensionRegistry);
                bitField0_ |= 0x00000400;
                break;
              } // case 74
            case 82:
              {
                serviceAccountEmail_ = input.readStringRequireUtf8();
                bitField0_ |= 0x00000800;
                break;
              } // case 82
            case 88:
              {
                flexResourceSchedulingGoal_ = input.readEnum();
                bitField0_ |= 0x00001000;
                break;
              } // case 88
            case 98:
              {
                serviceKmsKeyName_ = input.readStringRequireUtf8();
                bitField0_ |= 0x00000010;
                break;
              } // case 98
            case 106:
              {
                workerRegion_ = input.readStringRequireUtf8();
                bitField0_ |= 0x00002000;
                break;
              } // case 106
            case 114:
              {
                workerZone_ = input.readStringRequireUtf8();
                bitField0_ |= 0x00004000;
                break;
              } // case 114
            case 120:
              {
                shuffleMode_ = input.readEnum();
                bitField0_ |= 0x00008000;
                break;
              } // case 120
            case 130:
              {
                java.lang.String s = input.readStringRequireUtf8();
                ensureServiceOptionsIsMutable();
                serviceOptions_.add(s);
                break;
              } // case 130
            case 138:
              {
                input.readMessage(getDebugOptionsFieldBuilder().getBuilder(), extensionRegistry);
                bitField0_ |= 0x00010000;
                break;
              } // case 138
            default:
              {
                if (!super.parseUnknownField(input, extensionRegistry, tag)) {
                  done = true; // was an endgroup tag
                }
                break;
              } // default:
          } // switch (tag)
        } // while (!done)
      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
        throw e.unwrapIOException();
      } finally {
        onChanged();
      } // finally
      return this;
    }

    private int bitField0_;

    private java.lang.Object tempStoragePrefix_ = "";
    /**
     *
     *
     * <pre>
     * The prefix of the resources the system should use for temporary
     * storage.  The system will append the suffix "/temp-{JOBNAME} to
     * this resource prefix, where {JOBNAME} is the value of the
     * job_name field.  The resulting bucket and object prefix is used
     * as the prefix of the resources used to store temporary data
     * needed during the job execution.  NOTE: This will override the
     * value in taskrunner_settings.
     * The supported resource type is:
     * Google Cloud Storage:
     *   storage.googleapis.com/{bucket}/{object}
     *   bucket.storage.googleapis.com/{object}
     * </pre>
     *
     * <code>string temp_storage_prefix = 1;</code>
     *
     * @return The tempStoragePrefix.
     */
    public java.lang.String getTempStoragePrefix() {
      java.lang.Object ref = tempStoragePrefix_;
      if (!(ref instanceof java.lang.String)) {
        com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
        java.lang.String s = bs.toStringUtf8();
        tempStoragePrefix_ = s;
        return s;
      } else {
        return (java.lang.String) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * The prefix of the resources the system should use for temporary
     * storage.  The system will append the suffix "/temp-{JOBNAME} to
     * this resource prefix, where {JOBNAME} is the value of the
     * job_name field.  The resulting bucket and object prefix is used
     * as the prefix of the resources used to store temporary data
     * needed during the job execution.  NOTE: This will override the
     * value in taskrunner_settings.
     * The supported resource type is:
     * Google Cloud Storage:
     *   storage.googleapis.com/{bucket}/{object}
     *   bucket.storage.googleapis.com/{object}
     * </pre>
     *
     * <code>string temp_storage_prefix = 1;</code>
     *
     * @return The bytes for tempStoragePrefix.
     */
    public com.google.protobuf.ByteString getTempStoragePrefixBytes() {
      java.lang.Object ref = tempStoragePrefix_;
      if (ref instanceof String) {
        com.google.protobuf.ByteString b =
            com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
        tempStoragePrefix_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * The prefix of the resources the system should use for temporary
     * storage.  The system will append the suffix "/temp-{JOBNAME} to
     * this resource prefix, where {JOBNAME} is the value of the
     * job_name field.  The resulting bucket and object prefix is used
     * as the prefix of the resources used to store temporary data
     * needed during the job execution.  NOTE: This will override the
     * value in taskrunner_settings.
     * The supported resource type is:
     * Google Cloud Storage:
     *   storage.googleapis.com/{bucket}/{object}
     *   bucket.storage.googleapis.com/{object}
     * </pre>
     *
     * <code>string temp_storage_prefix = 1;</code>
     *
     * @param value The tempStoragePrefix to set.
     * @return This builder for chaining.
     */
    public Builder setTempStoragePrefix(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      tempStoragePrefix_ = value;
      bitField0_ |= 0x00000001;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The prefix of the resources the system should use for temporary
     * storage.  The system will append the suffix "/temp-{JOBNAME} to
     * this resource prefix, where {JOBNAME} is the value of the
     * job_name field.  The resulting bucket and object prefix is used
     * as the prefix of the resources used to store temporary data
     * needed during the job execution.  NOTE: This will override the
     * value in taskrunner_settings.
     * The supported resource type is:
     * Google Cloud Storage:
     *   storage.googleapis.com/{bucket}/{object}
     *   bucket.storage.googleapis.com/{object}
     * </pre>
     *
     * <code>string temp_storage_prefix = 1;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearTempStoragePrefix() {
      tempStoragePrefix_ = getDefaultInstance().getTempStoragePrefix();
      bitField0_ = (bitField0_ & ~0x00000001);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The prefix of the resources the system should use for temporary
     * storage.  The system will append the suffix "/temp-{JOBNAME} to
     * this resource prefix, where {JOBNAME} is the value of the
     * job_name field.  The resulting bucket and object prefix is used
     * as the prefix of the resources used to store temporary data
     * needed during the job execution.  NOTE: This will override the
     * value in taskrunner_settings.
     * The supported resource type is:
     * Google Cloud Storage:
     *   storage.googleapis.com/{bucket}/{object}
     *   bucket.storage.googleapis.com/{object}
     * </pre>
     *
     * <code>string temp_storage_prefix = 1;</code>
     *
     * @param value The bytes for tempStoragePrefix to set.
     * @return This builder for chaining.
     */
    public Builder setTempStoragePrefixBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      tempStoragePrefix_ = value;
      bitField0_ |= 0x00000001;
      onChanged();
      return this;
    }

    private java.lang.Object clusterManagerApiService_ = "";
    /**
     *
     *
     * <pre>
     * The type of cluster manager API to use.  If unknown or
     * unspecified, the service will attempt to choose a reasonable
     * default.  This should be in the form of the API service name,
     * e.g. "compute.googleapis.com".
     * </pre>
     *
     * <code>string cluster_manager_api_service = 2;</code>
     *
     * @return The clusterManagerApiService.
     */
    public java.lang.String getClusterManagerApiService() {
      java.lang.Object ref = clusterManagerApiService_;
      if (!(ref instanceof java.lang.String)) {
        com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
        java.lang.String s = bs.toStringUtf8();
        clusterManagerApiService_ = s;
        return s;
      } else {
        return (java.lang.String) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * The type of cluster manager API to use.  If unknown or
     * unspecified, the service will attempt to choose a reasonable
     * default.  This should be in the form of the API service name,
     * e.g. "compute.googleapis.com".
     * </pre>
     *
     * <code>string cluster_manager_api_service = 2;</code>
     *
     * @return The bytes for clusterManagerApiService.
     */
    public com.google.protobuf.ByteString getClusterManagerApiServiceBytes() {
      java.lang.Object ref = clusterManagerApiService_;
      if (ref instanceof String) {
        com.google.protobuf.ByteString b =
            com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
        clusterManagerApiService_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * The type of cluster manager API to use.  If unknown or
     * unspecified, the service will attempt to choose a reasonable
     * default.  This should be in the form of the API service name,
     * e.g. "compute.googleapis.com".
     * </pre>
     *
     * <code>string cluster_manager_api_service = 2;</code>
     *
     * @param value The clusterManagerApiService to set.
     * @return This builder for chaining.
     */
    public Builder setClusterManagerApiService(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      clusterManagerApiService_ = value;
      bitField0_ |= 0x00000002;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The type of cluster manager API to use.  If unknown or
     * unspecified, the service will attempt to choose a reasonable
     * default.  This should be in the form of the API service name,
     * e.g. "compute.googleapis.com".
     * </pre>
     *
     * <code>string cluster_manager_api_service = 2;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearClusterManagerApiService() {
      clusterManagerApiService_ = getDefaultInstance().getClusterManagerApiService();
      bitField0_ = (bitField0_ & ~0x00000002);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The type of cluster manager API to use.  If unknown or
     * unspecified, the service will attempt to choose a reasonable
     * default.  This should be in the form of the API service name,
     * e.g. "compute.googleapis.com".
     * </pre>
     *
     * <code>string cluster_manager_api_service = 2;</code>
     *
     * @param value The bytes for clusterManagerApiService to set.
     * @return This builder for chaining.
     */
    public Builder setClusterManagerApiServiceBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      clusterManagerApiService_ = value;
      bitField0_ |= 0x00000002;
      onChanged();
      return this;
    }

    private com.google.protobuf.LazyStringList experiments_ =
        com.google.protobuf.LazyStringArrayList.EMPTY;

    private void ensureExperimentsIsMutable() {
      if (!((bitField0_ & 0x00000004) != 0)) {
        experiments_ = new com.google.protobuf.LazyStringArrayList(experiments_);
        bitField0_ |= 0x00000004;
      }
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @return A list containing the experiments.
     */
    public com.google.protobuf.ProtocolStringList getExperimentsList() {
      return experiments_.getUnmodifiableView();
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @return The count of experiments.
     */
    public int getExperimentsCount() {
      return experiments_.size();
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @param index The index of the element to return.
     * @return The experiments at the given index.
     */
    public java.lang.String getExperiments(int index) {
      return experiments_.get(index);
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @param index The index of the value to return.
     * @return The bytes of the experiments at the given index.
     */
    public com.google.protobuf.ByteString getExperimentsBytes(int index) {
      return experiments_.getByteString(index);
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @param index The index to set the value at.
     * @param value The experiments to set.
     * @return This builder for chaining.
     */
    public Builder setExperiments(int index, java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      ensureExperimentsIsMutable();
      experiments_.set(index, value);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @param value The experiments to add.
     * @return This builder for chaining.
     */
    public Builder addExperiments(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      ensureExperimentsIsMutable();
      experiments_.add(value);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @param values The experiments to add.
     * @return This builder for chaining.
     */
    public Builder addAllExperiments(java.lang.Iterable<java.lang.String> values) {
      ensureExperimentsIsMutable();
      com.google.protobuf.AbstractMessageLite.Builder.addAll(values, experiments_);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearExperiments() {
      experiments_ = com.google.protobuf.LazyStringArrayList.EMPTY;
      bitField0_ = (bitField0_ & ~0x00000004);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The list of experiments to enable. This field should be used for SDK
     * related experiments and not for service related experiments. The proper
     * field for service related experiments is service_options.
     * </pre>
     *
     * <code>repeated string experiments = 3;</code>
     *
     * @param value The bytes of the experiments to add.
     * @return This builder for chaining.
     */
    public Builder addExperimentsBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      ensureExperimentsIsMutable();
      experiments_.add(value);
      onChanged();
      return this;
    }

    private com.google.protobuf.LazyStringList serviceOptions_ =
        com.google.protobuf.LazyStringArrayList.EMPTY;

    private void ensureServiceOptionsIsMutable() {
      if (!((bitField0_ & 0x00000008) != 0)) {
        serviceOptions_ = new com.google.protobuf.LazyStringArrayList(serviceOptions_);
        bitField0_ |= 0x00000008;
      }
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @return A list containing the serviceOptions.
     */
    public com.google.protobuf.ProtocolStringList getServiceOptionsList() {
      return serviceOptions_.getUnmodifiableView();
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @return The count of serviceOptions.
     */
    public int getServiceOptionsCount() {
      return serviceOptions_.size();
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @param index The index of the element to return.
     * @return The serviceOptions at the given index.
     */
    public java.lang.String getServiceOptions(int index) {
      return serviceOptions_.get(index);
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @param index The index of the value to return.
     * @return The bytes of the serviceOptions at the given index.
     */
    public com.google.protobuf.ByteString getServiceOptionsBytes(int index) {
      return serviceOptions_.getByteString(index);
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @param index The index to set the value at.
     * @param value The serviceOptions to set.
     * @return This builder for chaining.
     */
    public Builder setServiceOptions(int index, java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      ensureServiceOptionsIsMutable();
      serviceOptions_.set(index, value);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @param value The serviceOptions to add.
     * @return This builder for chaining.
     */
    public Builder addServiceOptions(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      ensureServiceOptionsIsMutable();
      serviceOptions_.add(value);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @param values The serviceOptions to add.
     * @return This builder for chaining.
     */
    public Builder addAllServiceOptions(java.lang.Iterable<java.lang.String> values) {
      ensureServiceOptionsIsMutable();
      com.google.protobuf.AbstractMessageLite.Builder.addAll(values, serviceOptions_);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearServiceOptions() {
      serviceOptions_ = com.google.protobuf.LazyStringArrayList.EMPTY;
      bitField0_ = (bitField0_ & ~0x00000008);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The list of service options to enable. This field should be used for
     * service related experiments only. These experiments, when graduating to GA,
     * should be replaced by dedicated fields or become default (i.e. always on).
     * </pre>
     *
     * <code>repeated string service_options = 16;</code>
     *
     * @param value The bytes of the serviceOptions to add.
     * @return This builder for chaining.
     */
    public Builder addServiceOptionsBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      ensureServiceOptionsIsMutable();
      serviceOptions_.add(value);
      onChanged();
      return this;
    }

    private java.lang.Object serviceKmsKeyName_ = "";
    /**
     *
     *
     * <pre>
     * If set, contains the Cloud KMS key identifier used to encrypt data
     * at rest, AKA a Customer Managed Encryption Key (CMEK).
     * Format:
     *   projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
     * </pre>
     *
     * <code>string service_kms_key_name = 12;</code>
     *
     * @return The serviceKmsKeyName.
     */
    public java.lang.String getServiceKmsKeyName() {
      java.lang.Object ref = serviceKmsKeyName_;
      if (!(ref instanceof java.lang.String)) {
        com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
        java.lang.String s = bs.toStringUtf8();
        serviceKmsKeyName_ = s;
        return s;
      } else {
        return (java.lang.String) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * If set, contains the Cloud KMS key identifier used to encrypt data
     * at rest, AKA a Customer Managed Encryption Key (CMEK).
     * Format:
     *   projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
     * </pre>
     *
     * <code>string service_kms_key_name = 12;</code>
     *
     * @return The bytes for serviceKmsKeyName.
     */
    public com.google.protobuf.ByteString getServiceKmsKeyNameBytes() {
      java.lang.Object ref = serviceKmsKeyName_;
      if (ref instanceof String) {
        com.google.protobuf.ByteString b =
            com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
        serviceKmsKeyName_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * If set, contains the Cloud KMS key identifier used to encrypt data
     * at rest, AKA a Customer Managed Encryption Key (CMEK).
     * Format:
     *   projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
     * </pre>
     *
     * <code>string service_kms_key_name = 12;</code>
     *
     * @param value The serviceKmsKeyName to set.
     * @return This builder for chaining.
     */
    public Builder setServiceKmsKeyName(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      serviceKmsKeyName_ = value;
      bitField0_ |= 0x00000010;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * If set, contains the Cloud KMS key identifier used to encrypt data
     * at rest, AKA a Customer Managed Encryption Key (CMEK).
     * Format:
     *   projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
     * </pre>
     *
     * <code>string service_kms_key_name = 12;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearServiceKmsKeyName() {
      serviceKmsKeyName_ = getDefaultInstance().getServiceKmsKeyName();
      bitField0_ = (bitField0_ & ~0x00000010);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * If set, contains the Cloud KMS key identifier used to encrypt data
     * at rest, AKA a Customer Managed Encryption Key (CMEK).
     * Format:
     *   projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
     * </pre>
     *
     * <code>string service_kms_key_name = 12;</code>
     *
     * @param value The bytes for serviceKmsKeyName to set.
     * @return This builder for chaining.
     */
    public Builder setServiceKmsKeyNameBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      serviceKmsKeyName_ = value;
      bitField0_ |= 0x00000010;
      onChanged();
      return this;
    }

    private java.util.List<com.google.dataflow.v1beta3.WorkerPool> workerPools_ =
        java.util.Collections.emptyList();

    private void ensureWorkerPoolsIsMutable() {
      if (!((bitField0_ & 0x00000020) != 0)) {
        workerPools_ =
            new java.util.ArrayList<com.google.dataflow.v1beta3.WorkerPool>(workerPools_);
        bitField0_ |= 0x00000020;
      }
    }

    private com.google.protobuf.RepeatedFieldBuilderV3<
            com.google.dataflow.v1beta3.WorkerPool,
            com.google.dataflow.v1beta3.WorkerPool.Builder,
            com.google.dataflow.v1beta3.WorkerPoolOrBuilder>
        workerPoolsBuilder_;

    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public java.util.List<com.google.dataflow.v1beta3.WorkerPool> getWorkerPoolsList() {
      if (workerPoolsBuilder_ == null) {
        return java.util.Collections.unmodifiableList(workerPools_);
      } else {
        return workerPoolsBuilder_.getMessageList();
      }
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public int getWorkerPoolsCount() {
      if (workerPoolsBuilder_ == null) {
        return workerPools_.size();
      } else {
        return workerPoolsBuilder_.getCount();
      }
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public com.google.dataflow.v1beta3.WorkerPool getWorkerPools(int index) {
      if (workerPoolsBuilder_ == null) {
        return workerPools_.get(index);
      } else {
        return workerPoolsBuilder_.getMessage(index);
      }
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder setWorkerPools(int index, com.google.dataflow.v1beta3.WorkerPool value) {
      if (workerPoolsBuilder_ == null) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureWorkerPoolsIsMutable();
        workerPools_.set(index, value);
        onChanged();
      } else {
        workerPoolsBuilder_.setMessage(index, value);
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder setWorkerPools(
        int index, com.google.dataflow.v1beta3.WorkerPool.Builder builderForValue) {
      if (workerPoolsBuilder_ == null) {
        ensureWorkerPoolsIsMutable();
        workerPools_.set(index, builderForValue.build());
        onChanged();
      } else {
        workerPoolsBuilder_.setMessage(index, builderForValue.build());
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder addWorkerPools(com.google.dataflow.v1beta3.WorkerPool value) {
      if (workerPoolsBuilder_ == null) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureWorkerPoolsIsMutable();
        workerPools_.add(value);
        onChanged();
      } else {
        workerPoolsBuilder_.addMessage(value);
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder addWorkerPools(int index, com.google.dataflow.v1beta3.WorkerPool value) {
      if (workerPoolsBuilder_ == null) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureWorkerPoolsIsMutable();
        workerPools_.add(index, value);
        onChanged();
      } else {
        workerPoolsBuilder_.addMessage(index, value);
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder addWorkerPools(com.google.dataflow.v1beta3.WorkerPool.Builder builderForValue) {
      if (workerPoolsBuilder_ == null) {
        ensureWorkerPoolsIsMutable();
        workerPools_.add(builderForValue.build());
        onChanged();
      } else {
        workerPoolsBuilder_.addMessage(builderForValue.build());
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder addWorkerPools(
        int index, com.google.dataflow.v1beta3.WorkerPool.Builder builderForValue) {
      if (workerPoolsBuilder_ == null) {
        ensureWorkerPoolsIsMutable();
        workerPools_.add(index, builderForValue.build());
        onChanged();
      } else {
        workerPoolsBuilder_.addMessage(index, builderForValue.build());
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder addAllWorkerPools(
        java.lang.Iterable<? extends com.google.dataflow.v1beta3.WorkerPool> values) {
      if (workerPoolsBuilder_ == null) {
        ensureWorkerPoolsIsMutable();
        com.google.protobuf.AbstractMessageLite.Builder.addAll(values, workerPools_);
        onChanged();
      } else {
        workerPoolsBuilder_.addAllMessages(values);
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder clearWorkerPools() {
      if (workerPoolsBuilder_ == null) {
        workerPools_ = java.util.Collections.emptyList();
        bitField0_ = (bitField0_ & ~0x00000020);
        onChanged();
      } else {
        workerPoolsBuilder_.clear();
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public Builder removeWorkerPools(int index) {
      if (workerPoolsBuilder_ == null) {
        ensureWorkerPoolsIsMutable();
        workerPools_.remove(index);
        onChanged();
      } else {
        workerPoolsBuilder_.remove(index);
      }
      return this;
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public com.google.dataflow.v1beta3.WorkerPool.Builder getWorkerPoolsBuilder(int index) {
      return getWorkerPoolsFieldBuilder().getBuilder(index);
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public com.google.dataflow.v1beta3.WorkerPoolOrBuilder getWorkerPoolsOrBuilder(int index) {
      if (workerPoolsBuilder_ == null) {
        return workerPools_.get(index);
      } else {
        return workerPoolsBuilder_.getMessageOrBuilder(index);
      }
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public java.util.List<? extends com.google.dataflow.v1beta3.WorkerPoolOrBuilder>
        getWorkerPoolsOrBuilderList() {
      if (workerPoolsBuilder_ != null) {
        return workerPoolsBuilder_.getMessageOrBuilderList();
      } else {
        return java.util.Collections.unmodifiableList(workerPools_);
      }
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public com.google.dataflow.v1beta3.WorkerPool.Builder addWorkerPoolsBuilder() {
      return getWorkerPoolsFieldBuilder()
          .addBuilder(com.google.dataflow.v1beta3.WorkerPool.getDefaultInstance());
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public com.google.dataflow.v1beta3.WorkerPool.Builder addWorkerPoolsBuilder(int index) {
      return getWorkerPoolsFieldBuilder()
          .addBuilder(index, com.google.dataflow.v1beta3.WorkerPool.getDefaultInstance());
    }
    /**
     *
     *
     * <pre>
     * The worker pools. At least one "harness" worker pool must be
     * specified in order for the job to have workers.
     * </pre>
     *
     * <code>repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;</code>
     */
    public java.util.List<com.google.dataflow.v1beta3.WorkerPool.Builder>
        getWorkerPoolsBuilderList() {
      return getWorkerPoolsFieldBuilder().getBuilderList();
    }

    private com.google.protobuf.RepeatedFieldBuilderV3<
            com.google.dataflow.v1beta3.WorkerPool,
            com.google.dataflow.v1beta3.WorkerPool.Builder,
            com.google.dataflow.v1beta3.WorkerPoolOrBuilder>
        getWorkerPoolsFieldBuilder() {
      if (workerPoolsBuilder_ == null) {
        workerPoolsBuilder_ =
            new com.google.protobuf.RepeatedFieldBuilderV3<
                com.google.dataflow.v1beta3.WorkerPool,
                com.google.dataflow.v1beta3.WorkerPool.Builder,
                com.google.dataflow.v1beta3.WorkerPoolOrBuilder>(
                workerPools_, ((bitField0_ & 0x00000020) != 0), getParentForChildren(), isClean());
        workerPools_ = null;
      }
      return workerPoolsBuilder_;
    }

    private com.google.protobuf.Struct userAgent_;
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.protobuf.Struct,
            com.google.protobuf.Struct.Builder,
            com.google.protobuf.StructOrBuilder>
        userAgentBuilder_;
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     *
     * @return Whether the userAgent field is set.
     */
    public boolean hasUserAgent() {
      return ((bitField0_ & 0x00000040) != 0);
    }
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     *
     * @return The userAgent.
     */
    public com.google.protobuf.Struct getUserAgent() {
      if (userAgentBuilder_ == null) {
        return userAgent_ == null ? com.google.protobuf.Struct.getDefaultInstance() : userAgent_;
      } else {
        return userAgentBuilder_.getMessage();
      }
    }
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     */
    public Builder setUserAgent(com.google.protobuf.Struct value) {
      if (userAgentBuilder_ == null) {
        if (value == null) {
          throw new NullPointerException();
        }
        userAgent_ = value;
      } else {
        userAgentBuilder_.setMessage(value);
      }
      bitField0_ |= 0x00000040;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     */
    public Builder setUserAgent(com.google.protobuf.Struct.Builder builderForValue) {
      if (userAgentBuilder_ == null) {
        userAgent_ = builderForValue.build();
      } else {
        userAgentBuilder_.setMessage(builderForValue.build());
      }
      bitField0_ |= 0x00000040;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     */
    public Builder mergeUserAgent(com.google.protobuf.Struct value) {
      if (userAgentBuilder_ == null) {
        if (((bitField0_ & 0x00000040) != 0)
            && userAgent_ != null
            && userAgent_ != com.google.protobuf.Struct.getDefaultInstance()) {
          getUserAgentBuilder().mergeFrom(value);
        } else {
          userAgent_ = value;
        }
      } else {
        userAgentBuilder_.mergeFrom(value);
      }
      bitField0_ |= 0x00000040;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     */
    public Builder clearUserAgent() {
      bitField0_ = (bitField0_ & ~0x00000040);
      userAgent_ = null;
      if (userAgentBuilder_ != null) {
        userAgentBuilder_.dispose();
        userAgentBuilder_ = null;
      }
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     */
    public com.google.protobuf.Struct.Builder getUserAgentBuilder() {
      bitField0_ |= 0x00000040;
      onChanged();
      return getUserAgentFieldBuilder().getBuilder();
    }
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     */
    public com.google.protobuf.StructOrBuilder getUserAgentOrBuilder() {
      if (userAgentBuilder_ != null) {
        return userAgentBuilder_.getMessageOrBuilder();
      } else {
        return userAgent_ == null ? com.google.protobuf.Struct.getDefaultInstance() : userAgent_;
      }
    }
    /**
     *
     *
     * <pre>
     * A description of the process that generated the request.
     * </pre>
     *
     * <code>.google.protobuf.Struct user_agent = 5;</code>
     */
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.protobuf.Struct,
            com.google.protobuf.Struct.Builder,
            com.google.protobuf.StructOrBuilder>
        getUserAgentFieldBuilder() {
      if (userAgentBuilder_ == null) {
        userAgentBuilder_ =
            new com.google.protobuf.SingleFieldBuilderV3<
                com.google.protobuf.Struct,
                com.google.protobuf.Struct.Builder,
                com.google.protobuf.StructOrBuilder>(
                getUserAgent(), getParentForChildren(), isClean());
        userAgent_ = null;
      }
      return userAgentBuilder_;
    }

    private com.google.protobuf.Struct version_;
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.protobuf.Struct,
            com.google.protobuf.Struct.Builder,
            com.google.protobuf.StructOrBuilder>
        versionBuilder_;
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     *
     * @return Whether the version field is set.
     */
    public boolean hasVersion() {
      return ((bitField0_ & 0x00000080) != 0);
    }
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     *
     * @return The version.
     */
    public com.google.protobuf.Struct getVersion() {
      if (versionBuilder_ == null) {
        return version_ == null ? com.google.protobuf.Struct.getDefaultInstance() : version_;
      } else {
        return versionBuilder_.getMessage();
      }
    }
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     */
    public Builder setVersion(com.google.protobuf.Struct value) {
      if (versionBuilder_ == null) {
        if (value == null) {
          throw new NullPointerException();
        }
        version_ = value;
      } else {
        versionBuilder_.setMessage(value);
      }
      bitField0_ |= 0x00000080;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     */
    public Builder setVersion(com.google.protobuf.Struct.Builder builderForValue) {
      if (versionBuilder_ == null) {
        version_ = builderForValue.build();
      } else {
        versionBuilder_.setMessage(builderForValue.build());
      }
      bitField0_ |= 0x00000080;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     */
    public Builder mergeVersion(com.google.protobuf.Struct value) {
      if (versionBuilder_ == null) {
        if (((bitField0_ & 0x00000080) != 0)
            && version_ != null
            && version_ != com.google.protobuf.Struct.getDefaultInstance()) {
          getVersionBuilder().mergeFrom(value);
        } else {
          version_ = value;
        }
      } else {
        versionBuilder_.mergeFrom(value);
      }
      bitField0_ |= 0x00000080;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     */
    public Builder clearVersion() {
      bitField0_ = (bitField0_ & ~0x00000080);
      version_ = null;
      if (versionBuilder_ != null) {
        versionBuilder_.dispose();
        versionBuilder_ = null;
      }
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     */
    public com.google.protobuf.Struct.Builder getVersionBuilder() {
      bitField0_ |= 0x00000080;
      onChanged();
      return getVersionFieldBuilder().getBuilder();
    }
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     */
    public com.google.protobuf.StructOrBuilder getVersionOrBuilder() {
      if (versionBuilder_ != null) {
        return versionBuilder_.getMessageOrBuilder();
      } else {
        return version_ == null ? com.google.protobuf.Struct.getDefaultInstance() : version_;
      }
    }
    /**
     *
     *
     * <pre>
     * A structure describing which components and their versions of the service
     * are required in order to run the job.
     * </pre>
     *
     * <code>.google.protobuf.Struct version = 6;</code>
     */
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.protobuf.Struct,
            com.google.protobuf.Struct.Builder,
            com.google.protobuf.StructOrBuilder>
        getVersionFieldBuilder() {
      if (versionBuilder_ == null) {
        versionBuilder_ =
            new com.google.protobuf.SingleFieldBuilderV3<
                com.google.protobuf.Struct,
                com.google.protobuf.Struct.Builder,
                com.google.protobuf.StructOrBuilder>(
                getVersion(), getParentForChildren(), isClean());
        version_ = null;
      }
      return versionBuilder_;
    }

    private java.lang.Object dataset_ = "";
    /**
     *
     *
     * <pre>
     * The dataset for the current project where various workflow
     * related tables are stored.
     * The supported resource type is:
     * Google BigQuery:
     *   bigquery.googleapis.com/{dataset}
     * </pre>
     *
     * <code>string dataset = 7;</code>
     *
     * @return The dataset.
     */
    public java.lang.String getDataset() {
      java.lang.Object ref = dataset_;
      if (!(ref instanceof java.lang.String)) {
        com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
        java.lang.String s = bs.toStringUtf8();
        dataset_ = s;
        return s;
      } else {
        return (java.lang.String) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * The dataset for the current project where various workflow
     * related tables are stored.
     * The supported resource type is:
     * Google BigQuery:
     *   bigquery.googleapis.com/{dataset}
     * </pre>
     *
     * <code>string dataset = 7;</code>
     *
     * @return The bytes for dataset.
     */
    public com.google.protobuf.ByteString getDatasetBytes() {
      java.lang.Object ref = dataset_;
      if (ref instanceof String) {
        com.google.protobuf.ByteString b =
            com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
        dataset_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * The dataset for the current project where various workflow
     * related tables are stored.
     * The supported resource type is:
     * Google BigQuery:
     *   bigquery.googleapis.com/{dataset}
     * </pre>
     *
     * <code>string dataset = 7;</code>
     *
     * @param value The dataset to set.
     * @return This builder for chaining.
     */
    public Builder setDataset(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      dataset_ = value;
      bitField0_ |= 0x00000100;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The dataset for the current project where various workflow
     * related tables are stored.
     * The supported resource type is:
     * Google BigQuery:
     *   bigquery.googleapis.com/{dataset}
     * </pre>
     *
     * <code>string dataset = 7;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearDataset() {
      dataset_ = getDefaultInstance().getDataset();
      bitField0_ = (bitField0_ & ~0x00000100);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The dataset for the current project where various workflow
     * related tables are stored.
     * The supported resource type is:
     * Google BigQuery:
     *   bigquery.googleapis.com/{dataset}
     * </pre>
     *
     * <code>string dataset = 7;</code>
     *
     * @param value The bytes for dataset to set.
     * @return This builder for chaining.
     */
    public Builder setDatasetBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      dataset_ = value;
      bitField0_ |= 0x00000100;
      onChanged();
      return this;
    }

    private com.google.protobuf.Struct sdkPipelineOptions_;
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.protobuf.Struct,
            com.google.protobuf.Struct.Builder,
            com.google.protobuf.StructOrBuilder>
        sdkPipelineOptionsBuilder_;
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     *
     * @return Whether the sdkPipelineOptions field is set.
     */
    public boolean hasSdkPipelineOptions() {
      return ((bitField0_ & 0x00000200) != 0);
    }
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     *
     * @return The sdkPipelineOptions.
     */
    public com.google.protobuf.Struct getSdkPipelineOptions() {
      if (sdkPipelineOptionsBuilder_ == null) {
        return sdkPipelineOptions_ == null
            ? com.google.protobuf.Struct.getDefaultInstance()
            : sdkPipelineOptions_;
      } else {
        return sdkPipelineOptionsBuilder_.getMessage();
      }
    }
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     */
    public Builder setSdkPipelineOptions(com.google.protobuf.Struct value) {
      if (sdkPipelineOptionsBuilder_ == null) {
        if (value == null) {
          throw new NullPointerException();
        }
        sdkPipelineOptions_ = value;
      } else {
        sdkPipelineOptionsBuilder_.setMessage(value);
      }
      bitField0_ |= 0x00000200;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     */
    public Builder setSdkPipelineOptions(com.google.protobuf.Struct.Builder builderForValue) {
      if (sdkPipelineOptionsBuilder_ == null) {
        sdkPipelineOptions_ = builderForValue.build();
      } else {
        sdkPipelineOptionsBuilder_.setMessage(builderForValue.build());
      }
      bitField0_ |= 0x00000200;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     */
    public Builder mergeSdkPipelineOptions(com.google.protobuf.Struct value) {
      if (sdkPipelineOptionsBuilder_ == null) {
        if (((bitField0_ & 0x00000200) != 0)
            && sdkPipelineOptions_ != null
            && sdkPipelineOptions_ != com.google.protobuf.Struct.getDefaultInstance()) {
          getSdkPipelineOptionsBuilder().mergeFrom(value);
        } else {
          sdkPipelineOptions_ = value;
        }
      } else {
        sdkPipelineOptionsBuilder_.mergeFrom(value);
      }
      bitField0_ |= 0x00000200;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     */
    public Builder clearSdkPipelineOptions() {
      bitField0_ = (bitField0_ & ~0x00000200);
      sdkPipelineOptions_ = null;
      if (sdkPipelineOptionsBuilder_ != null) {
        sdkPipelineOptionsBuilder_.dispose();
        sdkPipelineOptionsBuilder_ = null;
      }
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     */
    public com.google.protobuf.Struct.Builder getSdkPipelineOptionsBuilder() {
      bitField0_ |= 0x00000200;
      onChanged();
      return getSdkPipelineOptionsFieldBuilder().getBuilder();
    }
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     */
    public com.google.protobuf.StructOrBuilder getSdkPipelineOptionsOrBuilder() {
      if (sdkPipelineOptionsBuilder_ != null) {
        return sdkPipelineOptionsBuilder_.getMessageOrBuilder();
      } else {
        return sdkPipelineOptions_ == null
            ? com.google.protobuf.Struct.getDefaultInstance()
            : sdkPipelineOptions_;
      }
    }
    /**
     *
     *
     * <pre>
     * The Cloud Dataflow SDK pipeline options specified by the user. These
     * options are passed through the service and are used to recreate the
     * SDK pipeline options on the worker in a language agnostic and platform
     * independent way.
     * </pre>
     *
     * <code>.google.protobuf.Struct sdk_pipeline_options = 8;</code>
     */
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.protobuf.Struct,
            com.google.protobuf.Struct.Builder,
            com.google.protobuf.StructOrBuilder>
        getSdkPipelineOptionsFieldBuilder() {
      if (sdkPipelineOptionsBuilder_ == null) {
        sdkPipelineOptionsBuilder_ =
            new com.google.protobuf.SingleFieldBuilderV3<
                com.google.protobuf.Struct,
                com.google.protobuf.Struct.Builder,
                com.google.protobuf.StructOrBuilder>(
                getSdkPipelineOptions(), getParentForChildren(), isClean());
        sdkPipelineOptions_ = null;
      }
      return sdkPipelineOptionsBuilder_;
    }

    private com.google.protobuf.Any internalExperiments_;
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.protobuf.Any,
            com.google.protobuf.Any.Builder,
            com.google.protobuf.AnyOrBuilder>
        internalExperimentsBuilder_;
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     *
     * @return Whether the internalExperiments field is set.
     */
    public boolean hasInternalExperiments() {
      return ((bitField0_ & 0x00000400) != 0);
    }
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     *
     * @return The internalExperiments.
     */
    public com.google.protobuf.Any getInternalExperiments() {
      if (internalExperimentsBuilder_ == null) {
        return internalExperiments_ == null
            ? com.google.protobuf.Any.getDefaultInstance()
            : internalExperiments_;
      } else {
        return internalExperimentsBuilder_.getMessage();
      }
    }
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     */
    public Builder setInternalExperiments(com.google.protobuf.Any value) {
      if (internalExperimentsBuilder_ == null) {
        if (value == null) {
          throw new NullPointerException();
        }
        internalExperiments_ = value;
      } else {
        internalExperimentsBuilder_.setMessage(value);
      }
      bitField0_ |= 0x00000400;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     */
    public Builder setInternalExperiments(com.google.protobuf.Any.Builder builderForValue) {
      if (internalExperimentsBuilder_ == null) {
        internalExperiments_ = builderForValue.build();
      } else {
        internalExperimentsBuilder_.setMessage(builderForValue.build());
      }
      bitField0_ |= 0x00000400;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     */
    public Builder mergeInternalExperiments(com.google.protobuf.Any value) {
      if (internalExperimentsBuilder_ == null) {
        if (((bitField0_ & 0x00000400) != 0)
            && internalExperiments_ != null
            && internalExperiments_ != com.google.protobuf.Any.getDefaultInstance()) {
          getInternalExperimentsBuilder().mergeFrom(value);
        } else {
          internalExperiments_ = value;
        }
      } else {
        internalExperimentsBuilder_.mergeFrom(value);
      }
      bitField0_ |= 0x00000400;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     */
    public Builder clearInternalExperiments() {
      bitField0_ = (bitField0_ & ~0x00000400);
      internalExperiments_ = null;
      if (internalExperimentsBuilder_ != null) {
        internalExperimentsBuilder_.dispose();
        internalExperimentsBuilder_ = null;
      }
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     */
    public com.google.protobuf.Any.Builder getInternalExperimentsBuilder() {
      bitField0_ |= 0x00000400;
      onChanged();
      return getInternalExperimentsFieldBuilder().getBuilder();
    }
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     */
    public com.google.protobuf.AnyOrBuilder getInternalExperimentsOrBuilder() {
      if (internalExperimentsBuilder_ != null) {
        return internalExperimentsBuilder_.getMessageOrBuilder();
      } else {
        return internalExperiments_ == null
            ? com.google.protobuf.Any.getDefaultInstance()
            : internalExperiments_;
      }
    }
    /**
     *
     *
     * <pre>
     * Experimental settings.
     * </pre>
     *
     * <code>.google.protobuf.Any internal_experiments = 9;</code>
     */
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.protobuf.Any,
            com.google.protobuf.Any.Builder,
            com.google.protobuf.AnyOrBuilder>
        getInternalExperimentsFieldBuilder() {
      if (internalExperimentsBuilder_ == null) {
        internalExperimentsBuilder_ =
            new com.google.protobuf.SingleFieldBuilderV3<
                com.google.protobuf.Any,
                com.google.protobuf.Any.Builder,
                com.google.protobuf.AnyOrBuilder>(
                getInternalExperiments(), getParentForChildren(), isClean());
        internalExperiments_ = null;
      }
      return internalExperimentsBuilder_;
    }

    private java.lang.Object serviceAccountEmail_ = "";
    /**
     *
     *
     * <pre>
     * Identity to run virtual machines as. Defaults to the default account.
     * </pre>
     *
     * <code>string service_account_email = 10;</code>
     *
     * @return The serviceAccountEmail.
     */
    public java.lang.String getServiceAccountEmail() {
      java.lang.Object ref = serviceAccountEmail_;
      if (!(ref instanceof java.lang.String)) {
        com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
        java.lang.String s = bs.toStringUtf8();
        serviceAccountEmail_ = s;
        return s;
      } else {
        return (java.lang.String) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * Identity to run virtual machines as. Defaults to the default account.
     * </pre>
     *
     * <code>string service_account_email = 10;</code>
     *
     * @return The bytes for serviceAccountEmail.
     */
    public com.google.protobuf.ByteString getServiceAccountEmailBytes() {
      java.lang.Object ref = serviceAccountEmail_;
      if (ref instanceof String) {
        com.google.protobuf.ByteString b =
            com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
        serviceAccountEmail_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * Identity to run virtual machines as. Defaults to the default account.
     * </pre>
     *
     * <code>string service_account_email = 10;</code>
     *
     * @param value The serviceAccountEmail to set.
     * @return This builder for chaining.
     */
    public Builder setServiceAccountEmail(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      serviceAccountEmail_ = value;
      bitField0_ |= 0x00000800;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Identity to run virtual machines as. Defaults to the default account.
     * </pre>
     *
     * <code>string service_account_email = 10;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearServiceAccountEmail() {
      serviceAccountEmail_ = getDefaultInstance().getServiceAccountEmail();
      bitField0_ = (bitField0_ & ~0x00000800);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Identity to run virtual machines as. Defaults to the default account.
     * </pre>
     *
     * <code>string service_account_email = 10;</code>
     *
     * @param value The bytes for serviceAccountEmail to set.
     * @return This builder for chaining.
     */
    public Builder setServiceAccountEmailBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      serviceAccountEmail_ = value;
      bitField0_ |= 0x00000800;
      onChanged();
      return this;
    }

    private int flexResourceSchedulingGoal_ = 0;
    /**
     *
     *
     * <pre>
     * Which Flexible Resource Scheduling mode to run in.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;
     * </code>
     *
     * @return The enum numeric value on the wire for flexResourceSchedulingGoal.
     */
    @java.lang.Override
    public int getFlexResourceSchedulingGoalValue() {
      return flexResourceSchedulingGoal_;
    }
    /**
     *
     *
     * <pre>
     * Which Flexible Resource Scheduling mode to run in.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;
     * </code>
     *
     * @param value The enum numeric value on the wire for flexResourceSchedulingGoal to set.
     * @return This builder for chaining.
     */
    public Builder setFlexResourceSchedulingGoalValue(int value) {
      flexResourceSchedulingGoal_ = value;
      bitField0_ |= 0x00001000;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Which Flexible Resource Scheduling mode to run in.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;
     * </code>
     *
     * @return The flexResourceSchedulingGoal.
     */
    @java.lang.Override
    public com.google.dataflow.v1beta3.FlexResourceSchedulingGoal getFlexResourceSchedulingGoal() {
      com.google.dataflow.v1beta3.FlexResourceSchedulingGoal result =
          com.google.dataflow.v1beta3.FlexResourceSchedulingGoal.forNumber(
              flexResourceSchedulingGoal_);
      return result == null
          ? com.google.dataflow.v1beta3.FlexResourceSchedulingGoal.UNRECOGNIZED
          : result;
    }
    /**
     *
     *
     * <pre>
     * Which Flexible Resource Scheduling mode to run in.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;
     * </code>
     *
     * @param value The flexResourceSchedulingGoal to set.
     * @return This builder for chaining.
     */
    public Builder setFlexResourceSchedulingGoal(
        com.google.dataflow.v1beta3.FlexResourceSchedulingGoal value) {
      if (value == null) {
        throw new NullPointerException();
      }
      bitField0_ |= 0x00001000;
      flexResourceSchedulingGoal_ = value.getNumber();
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Which Flexible Resource Scheduling mode to run in.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;
     * </code>
     *
     * @return This builder for chaining.
     */
    public Builder clearFlexResourceSchedulingGoal() {
      bitField0_ = (bitField0_ & ~0x00001000);
      flexResourceSchedulingGoal_ = 0;
      onChanged();
      return this;
    }

    private java.lang.Object workerRegion_ = "";
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_region = 13;</code>
     *
     * @return The workerRegion.
     */
    public java.lang.String getWorkerRegion() {
      java.lang.Object ref = workerRegion_;
      if (!(ref instanceof java.lang.String)) {
        com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
        java.lang.String s = bs.toStringUtf8();
        workerRegion_ = s;
        return s;
      } else {
        return (java.lang.String) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_region = 13;</code>
     *
     * @return The bytes for workerRegion.
     */
    public com.google.protobuf.ByteString getWorkerRegionBytes() {
      java.lang.Object ref = workerRegion_;
      if (ref instanceof String) {
        com.google.protobuf.ByteString b =
            com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
        workerRegion_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_region = 13;</code>
     *
     * @param value The workerRegion to set.
     * @return This builder for chaining.
     */
    public Builder setWorkerRegion(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      workerRegion_ = value;
      bitField0_ |= 0x00002000;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_region = 13;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearWorkerRegion() {
      workerRegion_ = getDefaultInstance().getWorkerRegion();
      bitField0_ = (bitField0_ & ~0x00002000);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_region = 13;</code>
     *
     * @param value The bytes for workerRegion to set.
     * @return This builder for chaining.
     */
    public Builder setWorkerRegionBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      workerRegion_ = value;
      bitField0_ |= 0x00002000;
      onChanged();
      return this;
    }

    private java.lang.Object workerZone_ = "";
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_zone = 14;</code>
     *
     * @return The workerZone.
     */
    public java.lang.String getWorkerZone() {
      java.lang.Object ref = workerZone_;
      if (!(ref instanceof java.lang.String)) {
        com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
        java.lang.String s = bs.toStringUtf8();
        workerZone_ = s;
        return s;
      } else {
        return (java.lang.String) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_zone = 14;</code>
     *
     * @return The bytes for workerZone.
     */
    public com.google.protobuf.ByteString getWorkerZoneBytes() {
      java.lang.Object ref = workerZone_;
      if (ref instanceof String) {
        com.google.protobuf.ByteString b =
            com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
        workerZone_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_zone = 14;</code>
     *
     * @param value The workerZone to set.
     * @return This builder for chaining.
     */
    public Builder setWorkerZone(java.lang.String value) {
      if (value == null) {
        throw new NullPointerException();
      }
      workerZone_ = value;
      bitField0_ |= 0x00004000;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_zone = 14;</code>
     *
     * @return This builder for chaining.
     */
    public Builder clearWorkerZone() {
      workerZone_ = getDefaultInstance().getWorkerZone();
      bitField0_ = (bitField0_ & ~0x00004000);
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * 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.
     * </pre>
     *
     * <code>string worker_zone = 14;</code>
     *
     * @param value The bytes for workerZone to set.
     * @return This builder for chaining.
     */
    public Builder setWorkerZoneBytes(com.google.protobuf.ByteString value) {
      if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
      workerZone_ = value;
      bitField0_ |= 0x00004000;
      onChanged();
      return this;
    }

    private int shuffleMode_ = 0;
    /**
     *
     *
     * <pre>
     * Output only. The shuffle mode used for the job.
     * </pre>
     *
     * <code>
     * .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
     * </code>
     *
     * @return The enum numeric value on the wire for shuffleMode.
     */
    @java.lang.Override
    public int getShuffleModeValue() {
      return shuffleMode_;
    }
    /**
     *
     *
     * <pre>
     * Output only. The shuffle mode used for the job.
     * </pre>
     *
     * <code>
     * .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
     * </code>
     *
     * @param value The enum numeric value on the wire for shuffleMode to set.
     * @return This builder for chaining.
     */
    public Builder setShuffleModeValue(int value) {
      shuffleMode_ = value;
      bitField0_ |= 0x00008000;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Output only. The shuffle mode used for the job.
     * </pre>
     *
     * <code>
     * .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
     * </code>
     *
     * @return The shuffleMode.
     */
    @java.lang.Override
    public com.google.dataflow.v1beta3.ShuffleMode getShuffleMode() {
      com.google.dataflow.v1beta3.ShuffleMode result =
          com.google.dataflow.v1beta3.ShuffleMode.forNumber(shuffleMode_);
      return result == null ? com.google.dataflow.v1beta3.ShuffleMode.UNRECOGNIZED : result;
    }
    /**
     *
     *
     * <pre>
     * Output only. The shuffle mode used for the job.
     * </pre>
     *
     * <code>
     * .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
     * </code>
     *
     * @param value The shuffleMode to set.
     * @return This builder for chaining.
     */
    public Builder setShuffleMode(com.google.dataflow.v1beta3.ShuffleMode value) {
      if (value == null) {
        throw new NullPointerException();
      }
      bitField0_ |= 0x00008000;
      shuffleMode_ = value.getNumber();
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Output only. The shuffle mode used for the job.
     * </pre>
     *
     * <code>
     * .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
     * </code>
     *
     * @return This builder for chaining.
     */
    public Builder clearShuffleMode() {
      bitField0_ = (bitField0_ & ~0x00008000);
      shuffleMode_ = 0;
      onChanged();
      return this;
    }

    private com.google.dataflow.v1beta3.DebugOptions debugOptions_;
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.dataflow.v1beta3.DebugOptions,
            com.google.dataflow.v1beta3.DebugOptions.Builder,
            com.google.dataflow.v1beta3.DebugOptionsOrBuilder>
        debugOptionsBuilder_;
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     *
     * @return Whether the debugOptions field is set.
     */
    public boolean hasDebugOptions() {
      return ((bitField0_ & 0x00010000) != 0);
    }
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     *
     * @return The debugOptions.
     */
    public com.google.dataflow.v1beta3.DebugOptions getDebugOptions() {
      if (debugOptionsBuilder_ == null) {
        return debugOptions_ == null
            ? com.google.dataflow.v1beta3.DebugOptions.getDefaultInstance()
            : debugOptions_;
      } else {
        return debugOptionsBuilder_.getMessage();
      }
    }
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     */
    public Builder setDebugOptions(com.google.dataflow.v1beta3.DebugOptions value) {
      if (debugOptionsBuilder_ == null) {
        if (value == null) {
          throw new NullPointerException();
        }
        debugOptions_ = value;
      } else {
        debugOptionsBuilder_.setMessage(value);
      }
      bitField0_ |= 0x00010000;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     */
    public Builder setDebugOptions(
        com.google.dataflow.v1beta3.DebugOptions.Builder builderForValue) {
      if (debugOptionsBuilder_ == null) {
        debugOptions_ = builderForValue.build();
      } else {
        debugOptionsBuilder_.setMessage(builderForValue.build());
      }
      bitField0_ |= 0x00010000;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     */
    public Builder mergeDebugOptions(com.google.dataflow.v1beta3.DebugOptions value) {
      if (debugOptionsBuilder_ == null) {
        if (((bitField0_ & 0x00010000) != 0)
            && debugOptions_ != null
            && debugOptions_ != com.google.dataflow.v1beta3.DebugOptions.getDefaultInstance()) {
          getDebugOptionsBuilder().mergeFrom(value);
        } else {
          debugOptions_ = value;
        }
      } else {
        debugOptionsBuilder_.mergeFrom(value);
      }
      bitField0_ |= 0x00010000;
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     */
    public Builder clearDebugOptions() {
      bitField0_ = (bitField0_ & ~0x00010000);
      debugOptions_ = null;
      if (debugOptionsBuilder_ != null) {
        debugOptionsBuilder_.dispose();
        debugOptionsBuilder_ = null;
      }
      onChanged();
      return this;
    }
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     */
    public com.google.dataflow.v1beta3.DebugOptions.Builder getDebugOptionsBuilder() {
      bitField0_ |= 0x00010000;
      onChanged();
      return getDebugOptionsFieldBuilder().getBuilder();
    }
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     */
    public com.google.dataflow.v1beta3.DebugOptionsOrBuilder getDebugOptionsOrBuilder() {
      if (debugOptionsBuilder_ != null) {
        return debugOptionsBuilder_.getMessageOrBuilder();
      } else {
        return debugOptions_ == null
            ? com.google.dataflow.v1beta3.DebugOptions.getDefaultInstance()
            : debugOptions_;
      }
    }
    /**
     *
     *
     * <pre>
     * Any debugging options to be supplied to the job.
     * </pre>
     *
     * <code>.google.dataflow.v1beta3.DebugOptions debug_options = 17;</code>
     */
    private com.google.protobuf.SingleFieldBuilderV3<
            com.google.dataflow.v1beta3.DebugOptions,
            com.google.dataflow.v1beta3.DebugOptions.Builder,
            com.google.dataflow.v1beta3.DebugOptionsOrBuilder>
        getDebugOptionsFieldBuilder() {
      if (debugOptionsBuilder_ == null) {
        debugOptionsBuilder_ =
            new com.google.protobuf.SingleFieldBuilderV3<
                com.google.dataflow.v1beta3.DebugOptions,
                com.google.dataflow.v1beta3.DebugOptions.Builder,
                com.google.dataflow.v1beta3.DebugOptionsOrBuilder>(
                getDebugOptions(), getParentForChildren(), isClean());
        debugOptions_ = null;
      }
      return debugOptionsBuilder_;
    }

    @java.lang.Override
    public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
      return super.setUnknownFields(unknownFields);
    }

    @java.lang.Override
    public final Builder mergeUnknownFields(
        final com.google.protobuf.UnknownFieldSet unknownFields) {
      return super.mergeUnknownFields(unknownFields);
    }

    // @@protoc_insertion_point(builder_scope:google.dataflow.v1beta3.Environment)
  }

  // @@protoc_insertion_point(class_scope:google.dataflow.v1beta3.Environment)
  private static final com.google.dataflow.v1beta3.Environment DEFAULT_INSTANCE;

  static {
    DEFAULT_INSTANCE = new com.google.dataflow.v1beta3.Environment();
  }

  public static com.google.dataflow.v1beta3.Environment getDefaultInstance() {
    return DEFAULT_INSTANCE;
  }

  private static final com.google.protobuf.Parser<Environment> PARSER =
      new com.google.protobuf.AbstractParser<Environment>() {
        @java.lang.Override
        public Environment parsePartialFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          Builder builder = newBuilder();
          try {
            builder.mergeFrom(input, extensionRegistry);
          } catch (com.google.protobuf.InvalidProtocolBufferException e) {
            throw e.setUnfinishedMessage(builder.buildPartial());
          } catch (com.google.protobuf.UninitializedMessageException e) {
            throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
          } catch (java.io.IOException e) {
            throw new com.google.protobuf.InvalidProtocolBufferException(e)
                .setUnfinishedMessage(builder.buildPartial());
          }
          return builder.buildPartial();
        }
      };

  public static com.google.protobuf.Parser<Environment> parser() {
    return PARSER;
  }

  @java.lang.Override
  public com.google.protobuf.Parser<Environment> getParserForType() {
    return PARSER;
  }

  @java.lang.Override
  public com.google.dataflow.v1beta3.Environment getDefaultInstanceForType() {
    return DEFAULT_INSTANCE;
  }
}