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