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