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 CDCRequest}
9    */
10  public final class CDCRequest extends
11      com.google.protobuf.GeneratedMessageV3 implements
12      // @@protoc_insertion_point(message_implements:CDCRequest)
13      CDCRequestOrBuilder {
14  private static final long serialVersionUID = 0L;
15    // Use CDCRequest.newBuilder() to construct.
16    private CDCRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
17      super(builder);
18    }
19    private CDCRequest() {
20      requestId_ = "";
21      type_ = 0;
22    }
23  
24    @java.lang.Override
25    @SuppressWarnings({"unused"})
26    protected java.lang.Object newInstance(
27        UnusedPrivateParameter unused) {
28      return new CDCRequest();
29    }
30  
31    public static final com.google.protobuf.Descriptors.Descriptor
32        getDescriptor() {
33      return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_CDCRequest_descriptor;
34    }
35  
36    @java.lang.Override
37    protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
38        internalGetFieldAccessorTable() {
39      return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_CDCRequest_fieldAccessorTable
40          .ensureFieldAccessorsInitialized(
41              org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.class, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Builder.class);
42    }
43  
44    /**
45     * Protobuf enum {@code CDCRequest.Type}
46     */
47    public enum Type
48        implements com.google.protobuf.ProtocolMessageEnum {
49      /**
50       * <code>UNKNOWN = 0;</code>
51       */
52      UNKNOWN(0),
53      /**
54       * <code>LOGIN = 1;</code>
55       */
56      LOGIN(1),
57      /**
58       * <code>STREAM_DATA = 2;</code>
59       */
60      STREAM_DATA(2),
61      /**
62       * <code>ACK_STREAMING = 3;</code>
63       */
64      ACK_STREAMING(3),
65      /**
66       * <code>STOP_STREAMING = 4;</code>
67       */
68      STOP_STREAMING(4),
69      /**
70       * <code>START_STREAMING = 5;</code>
71       */
72      START_STREAMING(5),
73      /**
74       * <code>DROP_STREAMING = 6;</code>
75       */
76      DROP_STREAMING(6),
77      UNRECOGNIZED(-1),
78      ;
79  
80      /**
81       * <code>UNKNOWN = 0;</code>
82       */
83      public static final int UNKNOWN_VALUE = 0;
84      /**
85       * <code>LOGIN = 1;</code>
86       */
87      public static final int LOGIN_VALUE = 1;
88      /**
89       * <code>STREAM_DATA = 2;</code>
90       */
91      public static final int STREAM_DATA_VALUE = 2;
92      /**
93       * <code>ACK_STREAMING = 3;</code>
94       */
95      public static final int ACK_STREAMING_VALUE = 3;
96      /**
97       * <code>STOP_STREAMING = 4;</code>
98       */
99      public static final int STOP_STREAMING_VALUE = 4;
100     /**
101      * <code>START_STREAMING = 5;</code>
102      */
103     public static final int START_STREAMING_VALUE = 5;
104     /**
105      * <code>DROP_STREAMING = 6;</code>
106      */
107     public static final int DROP_STREAMING_VALUE = 6;
108 
109 
110     public final int getNumber() {
111       if (this == UNRECOGNIZED) {
112         throw new java.lang.IllegalArgumentException(
113             "Can't get the number of an unknown enum value.");
114       }
115       return value;
116     }
117 
118     /**
119      * @param value The numeric wire value of the corresponding enum entry.
120      * @return The enum associated with the given numeric wire value.
121      * @deprecated Use {@link #forNumber(int)} instead.
122      */
123     @java.lang.Deprecated
124     public static Type valueOf(int value) {
125       return forNumber(value);
126     }
127 
128     /**
129      * @param value The numeric wire value of the corresponding enum entry.
130      * @return The enum associated with the given numeric wire value.
131      */
132     public static Type forNumber(int value) {
133       switch (value) {
134         case 0: return UNKNOWN;
135         case 1: return LOGIN;
136         case 2: return STREAM_DATA;
137         case 3: return ACK_STREAMING;
138         case 4: return STOP_STREAMING;
139         case 5: return START_STREAMING;
140         case 6: return DROP_STREAMING;
141         default: return null;
142       }
143     }
144 
145     public static com.google.protobuf.Internal.EnumLiteMap<Type>
146         internalGetValueMap() {
147       return internalValueMap;
148     }
149     private static final com.google.protobuf.Internal.EnumLiteMap<
150         Type> internalValueMap =
151           new com.google.protobuf.Internal.EnumLiteMap<Type>() {
152             public Type findValueByNumber(int number) {
153               return Type.forNumber(number);
154             }
155           };
156 
157     public final com.google.protobuf.Descriptors.EnumValueDescriptor
158         getValueDescriptor() {
159       if (this == UNRECOGNIZED) {
160         throw new java.lang.IllegalStateException(
161             "Can't get the descriptor of an unrecognized enum value.");
162       }
163       return getDescriptor().getValues().get(ordinal());
164     }
165     public final com.google.protobuf.Descriptors.EnumDescriptor
166         getDescriptorForType() {
167       return getDescriptor();
168     }
169     public static final com.google.protobuf.Descriptors.EnumDescriptor
170         getDescriptor() {
171       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.getDescriptor().getEnumTypes().get(0);
172     }
173 
174     private static final Type[] VALUES = values();
175 
176     public static Type valueOf(
177         com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
178       if (desc.getType() != getDescriptor()) {
179         throw new java.lang.IllegalArgumentException(
180           "EnumValueDescriptor is not for this type.");
181       }
182       if (desc.getIndex() == -1) {
183         return UNRECOGNIZED;
184       }
185       return VALUES[desc.getIndex()];
186     }
187 
188     private final int value;
189 
190     private Type(int value) {
191       this.value = value;
192     }
193 
194     // @@protoc_insertion_point(enum_scope:CDCRequest.Type)
195   }
196 
197   private int requestBodyCase_ = 0;
198   @SuppressWarnings("serial")
199   private java.lang.Object requestBody_;
200   public enum RequestBodyCase
201       implements com.google.protobuf.Internal.EnumLite,
202           com.google.protobuf.AbstractMessage.InternalOneOfEnum {
203     LOGIN_REQUEST_BODY(4),
204     STREAM_DATA_REQUEST_BODY(5),
205     ACK_STREAMING_REQUEST_BODY(6),
206     STOP_STREAMING_REQUEST_BODY(7),
207     START_STREAMING_REQUEST_BODY(8),
208     DROP_STREAMING_REQUEST_BODY(9),
209     REQUESTBODY_NOT_SET(0);
210     private final int value;
211     private RequestBodyCase(int value) {
212       this.value = value;
213     }
214     /**
215      * @param value The number of the enum to look for.
216      * @return The enum associated with the given number.
217      * @deprecated Use {@link #forNumber(int)} instead.
218      */
219     @java.lang.Deprecated
220     public static RequestBodyCase valueOf(int value) {
221       return forNumber(value);
222     }
223 
224     public static RequestBodyCase forNumber(int value) {
225       switch (value) {
226         case 4: return LOGIN_REQUEST_BODY;
227         case 5: return STREAM_DATA_REQUEST_BODY;
228         case 6: return ACK_STREAMING_REQUEST_BODY;
229         case 7: return STOP_STREAMING_REQUEST_BODY;
230         case 8: return START_STREAMING_REQUEST_BODY;
231         case 9: return DROP_STREAMING_REQUEST_BODY;
232         case 0: return REQUESTBODY_NOT_SET;
233         default: return null;
234       }
235     }
236     public int getNumber() {
237       return this.value;
238     }
239   };
240 
241   public RequestBodyCase
242   getRequestBodyCase() {
243     return RequestBodyCase.forNumber(
244         requestBodyCase_);
245   }
246 
247   public static final int VERSION_FIELD_NUMBER = 1;
248   private int version_ = 0;
249   /**
250    * <code>int32 version = 1;</code>
251    * @return The version.
252    */
253   @java.lang.Override
254   public int getVersion() {
255     return version_;
256   }
257 
258   public static final int REQUEST_ID_FIELD_NUMBER = 2;
259   @SuppressWarnings("serial")
260   private volatile java.lang.Object requestId_ = "";
261   /**
262    * <code>string request_id = 2;</code>
263    * @return The requestId.
264    */
265   @java.lang.Override
266   public java.lang.String getRequestId() {
267     java.lang.Object ref = requestId_;
268     if (ref instanceof java.lang.String) {
269       return (java.lang.String) ref;
270     } else {
271       com.google.protobuf.ByteString bs = 
272           (com.google.protobuf.ByteString) ref;
273       java.lang.String s = bs.toStringUtf8();
274       requestId_ = s;
275       return s;
276     }
277   }
278   /**
279    * <code>string request_id = 2;</code>
280    * @return The bytes for requestId.
281    */
282   @java.lang.Override
283   public com.google.protobuf.ByteString
284       getRequestIdBytes() {
285     java.lang.Object ref = requestId_;
286     if (ref instanceof java.lang.String) {
287       com.google.protobuf.ByteString b = 
288           com.google.protobuf.ByteString.copyFromUtf8(
289               (java.lang.String) ref);
290       requestId_ = b;
291       return b;
292     } else {
293       return (com.google.protobuf.ByteString) ref;
294     }
295   }
296 
297   public static final int TYPE_FIELD_NUMBER = 3;
298   private int type_ = 0;
299   /**
300    * <code>.CDCRequest.Type type = 3;</code>
301    * @return The enum numeric value on the wire for type.
302    */
303   @java.lang.Override public int getTypeValue() {
304     return type_;
305   }
306   /**
307    * <code>.CDCRequest.Type type = 3;</code>
308    * @return The type.
309    */
310   @java.lang.Override public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type getType() {
311     org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type result = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type.forNumber(type_);
312     return result == null ? org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type.UNRECOGNIZED : result;
313   }
314 
315   public static final int LOGIN_REQUEST_BODY_FIELD_NUMBER = 4;
316   /**
317    * <code>.LoginRequestBody login_request_body = 4;</code>
318    * @return Whether the loginRequestBody field is set.
319    */
320   @java.lang.Override
321   public boolean hasLoginRequestBody() {
322     return requestBodyCase_ == 4;
323   }
324   /**
325    * <code>.LoginRequestBody login_request_body = 4;</code>
326    * @return The loginRequestBody.
327    */
328   @java.lang.Override
329   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody getLoginRequestBody() {
330     if (requestBodyCase_ == 4) {
331        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody) requestBody_;
332     }
333     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.getDefaultInstance();
334   }
335   /**
336    * <code>.LoginRequestBody login_request_body = 4;</code>
337    */
338   @java.lang.Override
339   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBodyOrBuilder getLoginRequestBodyOrBuilder() {
340     if (requestBodyCase_ == 4) {
341        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody) requestBody_;
342     }
343     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.getDefaultInstance();
344   }
345 
346   public static final int STREAM_DATA_REQUEST_BODY_FIELD_NUMBER = 5;
347   /**
348    * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
349    * @return Whether the streamDataRequestBody field is set.
350    */
351   @java.lang.Override
352   public boolean hasStreamDataRequestBody() {
353     return requestBodyCase_ == 5;
354   }
355   /**
356    * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
357    * @return The streamDataRequestBody.
358    */
359   @java.lang.Override
360   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody getStreamDataRequestBody() {
361     if (requestBodyCase_ == 5) {
362        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody) requestBody_;
363     }
364     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.getDefaultInstance();
365   }
366   /**
367    * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
368    */
369   @java.lang.Override
370   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBodyOrBuilder getStreamDataRequestBodyOrBuilder() {
371     if (requestBodyCase_ == 5) {
372        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody) requestBody_;
373     }
374     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.getDefaultInstance();
375   }
376 
377   public static final int ACK_STREAMING_REQUEST_BODY_FIELD_NUMBER = 6;
378   /**
379    * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
380    * @return Whether the ackStreamingRequestBody field is set.
381    */
382   @java.lang.Override
383   public boolean hasAckStreamingRequestBody() {
384     return requestBodyCase_ == 6;
385   }
386   /**
387    * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
388    * @return The ackStreamingRequestBody.
389    */
390   @java.lang.Override
391   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody getAckStreamingRequestBody() {
392     if (requestBodyCase_ == 6) {
393        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody) requestBody_;
394     }
395     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.getDefaultInstance();
396   }
397   /**
398    * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
399    */
400   @java.lang.Override
401   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBodyOrBuilder getAckStreamingRequestBodyOrBuilder() {
402     if (requestBodyCase_ == 6) {
403        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody) requestBody_;
404     }
405     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.getDefaultInstance();
406   }
407 
408   public static final int STOP_STREAMING_REQUEST_BODY_FIELD_NUMBER = 7;
409   /**
410    * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
411    * @return Whether the stopStreamingRequestBody field is set.
412    */
413   @java.lang.Override
414   public boolean hasStopStreamingRequestBody() {
415     return requestBodyCase_ == 7;
416   }
417   /**
418    * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
419    * @return The stopStreamingRequestBody.
420    */
421   @java.lang.Override
422   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody getStopStreamingRequestBody() {
423     if (requestBodyCase_ == 7) {
424        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) requestBody_;
425     }
426     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance();
427   }
428   /**
429    * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
430    */
431   @java.lang.Override
432   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBodyOrBuilder getStopStreamingRequestBodyOrBuilder() {
433     if (requestBodyCase_ == 7) {
434        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) requestBody_;
435     }
436     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance();
437   }
438 
439   public static final int START_STREAMING_REQUEST_BODY_FIELD_NUMBER = 8;
440   /**
441    * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
442    * @return Whether the startStreamingRequestBody field is set.
443    */
444   @java.lang.Override
445   public boolean hasStartStreamingRequestBody() {
446     return requestBodyCase_ == 8;
447   }
448   /**
449    * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
450    * @return The startStreamingRequestBody.
451    */
452   @java.lang.Override
453   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody getStartStreamingRequestBody() {
454     if (requestBodyCase_ == 8) {
455        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) requestBody_;
456     }
457     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance();
458   }
459   /**
460    * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
461    */
462   @java.lang.Override
463   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBodyOrBuilder getStartStreamingRequestBodyOrBuilder() {
464     if (requestBodyCase_ == 8) {
465        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) requestBody_;
466     }
467     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance();
468   }
469 
470   public static final int DROP_STREAMING_REQUEST_BODY_FIELD_NUMBER = 9;
471   /**
472    * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
473    * @return Whether the dropStreamingRequestBody field is set.
474    */
475   @java.lang.Override
476   public boolean hasDropStreamingRequestBody() {
477     return requestBodyCase_ == 9;
478   }
479   /**
480    * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
481    * @return The dropStreamingRequestBody.
482    */
483   @java.lang.Override
484   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody getDropStreamingRequestBody() {
485     if (requestBodyCase_ == 9) {
486        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody) requestBody_;
487     }
488     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.getDefaultInstance();
489   }
490   /**
491    * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
492    */
493   @java.lang.Override
494   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBodyOrBuilder getDropStreamingRequestBodyOrBuilder() {
495     if (requestBodyCase_ == 9) {
496        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody) requestBody_;
497     }
498     return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.getDefaultInstance();
499   }
500 
501   private byte memoizedIsInitialized = -1;
502   @java.lang.Override
503   public final boolean isInitialized() {
504     byte isInitialized = memoizedIsInitialized;
505     if (isInitialized == 1) return true;
506     if (isInitialized == 0) return false;
507 
508     memoizedIsInitialized = 1;
509     return true;
510   }
511 
512   @java.lang.Override
513   public void writeTo(com.google.protobuf.CodedOutputStream output)
514                       throws java.io.IOException {
515     if (version_ != 0) {
516       output.writeInt32(1, version_);
517     }
518     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(requestId_)) {
519       com.google.protobuf.GeneratedMessageV3.writeString(output, 2, requestId_);
520     }
521     if (type_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type.UNKNOWN.getNumber()) {
522       output.writeEnum(3, type_);
523     }
524     if (requestBodyCase_ == 4) {
525       output.writeMessage(4, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody) requestBody_);
526     }
527     if (requestBodyCase_ == 5) {
528       output.writeMessage(5, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody) requestBody_);
529     }
530     if (requestBodyCase_ == 6) {
531       output.writeMessage(6, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody) requestBody_);
532     }
533     if (requestBodyCase_ == 7) {
534       output.writeMessage(7, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) requestBody_);
535     }
536     if (requestBodyCase_ == 8) {
537       output.writeMessage(8, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) requestBody_);
538     }
539     if (requestBodyCase_ == 9) {
540       output.writeMessage(9, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody) requestBody_);
541     }
542     getUnknownFields().writeTo(output);
543   }
544 
545   @java.lang.Override
546   public int getSerializedSize() {
547     int size = memoizedSize;
548     if (size != -1) return size;
549 
550     size = 0;
551     if (version_ != 0) {
552       size += com.google.protobuf.CodedOutputStream
553         .computeInt32Size(1, version_);
554     }
555     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(requestId_)) {
556       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, requestId_);
557     }
558     if (type_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type.UNKNOWN.getNumber()) {
559       size += com.google.protobuf.CodedOutputStream
560         .computeEnumSize(3, type_);
561     }
562     if (requestBodyCase_ == 4) {
563       size += com.google.protobuf.CodedOutputStream
564         .computeMessageSize(4, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody) requestBody_);
565     }
566     if (requestBodyCase_ == 5) {
567       size += com.google.protobuf.CodedOutputStream
568         .computeMessageSize(5, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody) requestBody_);
569     }
570     if (requestBodyCase_ == 6) {
571       size += com.google.protobuf.CodedOutputStream
572         .computeMessageSize(6, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody) requestBody_);
573     }
574     if (requestBodyCase_ == 7) {
575       size += com.google.protobuf.CodedOutputStream
576         .computeMessageSize(7, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) requestBody_);
577     }
578     if (requestBodyCase_ == 8) {
579       size += com.google.protobuf.CodedOutputStream
580         .computeMessageSize(8, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) requestBody_);
581     }
582     if (requestBodyCase_ == 9) {
583       size += com.google.protobuf.CodedOutputStream
584         .computeMessageSize(9, (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody) requestBody_);
585     }
586     size += getUnknownFields().getSerializedSize();
587     memoizedSize = size;
588     return size;
589   }
590 
591   @java.lang.Override
592   public boolean equals(final java.lang.Object obj) {
593     if (obj == this) {
594      return true;
595     }
596     if (!(obj instanceof org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest)) {
597       return super.equals(obj);
598     }
599     org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest other = (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest) obj;
600 
601     if (getVersion()
602         != other.getVersion()) return false;
603     if (!getRequestId()
604         .equals(other.getRequestId())) return false;
605     if (type_ != other.type_) return false;
606     if (!getRequestBodyCase().equals(other.getRequestBodyCase())) return false;
607     switch (requestBodyCase_) {
608       case 4:
609         if (!getLoginRequestBody()
610             .equals(other.getLoginRequestBody())) return false;
611         break;
612       case 5:
613         if (!getStreamDataRequestBody()
614             .equals(other.getStreamDataRequestBody())) return false;
615         break;
616       case 6:
617         if (!getAckStreamingRequestBody()
618             .equals(other.getAckStreamingRequestBody())) return false;
619         break;
620       case 7:
621         if (!getStopStreamingRequestBody()
622             .equals(other.getStopStreamingRequestBody())) return false;
623         break;
624       case 8:
625         if (!getStartStreamingRequestBody()
626             .equals(other.getStartStreamingRequestBody())) return false;
627         break;
628       case 9:
629         if (!getDropStreamingRequestBody()
630             .equals(other.getDropStreamingRequestBody())) return false;
631         break;
632       case 0:
633       default:
634     }
635     if (!getUnknownFields().equals(other.getUnknownFields())) return false;
636     return true;
637   }
638 
639   @java.lang.Override
640   public int hashCode() {
641     if (memoizedHashCode != 0) {
642       return memoizedHashCode;
643     }
644     int hash = 41;
645     hash = (19 * hash) + getDescriptor().hashCode();
646     hash = (37 * hash) + VERSION_FIELD_NUMBER;
647     hash = (53 * hash) + getVersion();
648     hash = (37 * hash) + REQUEST_ID_FIELD_NUMBER;
649     hash = (53 * hash) + getRequestId().hashCode();
650     hash = (37 * hash) + TYPE_FIELD_NUMBER;
651     hash = (53 * hash) + type_;
652     switch (requestBodyCase_) {
653       case 4:
654         hash = (37 * hash) + LOGIN_REQUEST_BODY_FIELD_NUMBER;
655         hash = (53 * hash) + getLoginRequestBody().hashCode();
656         break;
657       case 5:
658         hash = (37 * hash) + STREAM_DATA_REQUEST_BODY_FIELD_NUMBER;
659         hash = (53 * hash) + getStreamDataRequestBody().hashCode();
660         break;
661       case 6:
662         hash = (37 * hash) + ACK_STREAMING_REQUEST_BODY_FIELD_NUMBER;
663         hash = (53 * hash) + getAckStreamingRequestBody().hashCode();
664         break;
665       case 7:
666         hash = (37 * hash) + STOP_STREAMING_REQUEST_BODY_FIELD_NUMBER;
667         hash = (53 * hash) + getStopStreamingRequestBody().hashCode();
668         break;
669       case 8:
670         hash = (37 * hash) + START_STREAMING_REQUEST_BODY_FIELD_NUMBER;
671         hash = (53 * hash) + getStartStreamingRequestBody().hashCode();
672         break;
673       case 9:
674         hash = (37 * hash) + DROP_STREAMING_REQUEST_BODY_FIELD_NUMBER;
675         hash = (53 * hash) + getDropStreamingRequestBody().hashCode();
676         break;
677       case 0:
678       default:
679     }
680     hash = (29 * hash) + getUnknownFields().hashCode();
681     memoizedHashCode = hash;
682     return hash;
683   }
684 
685   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(
686       java.nio.ByteBuffer data)
687       throws com.google.protobuf.InvalidProtocolBufferException {
688     return PARSER.parseFrom(data);
689   }
690   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(
691       java.nio.ByteBuffer data,
692       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
693       throws com.google.protobuf.InvalidProtocolBufferException {
694     return PARSER.parseFrom(data, extensionRegistry);
695   }
696   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(
697       com.google.protobuf.ByteString data)
698       throws com.google.protobuf.InvalidProtocolBufferException {
699     return PARSER.parseFrom(data);
700   }
701   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(
702       com.google.protobuf.ByteString data,
703       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
704       throws com.google.protobuf.InvalidProtocolBufferException {
705     return PARSER.parseFrom(data, extensionRegistry);
706   }
707   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(byte[] data)
708       throws com.google.protobuf.InvalidProtocolBufferException {
709     return PARSER.parseFrom(data);
710   }
711   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(
712       byte[] data,
713       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
714       throws com.google.protobuf.InvalidProtocolBufferException {
715     return PARSER.parseFrom(data, extensionRegistry);
716   }
717   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(java.io.InputStream input)
718       throws java.io.IOException {
719     return com.google.protobuf.GeneratedMessageV3
720         .parseWithIOException(PARSER, input);
721   }
722   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(
723       java.io.InputStream input,
724       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
725       throws java.io.IOException {
726     return com.google.protobuf.GeneratedMessageV3
727         .parseWithIOException(PARSER, input, extensionRegistry);
728   }
729 
730   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseDelimitedFrom(java.io.InputStream input)
731       throws java.io.IOException {
732     return com.google.protobuf.GeneratedMessageV3
733         .parseDelimitedWithIOException(PARSER, input);
734   }
735 
736   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseDelimitedFrom(
737       java.io.InputStream input,
738       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
739       throws java.io.IOException {
740     return com.google.protobuf.GeneratedMessageV3
741         .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
742   }
743   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(
744       com.google.protobuf.CodedInputStream input)
745       throws java.io.IOException {
746     return com.google.protobuf.GeneratedMessageV3
747         .parseWithIOException(PARSER, input);
748   }
749   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest parseFrom(
750       com.google.protobuf.CodedInputStream input,
751       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
752       throws java.io.IOException {
753     return com.google.protobuf.GeneratedMessageV3
754         .parseWithIOException(PARSER, input, extensionRegistry);
755   }
756 
757   @java.lang.Override
758   public Builder newBuilderForType() { return newBuilder(); }
759   public static Builder newBuilder() {
760     return DEFAULT_INSTANCE.toBuilder();
761   }
762   public static Builder newBuilder(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest prototype) {
763     return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
764   }
765   @java.lang.Override
766   public Builder toBuilder() {
767     return this == DEFAULT_INSTANCE
768         ? new Builder() : new Builder().mergeFrom(this);
769   }
770 
771   @java.lang.Override
772   protected Builder newBuilderForType(
773       com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
774     Builder builder = new Builder(parent);
775     return builder;
776   }
777   /**
778    * Protobuf type {@code CDCRequest}
779    */
780   public static final class Builder extends
781       com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
782       // @@protoc_insertion_point(builder_implements:CDCRequest)
783       org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestOrBuilder {
784     public static final com.google.protobuf.Descriptors.Descriptor
785         getDescriptor() {
786       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_CDCRequest_descriptor;
787     }
788 
789     @java.lang.Override
790     protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
791         internalGetFieldAccessorTable() {
792       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_CDCRequest_fieldAccessorTable
793           .ensureFieldAccessorsInitialized(
794               org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.class, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Builder.class);
795     }
796 
797     // Construct using org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.newBuilder()
798     private Builder() {
799 
800     }
801 
802     private Builder(
803         com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
804       super(parent);
805 
806     }
807     @java.lang.Override
808     public Builder clear() {
809       super.clear();
810       bitField0_ = 0;
811       version_ = 0;
812       requestId_ = "";
813       type_ = 0;
814       if (loginRequestBodyBuilder_ != null) {
815         loginRequestBodyBuilder_.clear();
816       }
817       if (streamDataRequestBodyBuilder_ != null) {
818         streamDataRequestBodyBuilder_.clear();
819       }
820       if (ackStreamingRequestBodyBuilder_ != null) {
821         ackStreamingRequestBodyBuilder_.clear();
822       }
823       if (stopStreamingRequestBodyBuilder_ != null) {
824         stopStreamingRequestBodyBuilder_.clear();
825       }
826       if (startStreamingRequestBodyBuilder_ != null) {
827         startStreamingRequestBodyBuilder_.clear();
828       }
829       if (dropStreamingRequestBodyBuilder_ != null) {
830         dropStreamingRequestBodyBuilder_.clear();
831       }
832       requestBodyCase_ = 0;
833       requestBody_ = null;
834       return this;
835     }
836 
837     @java.lang.Override
838     public com.google.protobuf.Descriptors.Descriptor
839         getDescriptorForType() {
840       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_CDCRequest_descriptor;
841     }
842 
843     @java.lang.Override
844     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest getDefaultInstanceForType() {
845       return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.getDefaultInstance();
846     }
847 
848     @java.lang.Override
849     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest build() {
850       org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest result = buildPartial();
851       if (!result.isInitialized()) {
852         throw newUninitializedMessageException(result);
853       }
854       return result;
855     }
856 
857     @java.lang.Override
858     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest buildPartial() {
859       org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest result = new org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest(this);
860       if (bitField0_ != 0) { buildPartial0(result); }
861       buildPartialOneofs(result);
862       onBuilt();
863       return result;
864     }
865 
866     private void buildPartial0(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest result) {
867       int from_bitField0_ = bitField0_;
868       if (((from_bitField0_ & 0x00000001) != 0)) {
869         result.version_ = version_;
870       }
871       if (((from_bitField0_ & 0x00000002) != 0)) {
872         result.requestId_ = requestId_;
873       }
874       if (((from_bitField0_ & 0x00000004) != 0)) {
875         result.type_ = type_;
876       }
877     }
878 
879     private void buildPartialOneofs(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest result) {
880       result.requestBodyCase_ = requestBodyCase_;
881       result.requestBody_ = this.requestBody_;
882       if (requestBodyCase_ == 4 &&
883           loginRequestBodyBuilder_ != null) {
884         result.requestBody_ = loginRequestBodyBuilder_.build();
885       }
886       if (requestBodyCase_ == 5 &&
887           streamDataRequestBodyBuilder_ != null) {
888         result.requestBody_ = streamDataRequestBodyBuilder_.build();
889       }
890       if (requestBodyCase_ == 6 &&
891           ackStreamingRequestBodyBuilder_ != null) {
892         result.requestBody_ = ackStreamingRequestBodyBuilder_.build();
893       }
894       if (requestBodyCase_ == 7 &&
895           stopStreamingRequestBodyBuilder_ != null) {
896         result.requestBody_ = stopStreamingRequestBodyBuilder_.build();
897       }
898       if (requestBodyCase_ == 8 &&
899           startStreamingRequestBodyBuilder_ != null) {
900         result.requestBody_ = startStreamingRequestBodyBuilder_.build();
901       }
902       if (requestBodyCase_ == 9 &&
903           dropStreamingRequestBodyBuilder_ != null) {
904         result.requestBody_ = dropStreamingRequestBodyBuilder_.build();
905       }
906     }
907 
908     @java.lang.Override
909     public Builder clone() {
910       return super.clone();
911     }
912     @java.lang.Override
913     public Builder setField(
914         com.google.protobuf.Descriptors.FieldDescriptor field,
915         java.lang.Object value) {
916       return super.setField(field, value);
917     }
918     @java.lang.Override
919     public Builder clearField(
920         com.google.protobuf.Descriptors.FieldDescriptor field) {
921       return super.clearField(field);
922     }
923     @java.lang.Override
924     public Builder clearOneof(
925         com.google.protobuf.Descriptors.OneofDescriptor oneof) {
926       return super.clearOneof(oneof);
927     }
928     @java.lang.Override
929     public Builder setRepeatedField(
930         com.google.protobuf.Descriptors.FieldDescriptor field,
931         int index, java.lang.Object value) {
932       return super.setRepeatedField(field, index, value);
933     }
934     @java.lang.Override
935     public Builder addRepeatedField(
936         com.google.protobuf.Descriptors.FieldDescriptor field,
937         java.lang.Object value) {
938       return super.addRepeatedField(field, value);
939     }
940     @java.lang.Override
941     public Builder mergeFrom(com.google.protobuf.Message other) {
942       if (other instanceof org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest) {
943         return mergeFrom((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest)other);
944       } else {
945         super.mergeFrom(other);
946         return this;
947       }
948     }
949 
950     public Builder mergeFrom(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest other) {
951       if (other == org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.getDefaultInstance()) return this;
952       if (other.getVersion() != 0) {
953         setVersion(other.getVersion());
954       }
955       if (!other.getRequestId().isEmpty()) {
956         requestId_ = other.requestId_;
957         bitField0_ |= 0x00000002;
958         onChanged();
959       }
960       if (other.type_ != 0) {
961         setTypeValue(other.getTypeValue());
962       }
963       switch (other.getRequestBodyCase()) {
964         case LOGIN_REQUEST_BODY: {
965           mergeLoginRequestBody(other.getLoginRequestBody());
966           break;
967         }
968         case STREAM_DATA_REQUEST_BODY: {
969           mergeStreamDataRequestBody(other.getStreamDataRequestBody());
970           break;
971         }
972         case ACK_STREAMING_REQUEST_BODY: {
973           mergeAckStreamingRequestBody(other.getAckStreamingRequestBody());
974           break;
975         }
976         case STOP_STREAMING_REQUEST_BODY: {
977           mergeStopStreamingRequestBody(other.getStopStreamingRequestBody());
978           break;
979         }
980         case START_STREAMING_REQUEST_BODY: {
981           mergeStartStreamingRequestBody(other.getStartStreamingRequestBody());
982           break;
983         }
984         case DROP_STREAMING_REQUEST_BODY: {
985           mergeDropStreamingRequestBody(other.getDropStreamingRequestBody());
986           break;
987         }
988         case REQUESTBODY_NOT_SET: {
989           break;
990         }
991       }
992       this.mergeUnknownFields(other.getUnknownFields());
993       onChanged();
994       return this;
995     }
996 
997     @java.lang.Override
998     public final boolean isInitialized() {
999       return true;
1000     }
1001 
1002     @java.lang.Override
1003     public Builder mergeFrom(
1004         com.google.protobuf.CodedInputStream input,
1005         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
1006         throws java.io.IOException {
1007       if (extensionRegistry == null) {
1008         throw new java.lang.NullPointerException();
1009       }
1010       try {
1011         boolean done = false;
1012         while (!done) {
1013           int tag = input.readTag();
1014           switch (tag) {
1015             case 0:
1016               done = true;
1017               break;
1018             case 8: {
1019               version_ = input.readInt32();
1020               bitField0_ |= 0x00000001;
1021               break;
1022             } // case 8
1023             case 18: {
1024               requestId_ = input.readStringRequireUtf8();
1025               bitField0_ |= 0x00000002;
1026               break;
1027             } // case 18
1028             case 24: {
1029               type_ = input.readEnum();
1030               bitField0_ |= 0x00000004;
1031               break;
1032             } // case 24
1033             case 34: {
1034               input.readMessage(
1035                   getLoginRequestBodyFieldBuilder().getBuilder(),
1036                   extensionRegistry);
1037               requestBodyCase_ = 4;
1038               break;
1039             } // case 34
1040             case 42: {
1041               input.readMessage(
1042                   getStreamDataRequestBodyFieldBuilder().getBuilder(),
1043                   extensionRegistry);
1044               requestBodyCase_ = 5;
1045               break;
1046             } // case 42
1047             case 50: {
1048               input.readMessage(
1049                   getAckStreamingRequestBodyFieldBuilder().getBuilder(),
1050                   extensionRegistry);
1051               requestBodyCase_ = 6;
1052               break;
1053             } // case 50
1054             case 58: {
1055               input.readMessage(
1056                   getStopStreamingRequestBodyFieldBuilder().getBuilder(),
1057                   extensionRegistry);
1058               requestBodyCase_ = 7;
1059               break;
1060             } // case 58
1061             case 66: {
1062               input.readMessage(
1063                   getStartStreamingRequestBodyFieldBuilder().getBuilder(),
1064                   extensionRegistry);
1065               requestBodyCase_ = 8;
1066               break;
1067             } // case 66
1068             case 74: {
1069               input.readMessage(
1070                   getDropStreamingRequestBodyFieldBuilder().getBuilder(),
1071                   extensionRegistry);
1072               requestBodyCase_ = 9;
1073               break;
1074             } // case 74
1075             default: {
1076               if (!super.parseUnknownField(input, extensionRegistry, tag)) {
1077                 done = true; // was an endgroup tag
1078               }
1079               break;
1080             } // default:
1081           } // switch (tag)
1082         } // while (!done)
1083       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
1084         throw e.unwrapIOException();
1085       } finally {
1086         onChanged();
1087       } // finally
1088       return this;
1089     }
1090     private int requestBodyCase_ = 0;
1091     private java.lang.Object requestBody_;
1092     public RequestBodyCase
1093         getRequestBodyCase() {
1094       return RequestBodyCase.forNumber(
1095           requestBodyCase_);
1096     }
1097 
1098     public Builder clearRequestBody() {
1099       requestBodyCase_ = 0;
1100       requestBody_ = null;
1101       onChanged();
1102       return this;
1103     }
1104 
1105     private int bitField0_;
1106 
1107     private int version_ ;
1108     /**
1109      * <code>int32 version = 1;</code>
1110      * @return The version.
1111      */
1112     @java.lang.Override
1113     public int getVersion() {
1114       return version_;
1115     }
1116     /**
1117      * <code>int32 version = 1;</code>
1118      * @param value The version to set.
1119      * @return This builder for chaining.
1120      */
1121     public Builder setVersion(int value) {
1122 
1123       version_ = value;
1124       bitField0_ |= 0x00000001;
1125       onChanged();
1126       return this;
1127     }
1128     /**
1129      * <code>int32 version = 1;</code>
1130      * @return This builder for chaining.
1131      */
1132     public Builder clearVersion() {
1133       bitField0_ = (bitField0_ & ~0x00000001);
1134       version_ = 0;
1135       onChanged();
1136       return this;
1137     }
1138 
1139     private java.lang.Object requestId_ = "";
1140     /**
1141      * <code>string request_id = 2;</code>
1142      * @return The requestId.
1143      */
1144     public java.lang.String getRequestId() {
1145       java.lang.Object ref = requestId_;
1146       if (!(ref instanceof java.lang.String)) {
1147         com.google.protobuf.ByteString bs =
1148             (com.google.protobuf.ByteString) ref;
1149         java.lang.String s = bs.toStringUtf8();
1150         requestId_ = s;
1151         return s;
1152       } else {
1153         return (java.lang.String) ref;
1154       }
1155     }
1156     /**
1157      * <code>string request_id = 2;</code>
1158      * @return The bytes for requestId.
1159      */
1160     public com.google.protobuf.ByteString
1161         getRequestIdBytes() {
1162       java.lang.Object ref = requestId_;
1163       if (ref instanceof String) {
1164         com.google.protobuf.ByteString b = 
1165             com.google.protobuf.ByteString.copyFromUtf8(
1166                 (java.lang.String) ref);
1167         requestId_ = b;
1168         return b;
1169       } else {
1170         return (com.google.protobuf.ByteString) ref;
1171       }
1172     }
1173     /**
1174      * <code>string request_id = 2;</code>
1175      * @param value The requestId to set.
1176      * @return This builder for chaining.
1177      */
1178     public Builder setRequestId(
1179         java.lang.String value) {
1180       if (value == null) { throw new NullPointerException(); }
1181       requestId_ = value;
1182       bitField0_ |= 0x00000002;
1183       onChanged();
1184       return this;
1185     }
1186     /**
1187      * <code>string request_id = 2;</code>
1188      * @return This builder for chaining.
1189      */
1190     public Builder clearRequestId() {
1191       requestId_ = getDefaultInstance().getRequestId();
1192       bitField0_ = (bitField0_ & ~0x00000002);
1193       onChanged();
1194       return this;
1195     }
1196     /**
1197      * <code>string request_id = 2;</code>
1198      * @param value The bytes for requestId to set.
1199      * @return This builder for chaining.
1200      */
1201     public Builder setRequestIdBytes(
1202         com.google.protobuf.ByteString value) {
1203       if (value == null) { throw new NullPointerException(); }
1204       checkByteStringIsUtf8(value);
1205       requestId_ = value;
1206       bitField0_ |= 0x00000002;
1207       onChanged();
1208       return this;
1209     }
1210 
1211     private int type_ = 0;
1212     /**
1213      * <code>.CDCRequest.Type type = 3;</code>
1214      * @return The enum numeric value on the wire for type.
1215      */
1216     @java.lang.Override public int getTypeValue() {
1217       return type_;
1218     }
1219     /**
1220      * <code>.CDCRequest.Type type = 3;</code>
1221      * @param value The enum numeric value on the wire for type to set.
1222      * @return This builder for chaining.
1223      */
1224     public Builder setTypeValue(int value) {
1225       type_ = value;
1226       bitField0_ |= 0x00000004;
1227       onChanged();
1228       return this;
1229     }
1230     /**
1231      * <code>.CDCRequest.Type type = 3;</code>
1232      * @return The type.
1233      */
1234     @java.lang.Override
1235     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type getType() {
1236       org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type result = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type.forNumber(type_);
1237       return result == null ? org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type.UNRECOGNIZED : result;
1238     }
1239     /**
1240      * <code>.CDCRequest.Type type = 3;</code>
1241      * @param value The type to set.
1242      * @return This builder for chaining.
1243      */
1244     public Builder setType(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest.Type value) {
1245       if (value == null) {
1246         throw new NullPointerException();
1247       }
1248       bitField0_ |= 0x00000004;
1249       type_ = value.getNumber();
1250       onChanged();
1251       return this;
1252     }
1253     /**
1254      * <code>.CDCRequest.Type type = 3;</code>
1255      * @return This builder for chaining.
1256      */
1257     public Builder clearType() {
1258       bitField0_ = (bitField0_ & ~0x00000004);
1259       type_ = 0;
1260       onChanged();
1261       return this;
1262     }
1263 
1264     private com.google.protobuf.SingleFieldBuilderV3<
1265         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBodyOrBuilder> loginRequestBodyBuilder_;
1266     /**
1267      * <code>.LoginRequestBody login_request_body = 4;</code>
1268      * @return Whether the loginRequestBody field is set.
1269      */
1270     @java.lang.Override
1271     public boolean hasLoginRequestBody() {
1272       return requestBodyCase_ == 4;
1273     }
1274     /**
1275      * <code>.LoginRequestBody login_request_body = 4;</code>
1276      * @return The loginRequestBody.
1277      */
1278     @java.lang.Override
1279     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody getLoginRequestBody() {
1280       if (loginRequestBodyBuilder_ == null) {
1281         if (requestBodyCase_ == 4) {
1282           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody) requestBody_;
1283         }
1284         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.getDefaultInstance();
1285       } else {
1286         if (requestBodyCase_ == 4) {
1287           return loginRequestBodyBuilder_.getMessage();
1288         }
1289         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.getDefaultInstance();
1290       }
1291     }
1292     /**
1293      * <code>.LoginRequestBody login_request_body = 4;</code>
1294      */
1295     public Builder setLoginRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody value) {
1296       if (loginRequestBodyBuilder_ == null) {
1297         if (value == null) {
1298           throw new NullPointerException();
1299         }
1300         requestBody_ = value;
1301         onChanged();
1302       } else {
1303         loginRequestBodyBuilder_.setMessage(value);
1304       }
1305       requestBodyCase_ = 4;
1306       return this;
1307     }
1308     /**
1309      * <code>.LoginRequestBody login_request_body = 4;</code>
1310      */
1311     public Builder setLoginRequestBody(
1312         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.Builder builderForValue) {
1313       if (loginRequestBodyBuilder_ == null) {
1314         requestBody_ = builderForValue.build();
1315         onChanged();
1316       } else {
1317         loginRequestBodyBuilder_.setMessage(builderForValue.build());
1318       }
1319       requestBodyCase_ = 4;
1320       return this;
1321     }
1322     /**
1323      * <code>.LoginRequestBody login_request_body = 4;</code>
1324      */
1325     public Builder mergeLoginRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody value) {
1326       if (loginRequestBodyBuilder_ == null) {
1327         if (requestBodyCase_ == 4 &&
1328             requestBody_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.getDefaultInstance()) {
1329           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody) requestBody_)
1330               .mergeFrom(value).buildPartial();
1331         } else {
1332           requestBody_ = value;
1333         }
1334         onChanged();
1335       } else {
1336         if (requestBodyCase_ == 4) {
1337           loginRequestBodyBuilder_.mergeFrom(value);
1338         } else {
1339           loginRequestBodyBuilder_.setMessage(value);
1340         }
1341       }
1342       requestBodyCase_ = 4;
1343       return this;
1344     }
1345     /**
1346      * <code>.LoginRequestBody login_request_body = 4;</code>
1347      */
1348     public Builder clearLoginRequestBody() {
1349       if (loginRequestBodyBuilder_ == null) {
1350         if (requestBodyCase_ == 4) {
1351           requestBodyCase_ = 0;
1352           requestBody_ = null;
1353           onChanged();
1354         }
1355       } else {
1356         if (requestBodyCase_ == 4) {
1357           requestBodyCase_ = 0;
1358           requestBody_ = null;
1359         }
1360         loginRequestBodyBuilder_.clear();
1361       }
1362       return this;
1363     }
1364     /**
1365      * <code>.LoginRequestBody login_request_body = 4;</code>
1366      */
1367     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.Builder getLoginRequestBodyBuilder() {
1368       return getLoginRequestBodyFieldBuilder().getBuilder();
1369     }
1370     /**
1371      * <code>.LoginRequestBody login_request_body = 4;</code>
1372      */
1373     @java.lang.Override
1374     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBodyOrBuilder getLoginRequestBodyOrBuilder() {
1375       if ((requestBodyCase_ == 4) && (loginRequestBodyBuilder_ != null)) {
1376         return loginRequestBodyBuilder_.getMessageOrBuilder();
1377       } else {
1378         if (requestBodyCase_ == 4) {
1379           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody) requestBody_;
1380         }
1381         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.getDefaultInstance();
1382       }
1383     }
1384     /**
1385      * <code>.LoginRequestBody login_request_body = 4;</code>
1386      */
1387     private com.google.protobuf.SingleFieldBuilderV3<
1388         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBodyOrBuilder> 
1389         getLoginRequestBodyFieldBuilder() {
1390       if (loginRequestBodyBuilder_ == null) {
1391         if (!(requestBodyCase_ == 4)) {
1392           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.getDefaultInstance();
1393         }
1394         loginRequestBodyBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
1395             org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBodyOrBuilder>(
1396                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.LoginRequestBody) requestBody_,
1397                 getParentForChildren(),
1398                 isClean());
1399         requestBody_ = null;
1400       }
1401       requestBodyCase_ = 4;
1402       onChanged();
1403       return loginRequestBodyBuilder_;
1404     }
1405 
1406     private com.google.protobuf.SingleFieldBuilderV3<
1407         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBodyOrBuilder> streamDataRequestBodyBuilder_;
1408     /**
1409      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1410      * @return Whether the streamDataRequestBody field is set.
1411      */
1412     @java.lang.Override
1413     public boolean hasStreamDataRequestBody() {
1414       return requestBodyCase_ == 5;
1415     }
1416     /**
1417      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1418      * @return The streamDataRequestBody.
1419      */
1420     @java.lang.Override
1421     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody getStreamDataRequestBody() {
1422       if (streamDataRequestBodyBuilder_ == null) {
1423         if (requestBodyCase_ == 5) {
1424           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody) requestBody_;
1425         }
1426         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.getDefaultInstance();
1427       } else {
1428         if (requestBodyCase_ == 5) {
1429           return streamDataRequestBodyBuilder_.getMessage();
1430         }
1431         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.getDefaultInstance();
1432       }
1433     }
1434     /**
1435      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1436      */
1437     public Builder setStreamDataRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody value) {
1438       if (streamDataRequestBodyBuilder_ == null) {
1439         if (value == null) {
1440           throw new NullPointerException();
1441         }
1442         requestBody_ = value;
1443         onChanged();
1444       } else {
1445         streamDataRequestBodyBuilder_.setMessage(value);
1446       }
1447       requestBodyCase_ = 5;
1448       return this;
1449     }
1450     /**
1451      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1452      */
1453     public Builder setStreamDataRequestBody(
1454         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.Builder builderForValue) {
1455       if (streamDataRequestBodyBuilder_ == null) {
1456         requestBody_ = builderForValue.build();
1457         onChanged();
1458       } else {
1459         streamDataRequestBodyBuilder_.setMessage(builderForValue.build());
1460       }
1461       requestBodyCase_ = 5;
1462       return this;
1463     }
1464     /**
1465      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1466      */
1467     public Builder mergeStreamDataRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody value) {
1468       if (streamDataRequestBodyBuilder_ == null) {
1469         if (requestBodyCase_ == 5 &&
1470             requestBody_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.getDefaultInstance()) {
1471           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody) requestBody_)
1472               .mergeFrom(value).buildPartial();
1473         } else {
1474           requestBody_ = value;
1475         }
1476         onChanged();
1477       } else {
1478         if (requestBodyCase_ == 5) {
1479           streamDataRequestBodyBuilder_.mergeFrom(value);
1480         } else {
1481           streamDataRequestBodyBuilder_.setMessage(value);
1482         }
1483       }
1484       requestBodyCase_ = 5;
1485       return this;
1486     }
1487     /**
1488      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1489      */
1490     public Builder clearStreamDataRequestBody() {
1491       if (streamDataRequestBodyBuilder_ == null) {
1492         if (requestBodyCase_ == 5) {
1493           requestBodyCase_ = 0;
1494           requestBody_ = null;
1495           onChanged();
1496         }
1497       } else {
1498         if (requestBodyCase_ == 5) {
1499           requestBodyCase_ = 0;
1500           requestBody_ = null;
1501         }
1502         streamDataRequestBodyBuilder_.clear();
1503       }
1504       return this;
1505     }
1506     /**
1507      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1508      */
1509     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.Builder getStreamDataRequestBodyBuilder() {
1510       return getStreamDataRequestBodyFieldBuilder().getBuilder();
1511     }
1512     /**
1513      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1514      */
1515     @java.lang.Override
1516     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBodyOrBuilder getStreamDataRequestBodyOrBuilder() {
1517       if ((requestBodyCase_ == 5) && (streamDataRequestBodyBuilder_ != null)) {
1518         return streamDataRequestBodyBuilder_.getMessageOrBuilder();
1519       } else {
1520         if (requestBodyCase_ == 5) {
1521           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody) requestBody_;
1522         }
1523         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.getDefaultInstance();
1524       }
1525     }
1526     /**
1527      * <code>.StreamDataRequestBody stream_data_request_body = 5;</code>
1528      */
1529     private com.google.protobuf.SingleFieldBuilderV3<
1530         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBodyOrBuilder> 
1531         getStreamDataRequestBodyFieldBuilder() {
1532       if (streamDataRequestBodyBuilder_ == null) {
1533         if (!(requestBodyCase_ == 5)) {
1534           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.getDefaultInstance();
1535         }
1536         streamDataRequestBodyBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
1537             org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBodyOrBuilder>(
1538                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody) requestBody_,
1539                 getParentForChildren(),
1540                 isClean());
1541         requestBody_ = null;
1542       }
1543       requestBodyCase_ = 5;
1544       onChanged();
1545       return streamDataRequestBodyBuilder_;
1546     }
1547 
1548     private com.google.protobuf.SingleFieldBuilderV3<
1549         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBodyOrBuilder> ackStreamingRequestBodyBuilder_;
1550     /**
1551      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1552      * @return Whether the ackStreamingRequestBody field is set.
1553      */
1554     @java.lang.Override
1555     public boolean hasAckStreamingRequestBody() {
1556       return requestBodyCase_ == 6;
1557     }
1558     /**
1559      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1560      * @return The ackStreamingRequestBody.
1561      */
1562     @java.lang.Override
1563     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody getAckStreamingRequestBody() {
1564       if (ackStreamingRequestBodyBuilder_ == null) {
1565         if (requestBodyCase_ == 6) {
1566           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody) requestBody_;
1567         }
1568         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.getDefaultInstance();
1569       } else {
1570         if (requestBodyCase_ == 6) {
1571           return ackStreamingRequestBodyBuilder_.getMessage();
1572         }
1573         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.getDefaultInstance();
1574       }
1575     }
1576     /**
1577      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1578      */
1579     public Builder setAckStreamingRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody value) {
1580       if (ackStreamingRequestBodyBuilder_ == null) {
1581         if (value == null) {
1582           throw new NullPointerException();
1583         }
1584         requestBody_ = value;
1585         onChanged();
1586       } else {
1587         ackStreamingRequestBodyBuilder_.setMessage(value);
1588       }
1589       requestBodyCase_ = 6;
1590       return this;
1591     }
1592     /**
1593      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1594      */
1595     public Builder setAckStreamingRequestBody(
1596         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.Builder builderForValue) {
1597       if (ackStreamingRequestBodyBuilder_ == null) {
1598         requestBody_ = builderForValue.build();
1599         onChanged();
1600       } else {
1601         ackStreamingRequestBodyBuilder_.setMessage(builderForValue.build());
1602       }
1603       requestBodyCase_ = 6;
1604       return this;
1605     }
1606     /**
1607      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1608      */
1609     public Builder mergeAckStreamingRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody value) {
1610       if (ackStreamingRequestBodyBuilder_ == null) {
1611         if (requestBodyCase_ == 6 &&
1612             requestBody_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.getDefaultInstance()) {
1613           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody) requestBody_)
1614               .mergeFrom(value).buildPartial();
1615         } else {
1616           requestBody_ = value;
1617         }
1618         onChanged();
1619       } else {
1620         if (requestBodyCase_ == 6) {
1621           ackStreamingRequestBodyBuilder_.mergeFrom(value);
1622         } else {
1623           ackStreamingRequestBodyBuilder_.setMessage(value);
1624         }
1625       }
1626       requestBodyCase_ = 6;
1627       return this;
1628     }
1629     /**
1630      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1631      */
1632     public Builder clearAckStreamingRequestBody() {
1633       if (ackStreamingRequestBodyBuilder_ == null) {
1634         if (requestBodyCase_ == 6) {
1635           requestBodyCase_ = 0;
1636           requestBody_ = null;
1637           onChanged();
1638         }
1639       } else {
1640         if (requestBodyCase_ == 6) {
1641           requestBodyCase_ = 0;
1642           requestBody_ = null;
1643         }
1644         ackStreamingRequestBodyBuilder_.clear();
1645       }
1646       return this;
1647     }
1648     /**
1649      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1650      */
1651     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.Builder getAckStreamingRequestBodyBuilder() {
1652       return getAckStreamingRequestBodyFieldBuilder().getBuilder();
1653     }
1654     /**
1655      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1656      */
1657     @java.lang.Override
1658     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBodyOrBuilder getAckStreamingRequestBodyOrBuilder() {
1659       if ((requestBodyCase_ == 6) && (ackStreamingRequestBodyBuilder_ != null)) {
1660         return ackStreamingRequestBodyBuilder_.getMessageOrBuilder();
1661       } else {
1662         if (requestBodyCase_ == 6) {
1663           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody) requestBody_;
1664         }
1665         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.getDefaultInstance();
1666       }
1667     }
1668     /**
1669      * <code>.AckStreamingRequestBody ack_streaming_request_body = 6;</code>
1670      */
1671     private com.google.protobuf.SingleFieldBuilderV3<
1672         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBodyOrBuilder> 
1673         getAckStreamingRequestBodyFieldBuilder() {
1674       if (ackStreamingRequestBodyBuilder_ == null) {
1675         if (!(requestBodyCase_ == 6)) {
1676           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.getDefaultInstance();
1677         }
1678         ackStreamingRequestBodyBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
1679             org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBodyOrBuilder>(
1680                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.AckStreamingRequestBody) requestBody_,
1681                 getParentForChildren(),
1682                 isClean());
1683         requestBody_ = null;
1684       }
1685       requestBodyCase_ = 6;
1686       onChanged();
1687       return ackStreamingRequestBodyBuilder_;
1688     }
1689 
1690     private com.google.protobuf.SingleFieldBuilderV3<
1691         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBodyOrBuilder> stopStreamingRequestBodyBuilder_;
1692     /**
1693      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1694      * @return Whether the stopStreamingRequestBody field is set.
1695      */
1696     @java.lang.Override
1697     public boolean hasStopStreamingRequestBody() {
1698       return requestBodyCase_ == 7;
1699     }
1700     /**
1701      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1702      * @return The stopStreamingRequestBody.
1703      */
1704     @java.lang.Override
1705     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody getStopStreamingRequestBody() {
1706       if (stopStreamingRequestBodyBuilder_ == null) {
1707         if (requestBodyCase_ == 7) {
1708           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) requestBody_;
1709         }
1710         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance();
1711       } else {
1712         if (requestBodyCase_ == 7) {
1713           return stopStreamingRequestBodyBuilder_.getMessage();
1714         }
1715         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance();
1716       }
1717     }
1718     /**
1719      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1720      */
1721     public Builder setStopStreamingRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody value) {
1722       if (stopStreamingRequestBodyBuilder_ == null) {
1723         if (value == null) {
1724           throw new NullPointerException();
1725         }
1726         requestBody_ = value;
1727         onChanged();
1728       } else {
1729         stopStreamingRequestBodyBuilder_.setMessage(value);
1730       }
1731       requestBodyCase_ = 7;
1732       return this;
1733     }
1734     /**
1735      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1736      */
1737     public Builder setStopStreamingRequestBody(
1738         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.Builder builderForValue) {
1739       if (stopStreamingRequestBodyBuilder_ == null) {
1740         requestBody_ = builderForValue.build();
1741         onChanged();
1742       } else {
1743         stopStreamingRequestBodyBuilder_.setMessage(builderForValue.build());
1744       }
1745       requestBodyCase_ = 7;
1746       return this;
1747     }
1748     /**
1749      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1750      */
1751     public Builder mergeStopStreamingRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody value) {
1752       if (stopStreamingRequestBodyBuilder_ == null) {
1753         if (requestBodyCase_ == 7 &&
1754             requestBody_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance()) {
1755           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) requestBody_)
1756               .mergeFrom(value).buildPartial();
1757         } else {
1758           requestBody_ = value;
1759         }
1760         onChanged();
1761       } else {
1762         if (requestBodyCase_ == 7) {
1763           stopStreamingRequestBodyBuilder_.mergeFrom(value);
1764         } else {
1765           stopStreamingRequestBodyBuilder_.setMessage(value);
1766         }
1767       }
1768       requestBodyCase_ = 7;
1769       return this;
1770     }
1771     /**
1772      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1773      */
1774     public Builder clearStopStreamingRequestBody() {
1775       if (stopStreamingRequestBodyBuilder_ == null) {
1776         if (requestBodyCase_ == 7) {
1777           requestBodyCase_ = 0;
1778           requestBody_ = null;
1779           onChanged();
1780         }
1781       } else {
1782         if (requestBodyCase_ == 7) {
1783           requestBodyCase_ = 0;
1784           requestBody_ = null;
1785         }
1786         stopStreamingRequestBodyBuilder_.clear();
1787       }
1788       return this;
1789     }
1790     /**
1791      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1792      */
1793     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.Builder getStopStreamingRequestBodyBuilder() {
1794       return getStopStreamingRequestBodyFieldBuilder().getBuilder();
1795     }
1796     /**
1797      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1798      */
1799     @java.lang.Override
1800     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBodyOrBuilder getStopStreamingRequestBodyOrBuilder() {
1801       if ((requestBodyCase_ == 7) && (stopStreamingRequestBodyBuilder_ != null)) {
1802         return stopStreamingRequestBodyBuilder_.getMessageOrBuilder();
1803       } else {
1804         if (requestBodyCase_ == 7) {
1805           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) requestBody_;
1806         }
1807         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance();
1808       }
1809     }
1810     /**
1811      * <code>.StopStreamingRequestBody stop_streaming_request_body = 7;</code>
1812      */
1813     private com.google.protobuf.SingleFieldBuilderV3<
1814         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBodyOrBuilder> 
1815         getStopStreamingRequestBodyFieldBuilder() {
1816       if (stopStreamingRequestBodyBuilder_ == null) {
1817         if (!(requestBodyCase_ == 7)) {
1818           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.getDefaultInstance();
1819         }
1820         stopStreamingRequestBodyBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
1821             org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBodyOrBuilder>(
1822                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StopStreamingRequestBody) requestBody_,
1823                 getParentForChildren(),
1824                 isClean());
1825         requestBody_ = null;
1826       }
1827       requestBodyCase_ = 7;
1828       onChanged();
1829       return stopStreamingRequestBodyBuilder_;
1830     }
1831 
1832     private com.google.protobuf.SingleFieldBuilderV3<
1833         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBodyOrBuilder> startStreamingRequestBodyBuilder_;
1834     /**
1835      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1836      * @return Whether the startStreamingRequestBody field is set.
1837      */
1838     @java.lang.Override
1839     public boolean hasStartStreamingRequestBody() {
1840       return requestBodyCase_ == 8;
1841     }
1842     /**
1843      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1844      * @return The startStreamingRequestBody.
1845      */
1846     @java.lang.Override
1847     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody getStartStreamingRequestBody() {
1848       if (startStreamingRequestBodyBuilder_ == null) {
1849         if (requestBodyCase_ == 8) {
1850           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) requestBody_;
1851         }
1852         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance();
1853       } else {
1854         if (requestBodyCase_ == 8) {
1855           return startStreamingRequestBodyBuilder_.getMessage();
1856         }
1857         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance();
1858       }
1859     }
1860     /**
1861      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1862      */
1863     public Builder setStartStreamingRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody value) {
1864       if (startStreamingRequestBodyBuilder_ == null) {
1865         if (value == null) {
1866           throw new NullPointerException();
1867         }
1868         requestBody_ = value;
1869         onChanged();
1870       } else {
1871         startStreamingRequestBodyBuilder_.setMessage(value);
1872       }
1873       requestBodyCase_ = 8;
1874       return this;
1875     }
1876     /**
1877      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1878      */
1879     public Builder setStartStreamingRequestBody(
1880         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.Builder builderForValue) {
1881       if (startStreamingRequestBodyBuilder_ == null) {
1882         requestBody_ = builderForValue.build();
1883         onChanged();
1884       } else {
1885         startStreamingRequestBodyBuilder_.setMessage(builderForValue.build());
1886       }
1887       requestBodyCase_ = 8;
1888       return this;
1889     }
1890     /**
1891      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1892      */
1893     public Builder mergeStartStreamingRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody value) {
1894       if (startStreamingRequestBodyBuilder_ == null) {
1895         if (requestBodyCase_ == 8 &&
1896             requestBody_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance()) {
1897           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) requestBody_)
1898               .mergeFrom(value).buildPartial();
1899         } else {
1900           requestBody_ = value;
1901         }
1902         onChanged();
1903       } else {
1904         if (requestBodyCase_ == 8) {
1905           startStreamingRequestBodyBuilder_.mergeFrom(value);
1906         } else {
1907           startStreamingRequestBodyBuilder_.setMessage(value);
1908         }
1909       }
1910       requestBodyCase_ = 8;
1911       return this;
1912     }
1913     /**
1914      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1915      */
1916     public Builder clearStartStreamingRequestBody() {
1917       if (startStreamingRequestBodyBuilder_ == null) {
1918         if (requestBodyCase_ == 8) {
1919           requestBodyCase_ = 0;
1920           requestBody_ = null;
1921           onChanged();
1922         }
1923       } else {
1924         if (requestBodyCase_ == 8) {
1925           requestBodyCase_ = 0;
1926           requestBody_ = null;
1927         }
1928         startStreamingRequestBodyBuilder_.clear();
1929       }
1930       return this;
1931     }
1932     /**
1933      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1934      */
1935     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.Builder getStartStreamingRequestBodyBuilder() {
1936       return getStartStreamingRequestBodyFieldBuilder().getBuilder();
1937     }
1938     /**
1939      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1940      */
1941     @java.lang.Override
1942     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBodyOrBuilder getStartStreamingRequestBodyOrBuilder() {
1943       if ((requestBodyCase_ == 8) && (startStreamingRequestBodyBuilder_ != null)) {
1944         return startStreamingRequestBodyBuilder_.getMessageOrBuilder();
1945       } else {
1946         if (requestBodyCase_ == 8) {
1947           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) requestBody_;
1948         }
1949         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance();
1950       }
1951     }
1952     /**
1953      * <code>.StartStreamingRequestBody start_streaming_request_body = 8;</code>
1954      */
1955     private com.google.protobuf.SingleFieldBuilderV3<
1956         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBodyOrBuilder> 
1957         getStartStreamingRequestBodyFieldBuilder() {
1958       if (startStreamingRequestBodyBuilder_ == null) {
1959         if (!(requestBodyCase_ == 8)) {
1960           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance();
1961         }
1962         startStreamingRequestBodyBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
1963             org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBodyOrBuilder>(
1964                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) requestBody_,
1965                 getParentForChildren(),
1966                 isClean());
1967         requestBody_ = null;
1968       }
1969       requestBodyCase_ = 8;
1970       onChanged();
1971       return startStreamingRequestBodyBuilder_;
1972     }
1973 
1974     private com.google.protobuf.SingleFieldBuilderV3<
1975         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBodyOrBuilder> dropStreamingRequestBodyBuilder_;
1976     /**
1977      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
1978      * @return Whether the dropStreamingRequestBody field is set.
1979      */
1980     @java.lang.Override
1981     public boolean hasDropStreamingRequestBody() {
1982       return requestBodyCase_ == 9;
1983     }
1984     /**
1985      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
1986      * @return The dropStreamingRequestBody.
1987      */
1988     @java.lang.Override
1989     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody getDropStreamingRequestBody() {
1990       if (dropStreamingRequestBodyBuilder_ == null) {
1991         if (requestBodyCase_ == 9) {
1992           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody) requestBody_;
1993         }
1994         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.getDefaultInstance();
1995       } else {
1996         if (requestBodyCase_ == 9) {
1997           return dropStreamingRequestBodyBuilder_.getMessage();
1998         }
1999         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.getDefaultInstance();
2000       }
2001     }
2002     /**
2003      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
2004      */
2005     public Builder setDropStreamingRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody value) {
2006       if (dropStreamingRequestBodyBuilder_ == null) {
2007         if (value == null) {
2008           throw new NullPointerException();
2009         }
2010         requestBody_ = value;
2011         onChanged();
2012       } else {
2013         dropStreamingRequestBodyBuilder_.setMessage(value);
2014       }
2015       requestBodyCase_ = 9;
2016       return this;
2017     }
2018     /**
2019      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
2020      */
2021     public Builder setDropStreamingRequestBody(
2022         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.Builder builderForValue) {
2023       if (dropStreamingRequestBodyBuilder_ == null) {
2024         requestBody_ = builderForValue.build();
2025         onChanged();
2026       } else {
2027         dropStreamingRequestBodyBuilder_.setMessage(builderForValue.build());
2028       }
2029       requestBodyCase_ = 9;
2030       return this;
2031     }
2032     /**
2033      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
2034      */
2035     public Builder mergeDropStreamingRequestBody(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody value) {
2036       if (dropStreamingRequestBodyBuilder_ == null) {
2037         if (requestBodyCase_ == 9 &&
2038             requestBody_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.getDefaultInstance()) {
2039           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody) requestBody_)
2040               .mergeFrom(value).buildPartial();
2041         } else {
2042           requestBody_ = value;
2043         }
2044         onChanged();
2045       } else {
2046         if (requestBodyCase_ == 9) {
2047           dropStreamingRequestBodyBuilder_.mergeFrom(value);
2048         } else {
2049           dropStreamingRequestBodyBuilder_.setMessage(value);
2050         }
2051       }
2052       requestBodyCase_ = 9;
2053       return this;
2054     }
2055     /**
2056      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
2057      */
2058     public Builder clearDropStreamingRequestBody() {
2059       if (dropStreamingRequestBodyBuilder_ == null) {
2060         if (requestBodyCase_ == 9) {
2061           requestBodyCase_ = 0;
2062           requestBody_ = null;
2063           onChanged();
2064         }
2065       } else {
2066         if (requestBodyCase_ == 9) {
2067           requestBodyCase_ = 0;
2068           requestBody_ = null;
2069         }
2070         dropStreamingRequestBodyBuilder_.clear();
2071       }
2072       return this;
2073     }
2074     /**
2075      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
2076      */
2077     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.Builder getDropStreamingRequestBodyBuilder() {
2078       return getDropStreamingRequestBodyFieldBuilder().getBuilder();
2079     }
2080     /**
2081      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
2082      */
2083     @java.lang.Override
2084     public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBodyOrBuilder getDropStreamingRequestBodyOrBuilder() {
2085       if ((requestBodyCase_ == 9) && (dropStreamingRequestBodyBuilder_ != null)) {
2086         return dropStreamingRequestBodyBuilder_.getMessageOrBuilder();
2087       } else {
2088         if (requestBodyCase_ == 9) {
2089           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody) requestBody_;
2090         }
2091         return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.getDefaultInstance();
2092       }
2093     }
2094     /**
2095      * <code>.DropStreamingRequestBody drop_streaming_request_body = 9;</code>
2096      */
2097     private com.google.protobuf.SingleFieldBuilderV3<
2098         org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBodyOrBuilder> 
2099         getDropStreamingRequestBodyFieldBuilder() {
2100       if (dropStreamingRequestBodyBuilder_ == null) {
2101         if (!(requestBodyCase_ == 9)) {
2102           requestBody_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.getDefaultInstance();
2103         }
2104         dropStreamingRequestBodyBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
2105             org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBodyOrBuilder>(
2106                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.DropStreamingRequestBody) requestBody_,
2107                 getParentForChildren(),
2108                 isClean());
2109         requestBody_ = null;
2110       }
2111       requestBodyCase_ = 9;
2112       onChanged();
2113       return dropStreamingRequestBodyBuilder_;
2114     }
2115     @java.lang.Override
2116     public final Builder setUnknownFields(
2117         final com.google.protobuf.UnknownFieldSet unknownFields) {
2118       return super.setUnknownFields(unknownFields);
2119     }
2120 
2121     @java.lang.Override
2122     public final Builder mergeUnknownFields(
2123         final com.google.protobuf.UnknownFieldSet unknownFields) {
2124       return super.mergeUnknownFields(unknownFields);
2125     }
2126 
2127 
2128     // @@protoc_insertion_point(builder_scope:CDCRequest)
2129   }
2130 
2131   // @@protoc_insertion_point(class_scope:CDCRequest)
2132   private static final org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest DEFAULT_INSTANCE;
2133   static {
2134     DEFAULT_INSTANCE = new org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest();
2135   }
2136 
2137   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest getDefaultInstance() {
2138     return DEFAULT_INSTANCE;
2139   }
2140 
2141   private static final com.google.protobuf.Parser<CDCRequest>
2142       PARSER = new com.google.protobuf.AbstractParser<CDCRequest>() {
2143     @java.lang.Override
2144     public CDCRequest parsePartialFrom(
2145         com.google.protobuf.CodedInputStream input,
2146         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
2147         throws com.google.protobuf.InvalidProtocolBufferException {
2148       Builder builder = newBuilder();
2149       try {
2150         builder.mergeFrom(input, extensionRegistry);
2151       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
2152         throw e.setUnfinishedMessage(builder.buildPartial());
2153       } catch (com.google.protobuf.UninitializedMessageException e) {
2154         throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
2155       } catch (java.io.IOException e) {
2156         throw new com.google.protobuf.InvalidProtocolBufferException(e)
2157             .setUnfinishedMessage(builder.buildPartial());
2158       }
2159       return builder.buildPartial();
2160     }
2161   };
2162 
2163   public static com.google.protobuf.Parser<CDCRequest> parser() {
2164     return PARSER;
2165   }
2166 
2167   @java.lang.Override
2168   public com.google.protobuf.Parser<CDCRequest> getParserForType() {
2169     return PARSER;
2170   }
2171 
2172   @java.lang.Override
2173   public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequest getDefaultInstanceForType() {
2174     return DEFAULT_INSTANCE;
2175   }
2176 
2177 }
2178