View Javadoc
1   // Generated by the protocol buffer compiler.  DO NOT EDIT!
2   // source: CDCRequestProtocol.proto
3   
4   package org.apache.shardingsphere.data.pipeline.cdc.protocol.request;
5   
6   /**
7    * Protobuf type {@code StopStreamingRequestBody}
8    */
9   public final class StopStreamingRequestBody extends
10      com.google.protobuf.GeneratedMessageV3 implements
11      // @@protoc_insertion_point(message_implements:StopStreamingRequestBody)
12      StopStreamingRequestBodyOrBuilder {
13  private static final long serialVersionUID = 0L;
14    // Use StopStreamingRequestBody.newBuilder() to construct.
15    private StopStreamingRequestBody(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
16      super(builder);
17    }
18    private StopStreamingRequestBody() {
19      streamingId_ = "";
20    }
21  
22    @java.lang.Override
23    @SuppressWarnings({"unused"})
24    protected java.lang.Object newInstance(
25        UnusedPrivateParameter unused) {
26      return new StopStreamingRequestBody();
27    }
28  
29    @java.lang.Override
30    public final com.google.protobuf.UnknownFieldSet
31    getUnknownFields() {
32      return this.unknownFields;
33    }
34    public static final com.google.protobuf.Descriptors.Descriptor
35        getDescriptor() {
36      return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StopStreamingRequestBody_descriptor;
37    }
38  
39    @java.lang.Override
40    protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
41        internalGetFieldAccessorTable() {
42      return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StopStreamingRequestBody_fieldAccessorTable
43          .ensureFieldAccessorsInitialized(
44              org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.class, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.Builder.class);
45    }
46  
47    public static final int STREAMING_ID_FIELD_NUMBER = 1;
48    @SuppressWarnings("serial")
49    private volatile java.lang.Object streamingId_ = "";
50    /**
51     * <code>string streaming_id = 1;</code>
52     * @return The streamingId.
53     */
54    @java.lang.Override
55    public java.lang.String getStreamingId() {
56      java.lang.Object ref = streamingId_;
57      if (ref instanceof java.lang.String) {
58        return (java.lang.String) ref;
59      } else {
60        com.google.protobuf.ByteString bs = 
61            (com.google.protobuf.ByteString) ref;
62        java.lang.String s = bs.toStringUtf8();
63        streamingId_ = s;
64        return s;
65      }
66    }
67    /**
68     * <code>string streaming_id = 1;</code>
69     * @return The bytes for streamingId.
70     */
71    @java.lang.Override
72    public com.google.protobuf.ByteString
73        getStreamingIdBytes() {
74      java.lang.Object ref = streamingId_;
75      if (ref instanceof java.lang.String) {
76        com.google.protobuf.ByteString b = 
77            com.google.protobuf.ByteString.copyFromUtf8(
78                (java.lang.String) ref);
79        streamingId_ = b;
80        return b;
81      } else {
82        return (com.google.protobuf.ByteString) ref;
83      }
84    }
85  
86    private byte memoizedIsInitialized = -1;
87    @java.lang.Override
88    public final boolean isInitialized() {
89      byte isInitialized = memoizedIsInitialized;
90      if (isInitialized == 1) return true;
91      if (isInitialized == 0) return false;
92  
93      memoizedIsInitialized = 1;
94      return true;
95    }
96  
97    @java.lang.Override
98    public void writeTo(com.google.protobuf.CodedOutputStream output)
99                        throws java.io.IOException {
100     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(streamingId_)) {
101       com.google.protobuf.GeneratedMessageV3.writeString(output, 1, streamingId_);
102     }
103     getUnknownFields().writeTo(output);
104   }
105 
106   @java.lang.Override
107   public int getSerializedSize() {
108     int size = memoizedSize;
109     if (size != -1) return size;
110 
111     size = 0;
112     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(streamingId_)) {
113       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, streamingId_);
114     }
115     size += getUnknownFields().getSerializedSize();
116     memoizedSize = size;
117     return size;
118   }
119 
120   @java.lang.Override
121   public boolean equals(final java.lang.Object obj) {
122     if (obj == this) {
123      return true;
124     }
125     if (!(obj instanceof org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody)) {
126       return super.equals(obj);
127     }
128     org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody other = (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) obj;
129 
130     if (!getStreamingId()
131         .equals(other.getStreamingId())) return false;
132     if (!getUnknownFields().equals(other.getUnknownFields())) return false;
133     return true;
134   }
135 
136   @java.lang.Override
137   public int hashCode() {
138     if (memoizedHashCode != 0) {
139       return memoizedHashCode;
140     }
141     int hash = 41;
142     hash = (19 * hash) + getDescriptor().hashCode();
143     hash = (37 * hash) + STREAMING_ID_FIELD_NUMBER;
144     hash = (53 * hash) + getStreamingId().hashCode();
145     hash = (29 * hash) + getUnknownFields().hashCode();
146     memoizedHashCode = hash;
147     return hash;
148   }
149 
150   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(
151       java.nio.ByteBuffer data)
152       throws com.google.protobuf.InvalidProtocolBufferException {
153     return PARSER.parseFrom(data);
154   }
155   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(
156       java.nio.ByteBuffer data,
157       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
158       throws com.google.protobuf.InvalidProtocolBufferException {
159     return PARSER.parseFrom(data, extensionRegistry);
160   }
161   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(
162       com.google.protobuf.ByteString data)
163       throws com.google.protobuf.InvalidProtocolBufferException {
164     return PARSER.parseFrom(data);
165   }
166   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(
167       com.google.protobuf.ByteString data,
168       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
169       throws com.google.protobuf.InvalidProtocolBufferException {
170     return PARSER.parseFrom(data, extensionRegistry);
171   }
172   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(byte[] data)
173       throws com.google.protobuf.InvalidProtocolBufferException {
174     return PARSER.parseFrom(data);
175   }
176   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(
177       byte[] data,
178       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
179       throws com.google.protobuf.InvalidProtocolBufferException {
180     return PARSER.parseFrom(data, extensionRegistry);
181   }
182   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(java.io.InputStream input)
183       throws java.io.IOException {
184     return com.google.protobuf.GeneratedMessageV3
185         .parseWithIOException(PARSER, input);
186   }
187   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(
188       java.io.InputStream input,
189       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
190       throws java.io.IOException {
191     return com.google.protobuf.GeneratedMessageV3
192         .parseWithIOException(PARSER, input, extensionRegistry);
193   }
194   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseDelimitedFrom(java.io.InputStream input)
195       throws java.io.IOException {
196     return com.google.protobuf.GeneratedMessageV3
197         .parseDelimitedWithIOException(PARSER, input);
198   }
199   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseDelimitedFrom(
200       java.io.InputStream input,
201       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
202       throws java.io.IOException {
203     return com.google.protobuf.GeneratedMessageV3
204         .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
205   }
206   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(
207       com.google.protobuf.CodedInputStream input)
208       throws java.io.IOException {
209     return com.google.protobuf.GeneratedMessageV3
210         .parseWithIOException(PARSER, input);
211   }
212   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody parseFrom(
213       com.google.protobuf.CodedInputStream input,
214       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
215       throws java.io.IOException {
216     return com.google.protobuf.GeneratedMessageV3
217         .parseWithIOException(PARSER, input, extensionRegistry);
218   }
219 
220   @java.lang.Override
221   public Builder newBuilderForType() { return newBuilder(); }
222   public static Builder newBuilder() {
223     return DEFAULT_INSTANCE.toBuilder();
224   }
225   public static Builder newBuilder(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody prototype) {
226     return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
227   }
228   @java.lang.Override
229   public Builder toBuilder() {
230     return this == DEFAULT_INSTANCE
231         ? new Builder() : new Builder().mergeFrom(this);
232   }
233 
234   @java.lang.Override
235   protected Builder newBuilderForType(
236       com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
237     Builder builder = new Builder(parent);
238     return builder;
239   }
240   /**
241    * Protobuf type {@code StopStreamingRequestBody}
242    */
243   public static final class Builder extends
244       com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
245       // @@protoc_insertion_point(builder_implements:StopStreamingRequestBody)
246       org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBodyOrBuilder {
247     public static final com.google.protobuf.Descriptors.Descriptor
248         getDescriptor() {
249       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StopStreamingRequestBody_descriptor;
250     }
251 
252     @java.lang.Override
253     protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
254         internalGetFieldAccessorTable() {
255       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StopStreamingRequestBody_fieldAccessorTable
256           .ensureFieldAccessorsInitialized(
257               org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.class, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.Builder.class);
258     }
259 
260     // Construct using org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.newBuilder()
261     private Builder() {
262 
263     }
264 
265     private Builder(
266         com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
267       super(parent);
268 
269     }
270     @java.lang.Override
271     public Builder clear() {
272       super.clear();
273       bitField0_ = 0;
274       streamingId_ = "";
275       return this;
276     }
277 
278     @java.lang.Override
279     public com.google.protobuf.Descriptors.Descriptor
280         getDescriptorForType() {
281       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StopStreamingRequestBody_descriptor;
282     }
283 
284     @java.lang.Override
285     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody getDefaultInstanceForType() {
286       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance();
287     }
288 
289     @java.lang.Override
290     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody build() {
291       org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody result = buildPartial();
292       if (!result.isInitialized()) {
293         throw newUninitializedMessageException(result);
294       }
295       return result;
296     }
297 
298     @java.lang.Override
299     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody buildPartial() {
300       org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody result = new org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody(this);
301       if (bitField0_ != 0) { buildPartial0(result); }
302       onBuilt();
303       return result;
304     }
305 
306     private void buildPartial0(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody result) {
307       int from_bitField0_ = bitField0_;
308       if (((from_bitField0_ & 0x00000001) != 0)) {
309         result.streamingId_ = streamingId_;
310       }
311     }
312 
313     @java.lang.Override
314     public Builder clone() {
315       return super.clone();
316     }
317     @java.lang.Override
318     public Builder setField(
319         com.google.protobuf.Descriptors.FieldDescriptor field,
320         java.lang.Object value) {
321       return super.setField(field, value);
322     }
323     @java.lang.Override
324     public Builder clearField(
325         com.google.protobuf.Descriptors.FieldDescriptor field) {
326       return super.clearField(field);
327     }
328     @java.lang.Override
329     public Builder clearOneof(
330         com.google.protobuf.Descriptors.OneofDescriptor oneof) {
331       return super.clearOneof(oneof);
332     }
333     @java.lang.Override
334     public Builder setRepeatedField(
335         com.google.protobuf.Descriptors.FieldDescriptor field,
336         int index, java.lang.Object value) {
337       return super.setRepeatedField(field, index, value);
338     }
339     @java.lang.Override
340     public Builder addRepeatedField(
341         com.google.protobuf.Descriptors.FieldDescriptor field,
342         java.lang.Object value) {
343       return super.addRepeatedField(field, value);
344     }
345     @java.lang.Override
346     public Builder mergeFrom(com.google.protobuf.Message other) {
347       if (other instanceof org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) {
348         return mergeFrom((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody)other);
349       } else {
350         super.mergeFrom(other);
351         return this;
352       }
353     }
354 
355     public Builder mergeFrom(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody other) {
356       if (other == org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance()) return this;
357       if (!other.getStreamingId().isEmpty()) {
358         streamingId_ = other.streamingId_;
359         bitField0_ |= 0x00000001;
360         onChanged();
361       }
362       this.mergeUnknownFields(other.getUnknownFields());
363       onChanged();
364       return this;
365     }
366 
367     @java.lang.Override
368     public final boolean isInitialized() {
369       return true;
370     }
371 
372     @java.lang.Override
373     public Builder mergeFrom(
374         com.google.protobuf.CodedInputStream input,
375         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
376         throws java.io.IOException {
377       if (extensionRegistry == null) {
378         throw new java.lang.NullPointerException();
379       }
380       try {
381         boolean done = false;
382         while (!done) {
383           int tag = input.readTag();
384           switch (tag) {
385             case 0:
386               done = true;
387               break;
388             case 10: {
389               streamingId_ = input.readStringRequireUtf8();
390               bitField0_ |= 0x00000001;
391               break;
392             } // case 10
393             default: {
394               if (!super.parseUnknownField(input, extensionRegistry, tag)) {
395                 done = true; // was an endgroup tag
396               }
397               break;
398             } // default:
399           } // switch (tag)
400         } // while (!done)
401       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
402         throw e.unwrapIOException();
403       } finally {
404         onChanged();
405       } // finally
406       return this;
407     }
408     private int bitField0_;
409 
410     private java.lang.Object streamingId_ = "";
411     /**
412      * <code>string streaming_id = 1;</code>
413      * @return The streamingId.
414      */
415     public java.lang.String getStreamingId() {
416       java.lang.Object ref = streamingId_;
417       if (!(ref instanceof java.lang.String)) {
418         com.google.protobuf.ByteString bs =
419             (com.google.protobuf.ByteString) ref;
420         java.lang.String s = bs.toStringUtf8();
421         streamingId_ = s;
422         return s;
423       } else {
424         return (java.lang.String) ref;
425       }
426     }
427     /**
428      * <code>string streaming_id = 1;</code>
429      * @return The bytes for streamingId.
430      */
431     public com.google.protobuf.ByteString
432         getStreamingIdBytes() {
433       java.lang.Object ref = streamingId_;
434       if (ref instanceof String) {
435         com.google.protobuf.ByteString b = 
436             com.google.protobuf.ByteString.copyFromUtf8(
437                 (java.lang.String) ref);
438         streamingId_ = b;
439         return b;
440       } else {
441         return (com.google.protobuf.ByteString) ref;
442       }
443     }
444     /**
445      * <code>string streaming_id = 1;</code>
446      * @param value The streamingId to set.
447      * @return This builder for chaining.
448      */
449     public Builder setStreamingId(
450         java.lang.String value) {
451       if (value == null) { throw new NullPointerException(); }
452       streamingId_ = value;
453       bitField0_ |= 0x00000001;
454       onChanged();
455       return this;
456     }
457     /**
458      * <code>string streaming_id = 1;</code>
459      * @return This builder for chaining.
460      */
461     public Builder clearStreamingId() {
462       streamingId_ = getDefaultInstance().getStreamingId();
463       bitField0_ = (bitField0_ & ~0x00000001);
464       onChanged();
465       return this;
466     }
467     /**
468      * <code>string streaming_id = 1;</code>
469      * @param value The bytes for streamingId to set.
470      * @return This builder for chaining.
471      */
472     public Builder setStreamingIdBytes(
473         com.google.protobuf.ByteString value) {
474       if (value == null) { throw new NullPointerException(); }
475       checkByteStringIsUtf8(value);
476       streamingId_ = value;
477       bitField0_ |= 0x00000001;
478       onChanged();
479       return this;
480     }
481     @java.lang.Override
482     public final Builder setUnknownFields(
483         final com.google.protobuf.UnknownFieldSet unknownFields) {
484       return super.setUnknownFields(unknownFields);
485     }
486 
487     @java.lang.Override
488     public final Builder mergeUnknownFields(
489         final com.google.protobuf.UnknownFieldSet unknownFields) {
490       return super.mergeUnknownFields(unknownFields);
491     }
492 
493 
494     // @@protoc_insertion_point(builder_scope:StopStreamingRequestBody)
495   }
496 
497   // @@protoc_insertion_point(class_scope:StopStreamingRequestBody)
498   private static final org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody DEFAULT_INSTANCE;
499   static {
500     DEFAULT_INSTANCE = new org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody();
501   }
502 
503   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody getDefaultInstance() {
504     return DEFAULT_INSTANCE;
505   }
506 
507   private static final com.google.protobuf.Parser<StopStreamingRequestBody>
508       PARSER = new com.google.protobuf.AbstractParser<StopStreamingRequestBody>() {
509     @java.lang.Override
510     public StopStreamingRequestBody parsePartialFrom(
511         com.google.protobuf.CodedInputStream input,
512         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
513         throws com.google.protobuf.InvalidProtocolBufferException {
514       Builder builder = newBuilder();
515       try {
516         builder.mergeFrom(input, extensionRegistry);
517       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
518         throw e.setUnfinishedMessage(builder.buildPartial());
519       } catch (com.google.protobuf.UninitializedMessageException e) {
520         throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
521       } catch (java.io.IOException e) {
522         throw new com.google.protobuf.InvalidProtocolBufferException(e)
523             .setUnfinishedMessage(builder.buildPartial());
524       }
525       return builder.buildPartial();
526     }
527   };
528 
529   public static com.google.protobuf.Parser<StopStreamingRequestBody> parser() {
530     return PARSER;
531   }
532 
533   @java.lang.Override
534   public com.google.protobuf.Parser<StopStreamingRequestBody> getParserForType() {
535     return PARSER;
536   }
537 
538   @java.lang.Override
539   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody getDefaultInstanceForType() {
540     return DEFAULT_INSTANCE;
541   }
542 
543 }
544