• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright 2020 Google LLC
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *     https://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 // Generated by the protocol buffer compiler.  DO NOT EDIT!
17 // source: google/dataflow/v1beta3/environment.proto
18 
19 package com.google.dataflow.v1beta3;
20 
21 /**
22  *
23  *
24  * <pre>
25  * Defines a SDK harness container for executing Dataflow pipelines.
26  * </pre>
27  *
28  * Protobuf type {@code google.dataflow.v1beta3.SdkHarnessContainerImage}
29  */
30 public final class SdkHarnessContainerImage extends com.google.protobuf.GeneratedMessageV3
31     implements
32     // @@protoc_insertion_point(message_implements:google.dataflow.v1beta3.SdkHarnessContainerImage)
33     SdkHarnessContainerImageOrBuilder {
34   private static final long serialVersionUID = 0L;
35   // Use SdkHarnessContainerImage.newBuilder() to construct.
SdkHarnessContainerImage(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)36   private SdkHarnessContainerImage(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
37     super(builder);
38   }
39 
SdkHarnessContainerImage()40   private SdkHarnessContainerImage() {
41     containerImage_ = "";
42     environmentId_ = "";
43     capabilities_ = com.google.protobuf.LazyStringArrayList.EMPTY;
44   }
45 
46   @java.lang.Override
47   @SuppressWarnings({"unused"})
newInstance(UnusedPrivateParameter unused)48   protected java.lang.Object newInstance(UnusedPrivateParameter unused) {
49     return new SdkHarnessContainerImage();
50   }
51 
52   @java.lang.Override
getUnknownFields()53   public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
54     return this.unknownFields;
55   }
56 
getDescriptor()57   public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
58     return com.google.dataflow.v1beta3.EnvironmentProto
59         .internal_static_google_dataflow_v1beta3_SdkHarnessContainerImage_descriptor;
60   }
61 
62   @java.lang.Override
63   protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()64       internalGetFieldAccessorTable() {
65     return com.google.dataflow.v1beta3.EnvironmentProto
66         .internal_static_google_dataflow_v1beta3_SdkHarnessContainerImage_fieldAccessorTable
67         .ensureFieldAccessorsInitialized(
68             com.google.dataflow.v1beta3.SdkHarnessContainerImage.class,
69             com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder.class);
70   }
71 
72   public static final int CONTAINER_IMAGE_FIELD_NUMBER = 1;
73 
74   @SuppressWarnings("serial")
75   private volatile java.lang.Object containerImage_ = "";
76   /**
77    *
78    *
79    * <pre>
80    * A docker container image that resides in Google Container Registry.
81    * </pre>
82    *
83    * <code>string container_image = 1;</code>
84    *
85    * @return The containerImage.
86    */
87   @java.lang.Override
getContainerImage()88   public java.lang.String getContainerImage() {
89     java.lang.Object ref = containerImage_;
90     if (ref instanceof java.lang.String) {
91       return (java.lang.String) ref;
92     } else {
93       com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
94       java.lang.String s = bs.toStringUtf8();
95       containerImage_ = s;
96       return s;
97     }
98   }
99   /**
100    *
101    *
102    * <pre>
103    * A docker container image that resides in Google Container Registry.
104    * </pre>
105    *
106    * <code>string container_image = 1;</code>
107    *
108    * @return The bytes for containerImage.
109    */
110   @java.lang.Override
getContainerImageBytes()111   public com.google.protobuf.ByteString getContainerImageBytes() {
112     java.lang.Object ref = containerImage_;
113     if (ref instanceof java.lang.String) {
114       com.google.protobuf.ByteString b =
115           com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
116       containerImage_ = b;
117       return b;
118     } else {
119       return (com.google.protobuf.ByteString) ref;
120     }
121   }
122 
123   public static final int USE_SINGLE_CORE_PER_CONTAINER_FIELD_NUMBER = 2;
124   private boolean useSingleCorePerContainer_ = false;
125   /**
126    *
127    *
128    * <pre>
129    * If true, recommends the Dataflow service to use only one core per SDK
130    * container instance with this image. If false (or unset) recommends using
131    * more than one core per SDK container instance with this image for
132    * efficiency. Note that Dataflow service may choose to override this property
133    * if needed.
134    * </pre>
135    *
136    * <code>bool use_single_core_per_container = 2;</code>
137    *
138    * @return The useSingleCorePerContainer.
139    */
140   @java.lang.Override
getUseSingleCorePerContainer()141   public boolean getUseSingleCorePerContainer() {
142     return useSingleCorePerContainer_;
143   }
144 
145   public static final int ENVIRONMENT_ID_FIELD_NUMBER = 3;
146 
147   @SuppressWarnings("serial")
148   private volatile java.lang.Object environmentId_ = "";
149   /**
150    *
151    *
152    * <pre>
153    * Environment ID for the Beam runner API proto Environment that corresponds
154    * to the current SDK Harness.
155    * </pre>
156    *
157    * <code>string environment_id = 3;</code>
158    *
159    * @return The environmentId.
160    */
161   @java.lang.Override
getEnvironmentId()162   public java.lang.String getEnvironmentId() {
163     java.lang.Object ref = environmentId_;
164     if (ref instanceof java.lang.String) {
165       return (java.lang.String) ref;
166     } else {
167       com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
168       java.lang.String s = bs.toStringUtf8();
169       environmentId_ = s;
170       return s;
171     }
172   }
173   /**
174    *
175    *
176    * <pre>
177    * Environment ID for the Beam runner API proto Environment that corresponds
178    * to the current SDK Harness.
179    * </pre>
180    *
181    * <code>string environment_id = 3;</code>
182    *
183    * @return The bytes for environmentId.
184    */
185   @java.lang.Override
getEnvironmentIdBytes()186   public com.google.protobuf.ByteString getEnvironmentIdBytes() {
187     java.lang.Object ref = environmentId_;
188     if (ref instanceof java.lang.String) {
189       com.google.protobuf.ByteString b =
190           com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
191       environmentId_ = b;
192       return b;
193     } else {
194       return (com.google.protobuf.ByteString) ref;
195     }
196   }
197 
198   public static final int CAPABILITIES_FIELD_NUMBER = 4;
199 
200   @SuppressWarnings("serial")
201   private com.google.protobuf.LazyStringList capabilities_;
202   /**
203    *
204    *
205    * <pre>
206    * The set of capabilities enumerated in the above Environment proto. See also
207    * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
208    * </pre>
209    *
210    * <code>repeated string capabilities = 4;</code>
211    *
212    * @return A list containing the capabilities.
213    */
getCapabilitiesList()214   public com.google.protobuf.ProtocolStringList getCapabilitiesList() {
215     return capabilities_;
216   }
217   /**
218    *
219    *
220    * <pre>
221    * The set of capabilities enumerated in the above Environment proto. See also
222    * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
223    * </pre>
224    *
225    * <code>repeated string capabilities = 4;</code>
226    *
227    * @return The count of capabilities.
228    */
getCapabilitiesCount()229   public int getCapabilitiesCount() {
230     return capabilities_.size();
231   }
232   /**
233    *
234    *
235    * <pre>
236    * The set of capabilities enumerated in the above Environment proto. See also
237    * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
238    * </pre>
239    *
240    * <code>repeated string capabilities = 4;</code>
241    *
242    * @param index The index of the element to return.
243    * @return The capabilities at the given index.
244    */
getCapabilities(int index)245   public java.lang.String getCapabilities(int index) {
246     return capabilities_.get(index);
247   }
248   /**
249    *
250    *
251    * <pre>
252    * The set of capabilities enumerated in the above Environment proto. See also
253    * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
254    * </pre>
255    *
256    * <code>repeated string capabilities = 4;</code>
257    *
258    * @param index The index of the value to return.
259    * @return The bytes of the capabilities at the given index.
260    */
getCapabilitiesBytes(int index)261   public com.google.protobuf.ByteString getCapabilitiesBytes(int index) {
262     return capabilities_.getByteString(index);
263   }
264 
265   private byte memoizedIsInitialized = -1;
266 
267   @java.lang.Override
isInitialized()268   public final boolean isInitialized() {
269     byte isInitialized = memoizedIsInitialized;
270     if (isInitialized == 1) return true;
271     if (isInitialized == 0) return false;
272 
273     memoizedIsInitialized = 1;
274     return true;
275   }
276 
277   @java.lang.Override
writeTo(com.google.protobuf.CodedOutputStream output)278   public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException {
279     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(containerImage_)) {
280       com.google.protobuf.GeneratedMessageV3.writeString(output, 1, containerImage_);
281     }
282     if (useSingleCorePerContainer_ != false) {
283       output.writeBool(2, useSingleCorePerContainer_);
284     }
285     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(environmentId_)) {
286       com.google.protobuf.GeneratedMessageV3.writeString(output, 3, environmentId_);
287     }
288     for (int i = 0; i < capabilities_.size(); i++) {
289       com.google.protobuf.GeneratedMessageV3.writeString(output, 4, capabilities_.getRaw(i));
290     }
291     getUnknownFields().writeTo(output);
292   }
293 
294   @java.lang.Override
getSerializedSize()295   public int getSerializedSize() {
296     int size = memoizedSize;
297     if (size != -1) return size;
298 
299     size = 0;
300     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(containerImage_)) {
301       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, containerImage_);
302     }
303     if (useSingleCorePerContainer_ != false) {
304       size += com.google.protobuf.CodedOutputStream.computeBoolSize(2, useSingleCorePerContainer_);
305     }
306     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(environmentId_)) {
307       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(3, environmentId_);
308     }
309     {
310       int dataSize = 0;
311       for (int i = 0; i < capabilities_.size(); i++) {
312         dataSize += computeStringSizeNoTag(capabilities_.getRaw(i));
313       }
314       size += dataSize;
315       size += 1 * getCapabilitiesList().size();
316     }
317     size += getUnknownFields().getSerializedSize();
318     memoizedSize = size;
319     return size;
320   }
321 
322   @java.lang.Override
equals(final java.lang.Object obj)323   public boolean equals(final java.lang.Object obj) {
324     if (obj == this) {
325       return true;
326     }
327     if (!(obj instanceof com.google.dataflow.v1beta3.SdkHarnessContainerImage)) {
328       return super.equals(obj);
329     }
330     com.google.dataflow.v1beta3.SdkHarnessContainerImage other =
331         (com.google.dataflow.v1beta3.SdkHarnessContainerImage) obj;
332 
333     if (!getContainerImage().equals(other.getContainerImage())) return false;
334     if (getUseSingleCorePerContainer() != other.getUseSingleCorePerContainer()) return false;
335     if (!getEnvironmentId().equals(other.getEnvironmentId())) return false;
336     if (!getCapabilitiesList().equals(other.getCapabilitiesList())) return false;
337     if (!getUnknownFields().equals(other.getUnknownFields())) return false;
338     return true;
339   }
340 
341   @java.lang.Override
hashCode()342   public int hashCode() {
343     if (memoizedHashCode != 0) {
344       return memoizedHashCode;
345     }
346     int hash = 41;
347     hash = (19 * hash) + getDescriptor().hashCode();
348     hash = (37 * hash) + CONTAINER_IMAGE_FIELD_NUMBER;
349     hash = (53 * hash) + getContainerImage().hashCode();
350     hash = (37 * hash) + USE_SINGLE_CORE_PER_CONTAINER_FIELD_NUMBER;
351     hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getUseSingleCorePerContainer());
352     hash = (37 * hash) + ENVIRONMENT_ID_FIELD_NUMBER;
353     hash = (53 * hash) + getEnvironmentId().hashCode();
354     if (getCapabilitiesCount() > 0) {
355       hash = (37 * hash) + CAPABILITIES_FIELD_NUMBER;
356       hash = (53 * hash) + getCapabilitiesList().hashCode();
357     }
358     hash = (29 * hash) + getUnknownFields().hashCode();
359     memoizedHashCode = hash;
360     return hash;
361   }
362 
parseFrom( java.nio.ByteBuffer data)363   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
364       java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException {
365     return PARSER.parseFrom(data);
366   }
367 
parseFrom( java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)368   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
369       java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
370       throws com.google.protobuf.InvalidProtocolBufferException {
371     return PARSER.parseFrom(data, extensionRegistry);
372   }
373 
parseFrom( com.google.protobuf.ByteString data)374   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
375       com.google.protobuf.ByteString data)
376       throws com.google.protobuf.InvalidProtocolBufferException {
377     return PARSER.parseFrom(data);
378   }
379 
parseFrom( com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)380   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
381       com.google.protobuf.ByteString data,
382       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
383       throws com.google.protobuf.InvalidProtocolBufferException {
384     return PARSER.parseFrom(data, extensionRegistry);
385   }
386 
parseFrom(byte[] data)387   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(byte[] data)
388       throws com.google.protobuf.InvalidProtocolBufferException {
389     return PARSER.parseFrom(data);
390   }
391 
parseFrom( byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)392   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
393       byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
394       throws com.google.protobuf.InvalidProtocolBufferException {
395     return PARSER.parseFrom(data, extensionRegistry);
396   }
397 
parseFrom( java.io.InputStream input)398   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
399       java.io.InputStream input) throws java.io.IOException {
400     return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input);
401   }
402 
parseFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)403   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
404       java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
405       throws java.io.IOException {
406     return com.google.protobuf.GeneratedMessageV3.parseWithIOException(
407         PARSER, input, extensionRegistry);
408   }
409 
parseDelimitedFrom( java.io.InputStream input)410   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseDelimitedFrom(
411       java.io.InputStream input) throws java.io.IOException {
412     return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(PARSER, input);
413   }
414 
parseDelimitedFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)415   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseDelimitedFrom(
416       java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
417       throws java.io.IOException {
418     return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(
419         PARSER, input, extensionRegistry);
420   }
421 
parseFrom( com.google.protobuf.CodedInputStream input)422   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
423       com.google.protobuf.CodedInputStream input) throws java.io.IOException {
424     return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input);
425   }
426 
parseFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)427   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage parseFrom(
428       com.google.protobuf.CodedInputStream input,
429       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
430       throws java.io.IOException {
431     return com.google.protobuf.GeneratedMessageV3.parseWithIOException(
432         PARSER, input, extensionRegistry);
433   }
434 
435   @java.lang.Override
newBuilderForType()436   public Builder newBuilderForType() {
437     return newBuilder();
438   }
439 
newBuilder()440   public static Builder newBuilder() {
441     return DEFAULT_INSTANCE.toBuilder();
442   }
443 
newBuilder(com.google.dataflow.v1beta3.SdkHarnessContainerImage prototype)444   public static Builder newBuilder(com.google.dataflow.v1beta3.SdkHarnessContainerImage prototype) {
445     return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
446   }
447 
448   @java.lang.Override
toBuilder()449   public Builder toBuilder() {
450     return this == DEFAULT_INSTANCE ? new Builder() : new Builder().mergeFrom(this);
451   }
452 
453   @java.lang.Override
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)454   protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
455     Builder builder = new Builder(parent);
456     return builder;
457   }
458   /**
459    *
460    *
461    * <pre>
462    * Defines a SDK harness container for executing Dataflow pipelines.
463    * </pre>
464    *
465    * Protobuf type {@code google.dataflow.v1beta3.SdkHarnessContainerImage}
466    */
467   public static final class Builder extends com.google.protobuf.GeneratedMessageV3.Builder<Builder>
468       implements
469       // @@protoc_insertion_point(builder_implements:google.dataflow.v1beta3.SdkHarnessContainerImage)
470       com.google.dataflow.v1beta3.SdkHarnessContainerImageOrBuilder {
getDescriptor()471     public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
472       return com.google.dataflow.v1beta3.EnvironmentProto
473           .internal_static_google_dataflow_v1beta3_SdkHarnessContainerImage_descriptor;
474     }
475 
476     @java.lang.Override
477     protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()478         internalGetFieldAccessorTable() {
479       return com.google.dataflow.v1beta3.EnvironmentProto
480           .internal_static_google_dataflow_v1beta3_SdkHarnessContainerImage_fieldAccessorTable
481           .ensureFieldAccessorsInitialized(
482               com.google.dataflow.v1beta3.SdkHarnessContainerImage.class,
483               com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder.class);
484     }
485 
486     // Construct using com.google.dataflow.v1beta3.SdkHarnessContainerImage.newBuilder()
Builder()487     private Builder() {}
488 
Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)489     private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
490       super(parent);
491     }
492 
493     @java.lang.Override
clear()494     public Builder clear() {
495       super.clear();
496       bitField0_ = 0;
497       containerImage_ = "";
498       useSingleCorePerContainer_ = false;
499       environmentId_ = "";
500       capabilities_ = com.google.protobuf.LazyStringArrayList.EMPTY;
501       bitField0_ = (bitField0_ & ~0x00000008);
502       return this;
503     }
504 
505     @java.lang.Override
getDescriptorForType()506     public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() {
507       return com.google.dataflow.v1beta3.EnvironmentProto
508           .internal_static_google_dataflow_v1beta3_SdkHarnessContainerImage_descriptor;
509     }
510 
511     @java.lang.Override
getDefaultInstanceForType()512     public com.google.dataflow.v1beta3.SdkHarnessContainerImage getDefaultInstanceForType() {
513       return com.google.dataflow.v1beta3.SdkHarnessContainerImage.getDefaultInstance();
514     }
515 
516     @java.lang.Override
build()517     public com.google.dataflow.v1beta3.SdkHarnessContainerImage build() {
518       com.google.dataflow.v1beta3.SdkHarnessContainerImage result = buildPartial();
519       if (!result.isInitialized()) {
520         throw newUninitializedMessageException(result);
521       }
522       return result;
523     }
524 
525     @java.lang.Override
buildPartial()526     public com.google.dataflow.v1beta3.SdkHarnessContainerImage buildPartial() {
527       com.google.dataflow.v1beta3.SdkHarnessContainerImage result =
528           new com.google.dataflow.v1beta3.SdkHarnessContainerImage(this);
529       buildPartialRepeatedFields(result);
530       if (bitField0_ != 0) {
531         buildPartial0(result);
532       }
533       onBuilt();
534       return result;
535     }
536 
buildPartialRepeatedFields( com.google.dataflow.v1beta3.SdkHarnessContainerImage result)537     private void buildPartialRepeatedFields(
538         com.google.dataflow.v1beta3.SdkHarnessContainerImage result) {
539       if (((bitField0_ & 0x00000008) != 0)) {
540         capabilities_ = capabilities_.getUnmodifiableView();
541         bitField0_ = (bitField0_ & ~0x00000008);
542       }
543       result.capabilities_ = capabilities_;
544     }
545 
buildPartial0(com.google.dataflow.v1beta3.SdkHarnessContainerImage result)546     private void buildPartial0(com.google.dataflow.v1beta3.SdkHarnessContainerImage result) {
547       int from_bitField0_ = bitField0_;
548       if (((from_bitField0_ & 0x00000001) != 0)) {
549         result.containerImage_ = containerImage_;
550       }
551       if (((from_bitField0_ & 0x00000002) != 0)) {
552         result.useSingleCorePerContainer_ = useSingleCorePerContainer_;
553       }
554       if (((from_bitField0_ & 0x00000004) != 0)) {
555         result.environmentId_ = environmentId_;
556       }
557     }
558 
559     @java.lang.Override
clone()560     public Builder clone() {
561       return super.clone();
562     }
563 
564     @java.lang.Override
setField( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)565     public Builder setField(
566         com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
567       return super.setField(field, value);
568     }
569 
570     @java.lang.Override
clearField(com.google.protobuf.Descriptors.FieldDescriptor field)571     public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
572       return super.clearField(field);
573     }
574 
575     @java.lang.Override
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)576     public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
577       return super.clearOneof(oneof);
578     }
579 
580     @java.lang.Override
setRepeatedField( com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value)581     public Builder setRepeatedField(
582         com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
583       return super.setRepeatedField(field, index, value);
584     }
585 
586     @java.lang.Override
addRepeatedField( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)587     public Builder addRepeatedField(
588         com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
589       return super.addRepeatedField(field, value);
590     }
591 
592     @java.lang.Override
mergeFrom(com.google.protobuf.Message other)593     public Builder mergeFrom(com.google.protobuf.Message other) {
594       if (other instanceof com.google.dataflow.v1beta3.SdkHarnessContainerImage) {
595         return mergeFrom((com.google.dataflow.v1beta3.SdkHarnessContainerImage) other);
596       } else {
597         super.mergeFrom(other);
598         return this;
599       }
600     }
601 
mergeFrom(com.google.dataflow.v1beta3.SdkHarnessContainerImage other)602     public Builder mergeFrom(com.google.dataflow.v1beta3.SdkHarnessContainerImage other) {
603       if (other == com.google.dataflow.v1beta3.SdkHarnessContainerImage.getDefaultInstance())
604         return this;
605       if (!other.getContainerImage().isEmpty()) {
606         containerImage_ = other.containerImage_;
607         bitField0_ |= 0x00000001;
608         onChanged();
609       }
610       if (other.getUseSingleCorePerContainer() != false) {
611         setUseSingleCorePerContainer(other.getUseSingleCorePerContainer());
612       }
613       if (!other.getEnvironmentId().isEmpty()) {
614         environmentId_ = other.environmentId_;
615         bitField0_ |= 0x00000004;
616         onChanged();
617       }
618       if (!other.capabilities_.isEmpty()) {
619         if (capabilities_.isEmpty()) {
620           capabilities_ = other.capabilities_;
621           bitField0_ = (bitField0_ & ~0x00000008);
622         } else {
623           ensureCapabilitiesIsMutable();
624           capabilities_.addAll(other.capabilities_);
625         }
626         onChanged();
627       }
628       this.mergeUnknownFields(other.getUnknownFields());
629       onChanged();
630       return this;
631     }
632 
633     @java.lang.Override
isInitialized()634     public final boolean isInitialized() {
635       return true;
636     }
637 
638     @java.lang.Override
mergeFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)639     public Builder mergeFrom(
640         com.google.protobuf.CodedInputStream input,
641         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
642         throws java.io.IOException {
643       if (extensionRegistry == null) {
644         throw new java.lang.NullPointerException();
645       }
646       try {
647         boolean done = false;
648         while (!done) {
649           int tag = input.readTag();
650           switch (tag) {
651             case 0:
652               done = true;
653               break;
654             case 10:
655               {
656                 containerImage_ = input.readStringRequireUtf8();
657                 bitField0_ |= 0x00000001;
658                 break;
659               } // case 10
660             case 16:
661               {
662                 useSingleCorePerContainer_ = input.readBool();
663                 bitField0_ |= 0x00000002;
664                 break;
665               } // case 16
666             case 26:
667               {
668                 environmentId_ = input.readStringRequireUtf8();
669                 bitField0_ |= 0x00000004;
670                 break;
671               } // case 26
672             case 34:
673               {
674                 java.lang.String s = input.readStringRequireUtf8();
675                 ensureCapabilitiesIsMutable();
676                 capabilities_.add(s);
677                 break;
678               } // case 34
679             default:
680               {
681                 if (!super.parseUnknownField(input, extensionRegistry, tag)) {
682                   done = true; // was an endgroup tag
683                 }
684                 break;
685               } // default:
686           } // switch (tag)
687         } // while (!done)
688       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
689         throw e.unwrapIOException();
690       } finally {
691         onChanged();
692       } // finally
693       return this;
694     }
695 
696     private int bitField0_;
697 
698     private java.lang.Object containerImage_ = "";
699     /**
700      *
701      *
702      * <pre>
703      * A docker container image that resides in Google Container Registry.
704      * </pre>
705      *
706      * <code>string container_image = 1;</code>
707      *
708      * @return The containerImage.
709      */
getContainerImage()710     public java.lang.String getContainerImage() {
711       java.lang.Object ref = containerImage_;
712       if (!(ref instanceof java.lang.String)) {
713         com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
714         java.lang.String s = bs.toStringUtf8();
715         containerImage_ = s;
716         return s;
717       } else {
718         return (java.lang.String) ref;
719       }
720     }
721     /**
722      *
723      *
724      * <pre>
725      * A docker container image that resides in Google Container Registry.
726      * </pre>
727      *
728      * <code>string container_image = 1;</code>
729      *
730      * @return The bytes for containerImage.
731      */
getContainerImageBytes()732     public com.google.protobuf.ByteString getContainerImageBytes() {
733       java.lang.Object ref = containerImage_;
734       if (ref instanceof String) {
735         com.google.protobuf.ByteString b =
736             com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
737         containerImage_ = b;
738         return b;
739       } else {
740         return (com.google.protobuf.ByteString) ref;
741       }
742     }
743     /**
744      *
745      *
746      * <pre>
747      * A docker container image that resides in Google Container Registry.
748      * </pre>
749      *
750      * <code>string container_image = 1;</code>
751      *
752      * @param value The containerImage to set.
753      * @return This builder for chaining.
754      */
setContainerImage(java.lang.String value)755     public Builder setContainerImage(java.lang.String value) {
756       if (value == null) {
757         throw new NullPointerException();
758       }
759       containerImage_ = value;
760       bitField0_ |= 0x00000001;
761       onChanged();
762       return this;
763     }
764     /**
765      *
766      *
767      * <pre>
768      * A docker container image that resides in Google Container Registry.
769      * </pre>
770      *
771      * <code>string container_image = 1;</code>
772      *
773      * @return This builder for chaining.
774      */
clearContainerImage()775     public Builder clearContainerImage() {
776       containerImage_ = getDefaultInstance().getContainerImage();
777       bitField0_ = (bitField0_ & ~0x00000001);
778       onChanged();
779       return this;
780     }
781     /**
782      *
783      *
784      * <pre>
785      * A docker container image that resides in Google Container Registry.
786      * </pre>
787      *
788      * <code>string container_image = 1;</code>
789      *
790      * @param value The bytes for containerImage to set.
791      * @return This builder for chaining.
792      */
setContainerImageBytes(com.google.protobuf.ByteString value)793     public Builder setContainerImageBytes(com.google.protobuf.ByteString value) {
794       if (value == null) {
795         throw new NullPointerException();
796       }
797       checkByteStringIsUtf8(value);
798       containerImage_ = value;
799       bitField0_ |= 0x00000001;
800       onChanged();
801       return this;
802     }
803 
804     private boolean useSingleCorePerContainer_;
805     /**
806      *
807      *
808      * <pre>
809      * If true, recommends the Dataflow service to use only one core per SDK
810      * container instance with this image. If false (or unset) recommends using
811      * more than one core per SDK container instance with this image for
812      * efficiency. Note that Dataflow service may choose to override this property
813      * if needed.
814      * </pre>
815      *
816      * <code>bool use_single_core_per_container = 2;</code>
817      *
818      * @return The useSingleCorePerContainer.
819      */
820     @java.lang.Override
getUseSingleCorePerContainer()821     public boolean getUseSingleCorePerContainer() {
822       return useSingleCorePerContainer_;
823     }
824     /**
825      *
826      *
827      * <pre>
828      * If true, recommends the Dataflow service to use only one core per SDK
829      * container instance with this image. If false (or unset) recommends using
830      * more than one core per SDK container instance with this image for
831      * efficiency. Note that Dataflow service may choose to override this property
832      * if needed.
833      * </pre>
834      *
835      * <code>bool use_single_core_per_container = 2;</code>
836      *
837      * @param value The useSingleCorePerContainer to set.
838      * @return This builder for chaining.
839      */
setUseSingleCorePerContainer(boolean value)840     public Builder setUseSingleCorePerContainer(boolean value) {
841 
842       useSingleCorePerContainer_ = value;
843       bitField0_ |= 0x00000002;
844       onChanged();
845       return this;
846     }
847     /**
848      *
849      *
850      * <pre>
851      * If true, recommends the Dataflow service to use only one core per SDK
852      * container instance with this image. If false (or unset) recommends using
853      * more than one core per SDK container instance with this image for
854      * efficiency. Note that Dataflow service may choose to override this property
855      * if needed.
856      * </pre>
857      *
858      * <code>bool use_single_core_per_container = 2;</code>
859      *
860      * @return This builder for chaining.
861      */
clearUseSingleCorePerContainer()862     public Builder clearUseSingleCorePerContainer() {
863       bitField0_ = (bitField0_ & ~0x00000002);
864       useSingleCorePerContainer_ = false;
865       onChanged();
866       return this;
867     }
868 
869     private java.lang.Object environmentId_ = "";
870     /**
871      *
872      *
873      * <pre>
874      * Environment ID for the Beam runner API proto Environment that corresponds
875      * to the current SDK Harness.
876      * </pre>
877      *
878      * <code>string environment_id = 3;</code>
879      *
880      * @return The environmentId.
881      */
getEnvironmentId()882     public java.lang.String getEnvironmentId() {
883       java.lang.Object ref = environmentId_;
884       if (!(ref instanceof java.lang.String)) {
885         com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
886         java.lang.String s = bs.toStringUtf8();
887         environmentId_ = s;
888         return s;
889       } else {
890         return (java.lang.String) ref;
891       }
892     }
893     /**
894      *
895      *
896      * <pre>
897      * Environment ID for the Beam runner API proto Environment that corresponds
898      * to the current SDK Harness.
899      * </pre>
900      *
901      * <code>string environment_id = 3;</code>
902      *
903      * @return The bytes for environmentId.
904      */
getEnvironmentIdBytes()905     public com.google.protobuf.ByteString getEnvironmentIdBytes() {
906       java.lang.Object ref = environmentId_;
907       if (ref instanceof String) {
908         com.google.protobuf.ByteString b =
909             com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
910         environmentId_ = b;
911         return b;
912       } else {
913         return (com.google.protobuf.ByteString) ref;
914       }
915     }
916     /**
917      *
918      *
919      * <pre>
920      * Environment ID for the Beam runner API proto Environment that corresponds
921      * to the current SDK Harness.
922      * </pre>
923      *
924      * <code>string environment_id = 3;</code>
925      *
926      * @param value The environmentId to set.
927      * @return This builder for chaining.
928      */
setEnvironmentId(java.lang.String value)929     public Builder setEnvironmentId(java.lang.String value) {
930       if (value == null) {
931         throw new NullPointerException();
932       }
933       environmentId_ = value;
934       bitField0_ |= 0x00000004;
935       onChanged();
936       return this;
937     }
938     /**
939      *
940      *
941      * <pre>
942      * Environment ID for the Beam runner API proto Environment that corresponds
943      * to the current SDK Harness.
944      * </pre>
945      *
946      * <code>string environment_id = 3;</code>
947      *
948      * @return This builder for chaining.
949      */
clearEnvironmentId()950     public Builder clearEnvironmentId() {
951       environmentId_ = getDefaultInstance().getEnvironmentId();
952       bitField0_ = (bitField0_ & ~0x00000004);
953       onChanged();
954       return this;
955     }
956     /**
957      *
958      *
959      * <pre>
960      * Environment ID for the Beam runner API proto Environment that corresponds
961      * to the current SDK Harness.
962      * </pre>
963      *
964      * <code>string environment_id = 3;</code>
965      *
966      * @param value The bytes for environmentId to set.
967      * @return This builder for chaining.
968      */
setEnvironmentIdBytes(com.google.protobuf.ByteString value)969     public Builder setEnvironmentIdBytes(com.google.protobuf.ByteString value) {
970       if (value == null) {
971         throw new NullPointerException();
972       }
973       checkByteStringIsUtf8(value);
974       environmentId_ = value;
975       bitField0_ |= 0x00000004;
976       onChanged();
977       return this;
978     }
979 
980     private com.google.protobuf.LazyStringList capabilities_ =
981         com.google.protobuf.LazyStringArrayList.EMPTY;
982 
ensureCapabilitiesIsMutable()983     private void ensureCapabilitiesIsMutable() {
984       if (!((bitField0_ & 0x00000008) != 0)) {
985         capabilities_ = new com.google.protobuf.LazyStringArrayList(capabilities_);
986         bitField0_ |= 0x00000008;
987       }
988     }
989     /**
990      *
991      *
992      * <pre>
993      * The set of capabilities enumerated in the above Environment proto. See also
994      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
995      * </pre>
996      *
997      * <code>repeated string capabilities = 4;</code>
998      *
999      * @return A list containing the capabilities.
1000      */
getCapabilitiesList()1001     public com.google.protobuf.ProtocolStringList getCapabilitiesList() {
1002       return capabilities_.getUnmodifiableView();
1003     }
1004     /**
1005      *
1006      *
1007      * <pre>
1008      * The set of capabilities enumerated in the above Environment proto. See also
1009      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
1010      * </pre>
1011      *
1012      * <code>repeated string capabilities = 4;</code>
1013      *
1014      * @return The count of capabilities.
1015      */
getCapabilitiesCount()1016     public int getCapabilitiesCount() {
1017       return capabilities_.size();
1018     }
1019     /**
1020      *
1021      *
1022      * <pre>
1023      * The set of capabilities enumerated in the above Environment proto. See also
1024      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
1025      * </pre>
1026      *
1027      * <code>repeated string capabilities = 4;</code>
1028      *
1029      * @param index The index of the element to return.
1030      * @return The capabilities at the given index.
1031      */
getCapabilities(int index)1032     public java.lang.String getCapabilities(int index) {
1033       return capabilities_.get(index);
1034     }
1035     /**
1036      *
1037      *
1038      * <pre>
1039      * The set of capabilities enumerated in the above Environment proto. See also
1040      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
1041      * </pre>
1042      *
1043      * <code>repeated string capabilities = 4;</code>
1044      *
1045      * @param index The index of the value to return.
1046      * @return The bytes of the capabilities at the given index.
1047      */
getCapabilitiesBytes(int index)1048     public com.google.protobuf.ByteString getCapabilitiesBytes(int index) {
1049       return capabilities_.getByteString(index);
1050     }
1051     /**
1052      *
1053      *
1054      * <pre>
1055      * The set of capabilities enumerated in the above Environment proto. See also
1056      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
1057      * </pre>
1058      *
1059      * <code>repeated string capabilities = 4;</code>
1060      *
1061      * @param index The index to set the value at.
1062      * @param value The capabilities to set.
1063      * @return This builder for chaining.
1064      */
setCapabilities(int index, java.lang.String value)1065     public Builder setCapabilities(int index, java.lang.String value) {
1066       if (value == null) {
1067         throw new NullPointerException();
1068       }
1069       ensureCapabilitiesIsMutable();
1070       capabilities_.set(index, value);
1071       onChanged();
1072       return this;
1073     }
1074     /**
1075      *
1076      *
1077      * <pre>
1078      * The set of capabilities enumerated in the above Environment proto. See also
1079      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
1080      * </pre>
1081      *
1082      * <code>repeated string capabilities = 4;</code>
1083      *
1084      * @param value The capabilities to add.
1085      * @return This builder for chaining.
1086      */
addCapabilities(java.lang.String value)1087     public Builder addCapabilities(java.lang.String value) {
1088       if (value == null) {
1089         throw new NullPointerException();
1090       }
1091       ensureCapabilitiesIsMutable();
1092       capabilities_.add(value);
1093       onChanged();
1094       return this;
1095     }
1096     /**
1097      *
1098      *
1099      * <pre>
1100      * The set of capabilities enumerated in the above Environment proto. See also
1101      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
1102      * </pre>
1103      *
1104      * <code>repeated string capabilities = 4;</code>
1105      *
1106      * @param values The capabilities to add.
1107      * @return This builder for chaining.
1108      */
addAllCapabilities(java.lang.Iterable<java.lang.String> values)1109     public Builder addAllCapabilities(java.lang.Iterable<java.lang.String> values) {
1110       ensureCapabilitiesIsMutable();
1111       com.google.protobuf.AbstractMessageLite.Builder.addAll(values, capabilities_);
1112       onChanged();
1113       return this;
1114     }
1115     /**
1116      *
1117      *
1118      * <pre>
1119      * The set of capabilities enumerated in the above Environment proto. See also
1120      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
1121      * </pre>
1122      *
1123      * <code>repeated string capabilities = 4;</code>
1124      *
1125      * @return This builder for chaining.
1126      */
clearCapabilities()1127     public Builder clearCapabilities() {
1128       capabilities_ = com.google.protobuf.LazyStringArrayList.EMPTY;
1129       bitField0_ = (bitField0_ & ~0x00000008);
1130       onChanged();
1131       return this;
1132     }
1133     /**
1134      *
1135      *
1136      * <pre>
1137      * The set of capabilities enumerated in the above Environment proto. See also
1138      * https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
1139      * </pre>
1140      *
1141      * <code>repeated string capabilities = 4;</code>
1142      *
1143      * @param value The bytes of the capabilities to add.
1144      * @return This builder for chaining.
1145      */
addCapabilitiesBytes(com.google.protobuf.ByteString value)1146     public Builder addCapabilitiesBytes(com.google.protobuf.ByteString value) {
1147       if (value == null) {
1148         throw new NullPointerException();
1149       }
1150       checkByteStringIsUtf8(value);
1151       ensureCapabilitiesIsMutable();
1152       capabilities_.add(value);
1153       onChanged();
1154       return this;
1155     }
1156 
1157     @java.lang.Override
setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields)1158     public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
1159       return super.setUnknownFields(unknownFields);
1160     }
1161 
1162     @java.lang.Override
mergeUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields)1163     public final Builder mergeUnknownFields(
1164         final com.google.protobuf.UnknownFieldSet unknownFields) {
1165       return super.mergeUnknownFields(unknownFields);
1166     }
1167 
1168     // @@protoc_insertion_point(builder_scope:google.dataflow.v1beta3.SdkHarnessContainerImage)
1169   }
1170 
1171   // @@protoc_insertion_point(class_scope:google.dataflow.v1beta3.SdkHarnessContainerImage)
1172   private static final com.google.dataflow.v1beta3.SdkHarnessContainerImage DEFAULT_INSTANCE;
1173 
1174   static {
1175     DEFAULT_INSTANCE = new com.google.dataflow.v1beta3.SdkHarnessContainerImage();
1176   }
1177 
getDefaultInstance()1178   public static com.google.dataflow.v1beta3.SdkHarnessContainerImage getDefaultInstance() {
1179     return DEFAULT_INSTANCE;
1180   }
1181 
1182   private static final com.google.protobuf.Parser<SdkHarnessContainerImage> PARSER =
1183       new com.google.protobuf.AbstractParser<SdkHarnessContainerImage>() {
1184         @java.lang.Override
1185         public SdkHarnessContainerImage parsePartialFrom(
1186             com.google.protobuf.CodedInputStream input,
1187             com.google.protobuf.ExtensionRegistryLite extensionRegistry)
1188             throws com.google.protobuf.InvalidProtocolBufferException {
1189           Builder builder = newBuilder();
1190           try {
1191             builder.mergeFrom(input, extensionRegistry);
1192           } catch (com.google.protobuf.InvalidProtocolBufferException e) {
1193             throw e.setUnfinishedMessage(builder.buildPartial());
1194           } catch (com.google.protobuf.UninitializedMessageException e) {
1195             throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
1196           } catch (java.io.IOException e) {
1197             throw new com.google.protobuf.InvalidProtocolBufferException(e)
1198                 .setUnfinishedMessage(builder.buildPartial());
1199           }
1200           return builder.buildPartial();
1201         }
1202       };
1203 
parser()1204   public static com.google.protobuf.Parser<SdkHarnessContainerImage> parser() {
1205     return PARSER;
1206   }
1207 
1208   @java.lang.Override
getParserForType()1209   public com.google.protobuf.Parser<SdkHarnessContainerImage> getParserForType() {
1210     return PARSER;
1211   }
1212 
1213   @java.lang.Override
getDefaultInstanceForType()1214   public com.google.dataflow.v1beta3.SdkHarnessContainerImage getDefaultInstanceForType() {
1215     return DEFAULT_INSTANCE;
1216   }
1217 }
1218