@@ -121,61 +121,61 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
121121 + "worker_main_class\030 \023 \001 (\t \" p\n \023 AutoscalingSe"
122122 + "ttings\022 @\n \t algorithm\030 \001 \001 (\016 2-.google.dataf"
123123 + "low.v1beta3.AutoscalingAlgorithm\022 \027 \n \017 max_"
124- + "num_workers\030 \002 \001 (\005 \" r \n \030 SdkHarnessContainer "
125- + "Image \022 \027 \n \017 container_image\030 \001 \001 (\t \022 %\n \035 use_si "
126- + "ngle_core_per_container \030 \002 \001 (\010 \022 \026 \n \016 environ "
127- + "ment_id \030 \003 \001 (\t \" \362 \007 \n \n WorkerPool \022 \014 \n \004 kind \030 \001 \001 "
128- + "( \t \022 \023 \n \013 num_workers \030 \002 \001 (\005 \022 2 \n \010 packages \030 \003 \003 ( "
129- + "\013 2 .google.dataflow.v1beta3.Package \022 G \n \023 d "
130- + "efault_package_set \030 \004 \001 ( \016 2*.google.datafl "
131- + "ow.v1beta3.DefaultPackageSet \022 \024 \n \014 machine_ "
132- + "type \ 030\005 \001 (\t \022 @\n \017 teardown_policy \030 \006 \001 ( \016 2 \' .go "
133- + "ogle.dataflow.v1beta3.TeardownPolicy \022 \024 \n \014 "
134- + "disk_size_gb \030 \007 \001 ( \005 \ 022\021 \n \t disk_type \030 \020 \001 (\t \022 \031 \n "
135- + "\021 disk_source_image \030 \010 \001 ( \t \ 022\014 \n \004 zone \030 \t \001 (\t \022 H "
136- + "\n \023 taskrunner_settings \030 \n \001 (\013 2+.google.dat "
137- + "aflow.v1beta3.TaskRunnerSettings \022 \033 \n \023 on_h "
138- + "ost_maintenance \030 \013 \001 ( \t \022 1 \n \n data_disks \030 \014 \003 ( "
139- + "\ 013 2\035 .google.dataflow.v1beta3.Disk \022 C \n \010 meta "
140- + "data \ 030\r \003 (\013 21.google.dataflow.v1beta3.Wor "
141- + "kerPool.MetadataEntry \022 J \n \024 autoscaling_set "
142- + "tings \ 030\016 \001 (\013 2,.google.dataflow.v1beta3.Au "
143- + "toscalingSettings \022 \' \n \t pool_args \030 \017 \001 ( \013 2 \024 .g "
144- + "oogle.protobuf.Any \022 \017 \n \007 network \030 \021 \001 (\t \022 \022 \n \n s "
145- + "ubnetwork \ 030\023 \001 (\t \022 & \n \036 worker_harness_contai "
146- + "ner_image \ 030\022 \001 (\t \022 \036 \n \026 num_threads_per_worke "
147- + "r \ 030\024 \001 (\005 \022 O\n \020 ip_configuration \030 \025 \001 ( \016 25.goog "
148- + "le. dataflow.v1beta3.WorkerIPAddressConfi "
149- + "guration \022 W\n \034 sdk_harness_container_images "
150- + "\030 \026 \003 (\013 21.google.dataflow.v1beta3.SdkHarn "
151- + "essContainerImage \032 / \n \r MetadataEntry \022 \013 \n \003 ke "
152- + "y \030 \001 \001 ( \t \ 022\r \n \005 value \030 \002 \001 (\t : \002 8 \001 \" . \n \014 DebugOptio "
153- + "ns \022 \036 \n \026 enable_hot_key_logging \030 \ 001 \001 ( \010 *K \n \007 Jo "
154- + "bType \022 \024 \n \020 JOB_TYPE_UNKNOWN \020 \000 \022 \022 \n \016 JOB_TYPE_ "
155- + "BATCH \020 \001 \022 \026 \n \022 JOB_TYPE_STREAMING \020 \002 *k \n \032 FlexR "
156- + "esourceSchedulingGoal \022 \026 \n \022 FLEXRS_UNSPECIF "
157- + "IED \020 \000 \ 022\032 \n \026 FLEXRS_SPEED_OPTIMIZED \020 \001 \022 \031 \n \025 FLE "
158- + "XRS_COST_OPTIMIZED \020 \002 *o \n \016 TeardownPolicy \022 \033 "
159- + "\n \027 TEARDOWN_POLICY_UNKNOWN \020 \000 \022 \023 \n \017 TEARDOWN_ "
160- + "ALWAYS \020 \001 \022 \027 \n \023 TEARDOWN_ON_SUCCESS \020 \002 \022 \022 \n \016 TEA "
161- + "RDOWN_NEVER \020 \003 * \220 \001 \n \021 DefaultPackageSet \022 \037 \n \033 D "
162- + "EFAULT_PACKAGE_SET_UNKNOWN \020 \000 \ 022\034 \n \030 DEFAULT_ "
163- + "PACKAGE_SET_NONE \020 \001 \022 \034 \n \030 DEFAULT_PACKAGE_SE "
164- + "T_JAVA \ 020\002 \022 \036 \n \032 DEFAULT_PACKAGE_SET_PYTHON \020 \003 "
165- + "*z\n \024 AutoscalingAlgorithm \022 ! \n \035 AUTOSCALING_ "
166- + "ALGORITHM_UNKNOWN \020 \000 \ 022\036 \n \032 AUTOSCALING_ALGOR "
167- + "ITHM_NONE \020 \001 \022 \037 \n \033 AUTOSCALING_ALGORITHM_BAS "
168- + "IC \020 \002 *f\n \034 WorkerIPAddressConfiguration \022 \031 \n \025 "
169- + "WORKER_IP_UNSPECIFIED \020 \000 \ 022\024 \n \020 WORKER_IP_PUB "
170- + "LIC \020 \001 \022 \025 \n \021 WORKER_IP_PRIVATE \020 \002 *L \n \013 ShuffleM "
171- + "ode \022 \034 \n \030 SHUFFLE_MODE_UNSPECIFIED \020 \000 \ 022\014 \n \010 VM_ "
172- + "BASED \020 \001 \022 \021 \n \r SERVICE_BASED \020 \002 B \325 \001 \n \033 com.googl "
173- + "e. dataflow.v1beta3B \020 EnvironmentProtoP \001 Z? "
174- + "google.golang.org/genproto/googleapis/da "
175- + "taflow/ v1beta3;dataflow \252 \002 \035 Google.Cloud.D "
176- + "ataflow.V1Beta3 \312 \002 \035 Google\\ Cloud\\ Dataflow\\ "
177- + "V1beta3\352 \002 Google::Cloud::Dataflow::V1bet "
178- + "a3b \006 proto3"
124+ + "num_workers\030 \002 \001 (\005 \" \210 \001 \n \030 SdkHarnessContaine "
125+ + "rImage \022 \027 \n \017 container_image\030 \001 \001 (\t \022 %\n \035 use_s "
126+ + "ingle_core_per_container \030 \002 \001 (\010 \022 \026 \n \016 enviro "
127+ + "nment_id \030 \003 \001 (\t \022 \024 \n \014 capabilities \030 \004 \003 ( \t \" \362 \007 \n "
128+ + "\n WorkerPool \022 \014 \n \004 kind \030 \001 \001 (\t \022 \023 \n \013 num_workers "
129+ + "\030 \002 \001 ( \005 \022 2 \n \010 packages \030 \003 \003 ( \013 2 .google.datafl "
130+ + "ow.v1beta3.Package \022 G \n \023 default_package_se "
131+ + "t \030 \004 \001 ( \016 2*.google.dataflow.v1beta3.Defaul "
132+ + "tPackageSet \022 \024 \n \014 machine_type \ 030\005 \001 (\t \022 @\n \017 tea "
133+ + "rdown_policy \030 \006 \001 ( \016 2 \' .google.dataflow.v1b "
134+ + "eta3.TeardownPolicy \ 022\024 \n \014 disk_size_gb \030 \007 \001 ("
135+ + "\005 \ 022\021 \n \t disk_type \030 \020 \001 (\t \022 \031 \n \021 disk_source_imag "
136+ + "e \030 \010 \001 ( \t \022 \014 \n \004 zone \030 \t \001 (\t \022 H \n \023 taskrunner_sett "
137+ + "ings \030 \n \001 ( \013 2+.google.dataflow.v1beta3.Tas "
138+ + "kRunnerSettings \022 \033 \n \023 on_host_maintenance \030 \013 "
139+ + " \001 ( \t \022 1 \n \n data_disks \030 \014 \003 ( \ 013 2\035 .google.datafl "
140+ + "ow.v1beta3.Disk \022 C \n \010 metadata \ 030\r \003 (\013 21.goog "
141+ + "le.dataflow.v1beta3.WorkerPool.MetadataE "
142+ + "ntry \022 J \n \024 autoscaling_settings \ 030\016 \001 (\013 2,.goo "
143+ + "gle.dataflow.v1beta3.AutoscalingSettings "
144+ + "\022 \' \n \t pool_args \030 \017 \001 (\013 2 \024 .google.protobuf.An "
145+ + "y \022 \017 \n \007 network \ 030\021 \001 (\t \022 \022 \n \n subnetwork \030 \023 \001 ( \t \022 & "
146+ + "\n \036 worker_harness_container_image \ 030\022 \001 (\t \022 \036 "
147+ + "\n \026 num_threads_per_worker \ 030\024 \001 (\005 \022 O\n \020 ip_con "
148+ + "figuration \030 \025 \001 ( \016 25.google. dataflow.v1bet "
149+ + "a3.WorkerIPAddressConfiguration \022 W\n \034 sdk_h "
150+ + "arness_container_images \030 \026 \003 (\013 21.google.d "
151+ + "ataflow.v1beta3.SdkHarnessContainerImage "
152+ + "\032 / \n \r MetadataEntry \ 022\013 \n \003 key \030 \001 \001 (\t \022 \r \n \005 value \030 "
153+ + "\002 \001 ( \t : \002 8 \ 001\" . \n \014 DebugOptions \022 \036 \n \026 enable_hot_ "
154+ + "key_logging \030 \001 \001 ( \010 *K \n \007 JobType \022 \024 \n \020 JOB_TYPE "
155+ + "_UNKNOWN \020 \000 \022 \022 \n \016 JOB_TYPE_BATCH \020 \001 \022 \026 \n \022 JOB_TY "
156+ + "PE_STREAMING \020 \002 *k \n \032 FlexResourceScheduling "
157+ + "Goal \ 022\026 \n \022 FLEXRS_UNSPECIFIED \020 \000 \022 \032 \n \026 FLEXRS_S "
158+ + "PEED_OPTIMIZED \020 \001 \022 \031 \n \025 FLEXRS_COST_OPTIMIZE "
159+ + "D \020 \002 *o \n \016 TeardownPolicy \022 \033 \n \027 TEARDOWN_POLICY "
160+ + "_UNKNOWN \020 \000 \022 \023 \n \017 TEARDOWN_ALWAYS \020 \001 \022 \027 \n \023 TEARD "
161+ + "OWN_ON_SUCCESS \020 \002 \022 \022 \n \016 TEARDOWN_NEVER \020 \003 * \220 \001 \n "
162+ + "\021 DefaultPackageSet \ 022\037 \n \033 DEFAULT_PACKAGE_SE "
163+ + "T_UNKNOWN \020 \000 \022 \034 \n \030 DEFAULT_PACKAGE_SET_NONE \020 "
164+ + "\001 \022 \034 \n \030 DEFAULT_PACKAGE_SET_JAVA \ 020\002 \022 \036 \n \032 DEFAU "
165+ + "LT_PACKAGE_SET_PYTHON \020 \003 *z\n \024 AutoscalingAl "
166+ + "gorithm \ 022! \n \035 AUTOSCALING_ALGORITHM_UNKNOWN "
167+ + "\020 \000 \022 \036 \n \032 AUTOSCALING_ALGORITHM_NONE \020 \ 001\022 \037 \n \033 AU "
168+ + "TOSCALING_ALGORITHM_BASIC \020 \002 *f\n \034 WorkerIPA "
169+ + "ddressConfiguration \ 022\031 \n \025 WORKER_IP_UNSPECI "
170+ + "FIED \020 \000 \022 \024 \n \020 WORKER_IP_PUBLIC \020 \001 \022 \025 \n \021 WORKER_I "
171+ + "P_PRIVATE \020 \002 *L \n \013 ShuffleMode \ 022\034 \n \030 SHUFFLE_MO "
172+ + "DE_UNSPECIFIED \020 \000 \022 \014 \n \010 VM_BASED \020 \001 \022 \021 \n \r SERVIC "
173+ + "E_BASED \020 \002 B \325 \001 \n \033 com.google. dataflow.v1beta "
174+ + "3B \020 EnvironmentProtoP \001 Z? google.golang.org"
175+ + "/genproto/googleapis/dataflow/ v1beta3;da "
176+ + "taflow \252 \002 \035 Google. Cloud. Dataflow.V1Beta3 \312 \002 "
177+ + "\035 Google \\ Cloud \\ Dataflow \\ V1beta3\352 \002 Google:"
178+ + ":Cloud::Dataflow::V1beta3b \006 proto3"
179179 };
180180 descriptor =
181181 com .google .protobuf .Descriptors .FileDescriptor .internalBuildGeneratedFileFrom (
@@ -278,7 +278,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
278278 new com .google .protobuf .GeneratedMessageV3 .FieldAccessorTable (
279279 internal_static_google_dataflow_v1beta3_SdkHarnessContainerImage_descriptor ,
280280 new java .lang .String [] {
281- "ContainerImage" , "UseSingleCorePerContainer" , "EnvironmentId" ,
281+ "ContainerImage" , "UseSingleCorePerContainer" , "EnvironmentId" , "Capabilities" ,
282282 });
283283 internal_static_google_dataflow_v1beta3_WorkerPool_descriptor =
284284 getDescriptor ().getMessageTypes ().get (7 );
0 commit comments