internalAddGeneratedFile( ' ø )google/dataflow/v1beta3/environment.protogoogle.dataflow.v1beta3google/protobuf/any.protogoogle/protobuf/struct.proto"Ï Environment temp_storage_prefix

( # cluster_manager_api_service
(  experiments (  service_options (  service_kms_key_name
( 9 worker_pools (2#.google.dataflow.v1beta3.WorkerPool+ user_agent
(2.google.protobuf.Struct( version
(2.google.protobuf.Struct dataset
( 5 sdk_pipeline_options
(2.google.protobuf.Struct2 internal_experiments
(2.google.protobuf.Any service_account_email
( Z flex_resource_scheduling_goal
(23.google.dataflow.v1beta3.FlexResourceSchedulingGoal worker_region
(  worker_zone
( ? shuffle_mode
(2$.google.dataflow.v1beta3.ShuffleModeBàA< debug_options
(2%.google.dataflow.v1beta3.DebugOptions") Package name

(  location
( "? Disk size_gb

( disk_type
(  mount_point
( "¡
WorkerSettings base_url

(  reporting_enabled
( service_path
(  shuffle_service_path
(  worker_id
(  temp_storage_prefix
( "¤ TaskRunnerSettings task_user

(  task_group
(  oauth_scopes (  base_url
(  dataflow_api_version
( I parallel_worker_settings
(2\'.google.dataflow.v1beta3.WorkerSettings base_task_dir
(  continue_on_exception
( log_to_serialconsole
( alsologtostderr
( log_upload_location
(  log_dir
(  temp_storage_prefix
(  harness_command
(  workflow_file_name
(  commandlines_file_name
(  vm_id
(  language_hint
( # streaming_worker_main_class
( "p AutoscalingSettings@ algorithm

(2-.google.dataflow.v1beta3.AutoscalingAlgorithm max_num_workers
("ˆ
SdkHarnessContainerImage container_image

( % use_single_core_per_container
( environment_id
(  capabilities ( "ò WorkerPool kind

(  num_workers
(2 packages (2 .google.dataflow.v1beta3.PackageG default_package_set
(2*.google.dataflow.v1beta3.DefaultPackageSet machine_type
( @ teardown_policy
(2\'.google.dataflow.v1beta3.TeardownPolicy disk_size_gb
( disk_type
(  disk_source_image
(  zone
( H taskrunner_settings
(2+.google.dataflow.v1beta3.TaskRunnerSettings on_host_maintenance
( 1 data_disks (2.google.dataflow.v1beta3.DiskC metadata (21.google.dataflow.v1beta3.WorkerPool.MetadataEntryJ autoscaling_settings
(2,.google.dataflow.v1beta3.AutoscalingSettings\' pool_args
(2.google.protobuf.Any network
(  subnetwork
( & worker_harness_container_image
(  num_threads_per_worker
(O ip_configuration
(25.google.dataflow.v1beta3.WorkerIPAddressConfigurationW sdk_harness_container_images (21.google.dataflow.v1beta3.SdkHarnessContainerImage/ MetadataEntry key

(  value
( :8
". DebugOptions enable_hot_key_logging

(*K JobType JOB_TYPE_UNKNOWN JOB_TYPE_BATCH
 JOB_TYPE_STREAMING*k FlexResourceSchedulingGoal FLEXRS_UNSPECIFIED FLEXRS_SPEED_OPTIMIZED
 FLEXRS_COST_OPTIMIZED*o TeardownPolicy TEARDOWN_POLICY_UNKNOWN TEARDOWN_ALWAYS
 TEARDOWN_ON_SUCCESS TEARDOWN_NEVER*�
DefaultPackageSet DEFAULT_PACKAGE_SET_UNKNOWN DEFAULT_PACKAGE_SET_NONE
 DEFAULT_PACKAGE_SET_JAVA DEFAULT_PACKAGE_SET_PYTHON*z AutoscalingAlgorithm! AUTOSCALING_ALGORITHM_UNKNOWN AUTOSCALING_ALGORITHM_NONE
 AUTOSCALING_ALGORITHM_BASIC*f WorkerIPAddressConfiguration WORKER_IP_UNSPECIFIED WORKER_IP_PUBLIC
 WORKER_IP_PRIVATE*L ShuffleMode SHUFFLE_MODE_UNSPECIFIED VM_BASED
 SERVICE_BASEDBÕ
com.google.dataflow.v1beta3BEnvironmentProtoP
Z?google.golang.org/genproto/googleapis/dataflow/v1beta3;dataflowªGoogle.Cloud.Dataflow.V1Beta3ÊGoogle\\Cloud\\Dataflow\\V1beta3ê Google::Cloud::Dataflow::V1beta3bproto3' , true); static::$is_initialized = true; } }