View Javadoc
1   // Generated by the protocol buffer compiler.  DO NOT EDIT!
2   // source: CDCResponseProtocol.proto
3   
4   // Protobuf Java Version: 3.25.8
5   package org.apache.shardingsphere.data.pipeline.cdc.protocol.response;
6   
7   /**
8    * Protobuf type {@code CDCResponse}
9    */
10  public final class CDCResponse extends
11      com.google.protobuf.GeneratedMessageV3 implements
12      // @@protoc_insertion_point(message_implements:CDCResponse)
13      CDCResponseOrBuilder {
14  private static final long serialVersionUID = 0L;
15    // Use CDCResponse.newBuilder() to construct.
16    private CDCResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
17      super(builder);
18    }
19    private CDCResponse() {
20      requestId_ = "";
21      status_ = 0;
22      errorCode_ = "";
23      errorMessage_ = "";
24    }
25  
26    @java.lang.Override
27    @SuppressWarnings({"unused"})
28    protected java.lang.Object newInstance(
29        UnusedPrivateParameter unused) {
30      return new CDCResponse();
31    }
32  
33    public static final com.google.protobuf.Descriptors.Descriptor
34        getDescriptor() {
35      return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponseProtocol.internal_static_CDCResponse_descriptor;
36    }
37  
38    @java.lang.Override
39    protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
40        internalGetFieldAccessorTable() {
41      return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponseProtocol.internal_static_CDCResponse_fieldAccessorTable
42          .ensureFieldAccessorsInitialized(
43              org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.class, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Builder.class);
44    }
45  
46    /**
47     * Protobuf enum {@code CDCResponse.Status}
48     */
49    public enum Status
50        implements com.google.protobuf.ProtocolMessageEnum {
51      /**
52       * <code>UNKNOWN = 0;</code>
53       */
54      UNKNOWN(0),
55      /**
56       * <code>SUCCEED = 1;</code>
57       */
58      SUCCEED(1),
59      /**
60       * <code>FAILED = 2;</code>
61       */
62      FAILED(2),
63      UNRECOGNIZED(-1),
64      ;
65  
66      /**
67       * <code>UNKNOWN = 0;</code>
68       */
69      public static final int UNKNOWN_VALUE = 0;
70      /**
71       * <code>SUCCEED = 1;</code>
72       */
73      public static final int SUCCEED_VALUE = 1;
74      /**
75       * <code>FAILED = 2;</code>
76       */
77      public static final int FAILED_VALUE = 2;
78  
79  
80      public final int getNumber() {
81        if (this == UNRECOGNIZED) {
82          throw new java.lang.IllegalArgumentException(
83              "Can't get the number of an unknown enum value.");
84        }
85        return value;
86      }
87  
88      /**
89       * @param value The numeric wire value of the corresponding enum entry.
90       * @return The enum associated with the given numeric wire value.
91       * @deprecated Use {@link #forNumber(int)} instead.
92       */
93      @java.lang.Deprecated
94      public static Status valueOf(int value) {
95        return forNumber(value);
96      }
97  
98      /**
99       * @param value The numeric wire value of the corresponding enum entry.
100      * @return The enum associated with the given numeric wire value.
101      */
102     public static Status forNumber(int value) {
103       switch (value) {
104         case 0: return UNKNOWN;
105         case 1: return SUCCEED;
106         case 2: return FAILED;
107         default: return null;
108       }
109     }
110 
111     public static com.google.protobuf.Internal.EnumLiteMap<Status>
112         internalGetValueMap() {
113       return internalValueMap;
114     }
115     private static final com.google.protobuf.Internal.EnumLiteMap<
116         Status> internalValueMap =
117           new com.google.protobuf.Internal.EnumLiteMap<Status>() {
118             public Status findValueByNumber(int number) {
119               return Status.forNumber(number);
120             }
121           };
122 
123     public final com.google.protobuf.Descriptors.EnumValueDescriptor
124         getValueDescriptor() {
125       if (this == UNRECOGNIZED) {
126         throw new java.lang.IllegalStateException(
127             "Can't get the descriptor of an unrecognized enum value.");
128       }
129       return getDescriptor().getValues().get(ordinal());
130     }
131     public final com.google.protobuf.Descriptors.EnumDescriptor
132         getDescriptorForType() {
133       return getDescriptor();
134     }
135     public static final com.google.protobuf.Descriptors.EnumDescriptor
136         getDescriptor() {
137       return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.getDescriptor().getEnumTypes().get(0);
138     }
139 
140     private static final Status[] VALUES = values();
141 
142     public static Status valueOf(
143         com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
144       if (desc.getType() != getDescriptor()) {
145         throw new java.lang.IllegalArgumentException(
146           "EnumValueDescriptor is not for this type.");
147       }
148       if (desc.getIndex() == -1) {
149         return UNRECOGNIZED;
150       }
151       return VALUES[desc.getIndex()];
152     }
153 
154     private final int value;
155 
156     private Status(int value) {
157       this.value = value;
158     }
159 
160     // @@protoc_insertion_point(enum_scope:CDCResponse.Status)
161   }
162 
163   private int bitField0_;
164   private int responseCase_ = 0;
165   @SuppressWarnings("serial")
166   private java.lang.Object response_;
167   public enum ResponseCase
168       implements com.google.protobuf.Internal.EnumLite,
169           com.google.protobuf.AbstractMessage.InternalOneOfEnum {
170     SERVER_GREETING_RESULT(3),
171     STREAM_DATA_RESULT(4),
172     DATA_RECORD_RESULT(5),
173     RESPONSE_NOT_SET(0);
174     private final int value;
175     private ResponseCase(int value) {
176       this.value = value;
177     }
178     /**
179      * @param value The number of the enum to look for.
180      * @return The enum associated with the given number.
181      * @deprecated Use {@link #forNumber(int)} instead.
182      */
183     @java.lang.Deprecated
184     public static ResponseCase valueOf(int value) {
185       return forNumber(value);
186     }
187 
188     public static ResponseCase forNumber(int value) {
189       switch (value) {
190         case 3: return SERVER_GREETING_RESULT;
191         case 4: return STREAM_DATA_RESULT;
192         case 5: return DATA_RECORD_RESULT;
193         case 0: return RESPONSE_NOT_SET;
194         default: return null;
195       }
196     }
197     public int getNumber() {
198       return this.value;
199     }
200   };
201 
202   public ResponseCase
203   getResponseCase() {
204     return ResponseCase.forNumber(
205         responseCase_);
206   }
207 
208   public static final int REQUEST_ID_FIELD_NUMBER = 1;
209   @SuppressWarnings("serial")
210   private volatile java.lang.Object requestId_ = "";
211   /**
212    * <code>string request_id = 1;</code>
213    * @return The requestId.
214    */
215   @java.lang.Override
216   public java.lang.String getRequestId() {
217     java.lang.Object ref = requestId_;
218     if (ref instanceof java.lang.String) {
219       return (java.lang.String) ref;
220     } else {
221       com.google.protobuf.ByteString bs = 
222           (com.google.protobuf.ByteString) ref;
223       java.lang.String s = bs.toStringUtf8();
224       requestId_ = s;
225       return s;
226     }
227   }
228   /**
229    * <code>string request_id = 1;</code>
230    * @return The bytes for requestId.
231    */
232   @java.lang.Override
233   public com.google.protobuf.ByteString
234       getRequestIdBytes() {
235     java.lang.Object ref = requestId_;
236     if (ref instanceof java.lang.String) {
237       com.google.protobuf.ByteString b = 
238           com.google.protobuf.ByteString.copyFromUtf8(
239               (java.lang.String) ref);
240       requestId_ = b;
241       return b;
242     } else {
243       return (com.google.protobuf.ByteString) ref;
244     }
245   }
246 
247   public static final int STATUS_FIELD_NUMBER = 2;
248   private int status_ = 0;
249   /**
250    * <code>.CDCResponse.Status status = 2;</code>
251    * @return The enum numeric value on the wire for status.
252    */
253   @java.lang.Override public int getStatusValue() {
254     return status_;
255   }
256   /**
257    * <code>.CDCResponse.Status status = 2;</code>
258    * @return The status.
259    */
260   @java.lang.Override public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status getStatus() {
261     org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status result = org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status.forNumber(status_);
262     return result == null ? org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status.UNRECOGNIZED : result;
263   }
264 
265   public static final int SERVER_GREETING_RESULT_FIELD_NUMBER = 3;
266   /**
267    * <code>.ServerGreetingResult server_greeting_result = 3;</code>
268    * @return Whether the serverGreetingResult field is set.
269    */
270   @java.lang.Override
271   public boolean hasServerGreetingResult() {
272     return responseCase_ == 3;
273   }
274   /**
275    * <code>.ServerGreetingResult server_greeting_result = 3;</code>
276    * @return The serverGreetingResult.
277    */
278   @java.lang.Override
279   public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult getServerGreetingResult() {
280     if (responseCase_ == 3) {
281        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult) response_;
282     }
283     return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.getDefaultInstance();
284   }
285   /**
286    * <code>.ServerGreetingResult server_greeting_result = 3;</code>
287    */
288   @java.lang.Override
289   public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResultOrBuilder getServerGreetingResultOrBuilder() {
290     if (responseCase_ == 3) {
291        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult) response_;
292     }
293     return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.getDefaultInstance();
294   }
295 
296   public static final int STREAM_DATA_RESULT_FIELD_NUMBER = 4;
297   /**
298    * <code>.StreamDataResult stream_data_result = 4;</code>
299    * @return Whether the streamDataResult field is set.
300    */
301   @java.lang.Override
302   public boolean hasStreamDataResult() {
303     return responseCase_ == 4;
304   }
305   /**
306    * <code>.StreamDataResult stream_data_result = 4;</code>
307    * @return The streamDataResult.
308    */
309   @java.lang.Override
310   public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult getStreamDataResult() {
311     if (responseCase_ == 4) {
312        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult) response_;
313     }
314     return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.getDefaultInstance();
315   }
316   /**
317    * <code>.StreamDataResult stream_data_result = 4;</code>
318    */
319   @java.lang.Override
320   public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResultOrBuilder getStreamDataResultOrBuilder() {
321     if (responseCase_ == 4) {
322        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult) response_;
323     }
324     return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.getDefaultInstance();
325   }
326 
327   public static final int DATA_RECORD_RESULT_FIELD_NUMBER = 5;
328   /**
329    * <code>.DataRecordResult data_record_result = 5;</code>
330    * @return Whether the dataRecordResult field is set.
331    */
332   @java.lang.Override
333   public boolean hasDataRecordResult() {
334     return responseCase_ == 5;
335   }
336   /**
337    * <code>.DataRecordResult data_record_result = 5;</code>
338    * @return The dataRecordResult.
339    */
340   @java.lang.Override
341   public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult getDataRecordResult() {
342     if (responseCase_ == 5) {
343        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult) response_;
344     }
345     return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.getDefaultInstance();
346   }
347   /**
348    * <code>.DataRecordResult data_record_result = 5;</code>
349    */
350   @java.lang.Override
351   public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResultOrBuilder getDataRecordResultOrBuilder() {
352     if (responseCase_ == 5) {
353        return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult) response_;
354     }
355     return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.getDefaultInstance();
356   }
357 
358   public static final int ERROR_CODE_FIELD_NUMBER = 14;
359   @SuppressWarnings("serial")
360   private volatile java.lang.Object errorCode_ = "";
361   /**
362    * <code>optional string error_code = 14;</code>
363    * @return Whether the errorCode field is set.
364    */
365   @java.lang.Override
366   public boolean hasErrorCode() {
367     return ((bitField0_ & 0x00000001) != 0);
368   }
369   /**
370    * <code>optional string error_code = 14;</code>
371    * @return The errorCode.
372    */
373   @java.lang.Override
374   public java.lang.String getErrorCode() {
375     java.lang.Object ref = errorCode_;
376     if (ref instanceof java.lang.String) {
377       return (java.lang.String) ref;
378     } else {
379       com.google.protobuf.ByteString bs = 
380           (com.google.protobuf.ByteString) ref;
381       java.lang.String s = bs.toStringUtf8();
382       errorCode_ = s;
383       return s;
384     }
385   }
386   /**
387    * <code>optional string error_code = 14;</code>
388    * @return The bytes for errorCode.
389    */
390   @java.lang.Override
391   public com.google.protobuf.ByteString
392       getErrorCodeBytes() {
393     java.lang.Object ref = errorCode_;
394     if (ref instanceof java.lang.String) {
395       com.google.protobuf.ByteString b = 
396           com.google.protobuf.ByteString.copyFromUtf8(
397               (java.lang.String) ref);
398       errorCode_ = b;
399       return b;
400     } else {
401       return (com.google.protobuf.ByteString) ref;
402     }
403   }
404 
405   public static final int ERROR_MESSAGE_FIELD_NUMBER = 15;
406   @SuppressWarnings("serial")
407   private volatile java.lang.Object errorMessage_ = "";
408   /**
409    * <code>optional string error_message = 15;</code>
410    * @return Whether the errorMessage field is set.
411    */
412   @java.lang.Override
413   public boolean hasErrorMessage() {
414     return ((bitField0_ & 0x00000002) != 0);
415   }
416   /**
417    * <code>optional string error_message = 15;</code>
418    * @return The errorMessage.
419    */
420   @java.lang.Override
421   public java.lang.String getErrorMessage() {
422     java.lang.Object ref = errorMessage_;
423     if (ref instanceof java.lang.String) {
424       return (java.lang.String) ref;
425     } else {
426       com.google.protobuf.ByteString bs = 
427           (com.google.protobuf.ByteString) ref;
428       java.lang.String s = bs.toStringUtf8();
429       errorMessage_ = s;
430       return s;
431     }
432   }
433   /**
434    * <code>optional string error_message = 15;</code>
435    * @return The bytes for errorMessage.
436    */
437   @java.lang.Override
438   public com.google.protobuf.ByteString
439       getErrorMessageBytes() {
440     java.lang.Object ref = errorMessage_;
441     if (ref instanceof java.lang.String) {
442       com.google.protobuf.ByteString b = 
443           com.google.protobuf.ByteString.copyFromUtf8(
444               (java.lang.String) ref);
445       errorMessage_ = b;
446       return b;
447     } else {
448       return (com.google.protobuf.ByteString) ref;
449     }
450   }
451 
452   private byte memoizedIsInitialized = -1;
453   @java.lang.Override
454   public final boolean isInitialized() {
455     byte isInitialized = memoizedIsInitialized;
456     if (isInitialized == 1) return true;
457     if (isInitialized == 0) return false;
458 
459     memoizedIsInitialized = 1;
460     return true;
461   }
462 
463   @java.lang.Override
464   public void writeTo(com.google.protobuf.CodedOutputStream output)
465                       throws java.io.IOException {
466     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(requestId_)) {
467       com.google.protobuf.GeneratedMessageV3.writeString(output, 1, requestId_);
468     }
469     if (status_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status.UNKNOWN.getNumber()) {
470       output.writeEnum(2, status_);
471     }
472     if (responseCase_ == 3) {
473       output.writeMessage(3, (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult) response_);
474     }
475     if (responseCase_ == 4) {
476       output.writeMessage(4, (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult) response_);
477     }
478     if (responseCase_ == 5) {
479       output.writeMessage(5, (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult) response_);
480     }
481     if (((bitField0_ & 0x00000001) != 0)) {
482       com.google.protobuf.GeneratedMessageV3.writeString(output, 14, errorCode_);
483     }
484     if (((bitField0_ & 0x00000002) != 0)) {
485       com.google.protobuf.GeneratedMessageV3.writeString(output, 15, errorMessage_);
486     }
487     getUnknownFields().writeTo(output);
488   }
489 
490   @java.lang.Override
491   public int getSerializedSize() {
492     int size = memoizedSize;
493     if (size != -1) return size;
494 
495     size = 0;
496     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(requestId_)) {
497       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, requestId_);
498     }
499     if (status_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status.UNKNOWN.getNumber()) {
500       size += com.google.protobuf.CodedOutputStream
501         .computeEnumSize(2, status_);
502     }
503     if (responseCase_ == 3) {
504       size += com.google.protobuf.CodedOutputStream
505         .computeMessageSize(3, (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult) response_);
506     }
507     if (responseCase_ == 4) {
508       size += com.google.protobuf.CodedOutputStream
509         .computeMessageSize(4, (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult) response_);
510     }
511     if (responseCase_ == 5) {
512       size += com.google.protobuf.CodedOutputStream
513         .computeMessageSize(5, (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult) response_);
514     }
515     if (((bitField0_ & 0x00000001) != 0)) {
516       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(14, errorCode_);
517     }
518     if (((bitField0_ & 0x00000002) != 0)) {
519       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(15, errorMessage_);
520     }
521     size += getUnknownFields().getSerializedSize();
522     memoizedSize = size;
523     return size;
524   }
525 
526   @java.lang.Override
527   public boolean equals(final java.lang.Object obj) {
528     if (obj == this) {
529      return true;
530     }
531     if (!(obj instanceof org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse)) {
532       return super.equals(obj);
533     }
534     org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse other = (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse) obj;
535 
536     if (!getRequestId()
537         .equals(other.getRequestId())) return false;
538     if (status_ != other.status_) return false;
539     if (hasErrorCode() != other.hasErrorCode()) return false;
540     if (hasErrorCode()) {
541       if (!getErrorCode()
542           .equals(other.getErrorCode())) return false;
543     }
544     if (hasErrorMessage() != other.hasErrorMessage()) return false;
545     if (hasErrorMessage()) {
546       if (!getErrorMessage()
547           .equals(other.getErrorMessage())) return false;
548     }
549     if (!getResponseCase().equals(other.getResponseCase())) return false;
550     switch (responseCase_) {
551       case 3:
552         if (!getServerGreetingResult()
553             .equals(other.getServerGreetingResult())) return false;
554         break;
555       case 4:
556         if (!getStreamDataResult()
557             .equals(other.getStreamDataResult())) return false;
558         break;
559       case 5:
560         if (!getDataRecordResult()
561             .equals(other.getDataRecordResult())) return false;
562         break;
563       case 0:
564       default:
565     }
566     if (!getUnknownFields().equals(other.getUnknownFields())) return false;
567     return true;
568   }
569 
570   @java.lang.Override
571   public int hashCode() {
572     if (memoizedHashCode != 0) {
573       return memoizedHashCode;
574     }
575     int hash = 41;
576     hash = (19 * hash) + getDescriptor().hashCode();
577     hash = (37 * hash) + REQUEST_ID_FIELD_NUMBER;
578     hash = (53 * hash) + getRequestId().hashCode();
579     hash = (37 * hash) + STATUS_FIELD_NUMBER;
580     hash = (53 * hash) + status_;
581     if (hasErrorCode()) {
582       hash = (37 * hash) + ERROR_CODE_FIELD_NUMBER;
583       hash = (53 * hash) + getErrorCode().hashCode();
584     }
585     if (hasErrorMessage()) {
586       hash = (37 * hash) + ERROR_MESSAGE_FIELD_NUMBER;
587       hash = (53 * hash) + getErrorMessage().hashCode();
588     }
589     switch (responseCase_) {
590       case 3:
591         hash = (37 * hash) + SERVER_GREETING_RESULT_FIELD_NUMBER;
592         hash = (53 * hash) + getServerGreetingResult().hashCode();
593         break;
594       case 4:
595         hash = (37 * hash) + STREAM_DATA_RESULT_FIELD_NUMBER;
596         hash = (53 * hash) + getStreamDataResult().hashCode();
597         break;
598       case 5:
599         hash = (37 * hash) + DATA_RECORD_RESULT_FIELD_NUMBER;
600         hash = (53 * hash) + getDataRecordResult().hashCode();
601         break;
602       case 0:
603       default:
604     }
605     hash = (29 * hash) + getUnknownFields().hashCode();
606     memoizedHashCode = hash;
607     return hash;
608   }
609 
610   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(
611       java.nio.ByteBuffer data)
612       throws com.google.protobuf.InvalidProtocolBufferException {
613     return PARSER.parseFrom(data);
614   }
615   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(
616       java.nio.ByteBuffer data,
617       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
618       throws com.google.protobuf.InvalidProtocolBufferException {
619     return PARSER.parseFrom(data, extensionRegistry);
620   }
621   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(
622       com.google.protobuf.ByteString data)
623       throws com.google.protobuf.InvalidProtocolBufferException {
624     return PARSER.parseFrom(data);
625   }
626   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(
627       com.google.protobuf.ByteString data,
628       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
629       throws com.google.protobuf.InvalidProtocolBufferException {
630     return PARSER.parseFrom(data, extensionRegistry);
631   }
632   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(byte[] data)
633       throws com.google.protobuf.InvalidProtocolBufferException {
634     return PARSER.parseFrom(data);
635   }
636   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(
637       byte[] data,
638       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
639       throws com.google.protobuf.InvalidProtocolBufferException {
640     return PARSER.parseFrom(data, extensionRegistry);
641   }
642   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(java.io.InputStream input)
643       throws java.io.IOException {
644     return com.google.protobuf.GeneratedMessageV3
645         .parseWithIOException(PARSER, input);
646   }
647   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(
648       java.io.InputStream input,
649       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
650       throws java.io.IOException {
651     return com.google.protobuf.GeneratedMessageV3
652         .parseWithIOException(PARSER, input, extensionRegistry);
653   }
654 
655   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseDelimitedFrom(java.io.InputStream input)
656       throws java.io.IOException {
657     return com.google.protobuf.GeneratedMessageV3
658         .parseDelimitedWithIOException(PARSER, input);
659   }
660 
661   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseDelimitedFrom(
662       java.io.InputStream input,
663       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
664       throws java.io.IOException {
665     return com.google.protobuf.GeneratedMessageV3
666         .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
667   }
668   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(
669       com.google.protobuf.CodedInputStream input)
670       throws java.io.IOException {
671     return com.google.protobuf.GeneratedMessageV3
672         .parseWithIOException(PARSER, input);
673   }
674   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse parseFrom(
675       com.google.protobuf.CodedInputStream input,
676       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
677       throws java.io.IOException {
678     return com.google.protobuf.GeneratedMessageV3
679         .parseWithIOException(PARSER, input, extensionRegistry);
680   }
681 
682   @java.lang.Override
683   public Builder newBuilderForType() { return newBuilder(); }
684   public static Builder newBuilder() {
685     return DEFAULT_INSTANCE.toBuilder();
686   }
687   public static Builder newBuilder(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse prototype) {
688     return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
689   }
690   @java.lang.Override
691   public Builder toBuilder() {
692     return this == DEFAULT_INSTANCE
693         ? new Builder() : new Builder().mergeFrom(this);
694   }
695 
696   @java.lang.Override
697   protected Builder newBuilderForType(
698       com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
699     Builder builder = new Builder(parent);
700     return builder;
701   }
702   /**
703    * Protobuf type {@code CDCResponse}
704    */
705   public static final class Builder extends
706       com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
707       // @@protoc_insertion_point(builder_implements:CDCResponse)
708       org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponseOrBuilder {
709     public static final com.google.protobuf.Descriptors.Descriptor
710         getDescriptor() {
711       return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponseProtocol.internal_static_CDCResponse_descriptor;
712     }
713 
714     @java.lang.Override
715     protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
716         internalGetFieldAccessorTable() {
717       return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponseProtocol.internal_static_CDCResponse_fieldAccessorTable
718           .ensureFieldAccessorsInitialized(
719               org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.class, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Builder.class);
720     }
721 
722     // Construct using org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.newBuilder()
723     private Builder() {
724 
725     }
726 
727     private Builder(
728         com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
729       super(parent);
730 
731     }
732     @java.lang.Override
733     public Builder clear() {
734       super.clear();
735       bitField0_ = 0;
736       requestId_ = "";
737       status_ = 0;
738       if (serverGreetingResultBuilder_ != null) {
739         serverGreetingResultBuilder_.clear();
740       }
741       if (streamDataResultBuilder_ != null) {
742         streamDataResultBuilder_.clear();
743       }
744       if (dataRecordResultBuilder_ != null) {
745         dataRecordResultBuilder_.clear();
746       }
747       errorCode_ = "";
748       errorMessage_ = "";
749       responseCase_ = 0;
750       response_ = null;
751       return this;
752     }
753 
754     @java.lang.Override
755     public com.google.protobuf.Descriptors.Descriptor
756         getDescriptorForType() {
757       return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponseProtocol.internal_static_CDCResponse_descriptor;
758     }
759 
760     @java.lang.Override
761     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse getDefaultInstanceForType() {
762       return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.getDefaultInstance();
763     }
764 
765     @java.lang.Override
766     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse build() {
767       org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse result = buildPartial();
768       if (!result.isInitialized()) {
769         throw newUninitializedMessageException(result);
770       }
771       return result;
772     }
773 
774     @java.lang.Override
775     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse buildPartial() {
776       org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse result = new org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse(this);
777       if (bitField0_ != 0) { buildPartial0(result); }
778       buildPartialOneofs(result);
779       onBuilt();
780       return result;
781     }
782 
783     private void buildPartial0(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse result) {
784       int from_bitField0_ = bitField0_;
785       if (((from_bitField0_ & 0x00000001) != 0)) {
786         result.requestId_ = requestId_;
787       }
788       if (((from_bitField0_ & 0x00000002) != 0)) {
789         result.status_ = status_;
790       }
791       int to_bitField0_ = 0;
792       if (((from_bitField0_ & 0x00000020) != 0)) {
793         result.errorCode_ = errorCode_;
794         to_bitField0_ |= 0x00000001;
795       }
796       if (((from_bitField0_ & 0x00000040) != 0)) {
797         result.errorMessage_ = errorMessage_;
798         to_bitField0_ |= 0x00000002;
799       }
800       result.bitField0_ |= to_bitField0_;
801     }
802 
803     private void buildPartialOneofs(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse result) {
804       result.responseCase_ = responseCase_;
805       result.response_ = this.response_;
806       if (responseCase_ == 3 &&
807           serverGreetingResultBuilder_ != null) {
808         result.response_ = serverGreetingResultBuilder_.build();
809       }
810       if (responseCase_ == 4 &&
811           streamDataResultBuilder_ != null) {
812         result.response_ = streamDataResultBuilder_.build();
813       }
814       if (responseCase_ == 5 &&
815           dataRecordResultBuilder_ != null) {
816         result.response_ = dataRecordResultBuilder_.build();
817       }
818     }
819 
820     @java.lang.Override
821     public Builder clone() {
822       return super.clone();
823     }
824     @java.lang.Override
825     public Builder setField(
826         com.google.protobuf.Descriptors.FieldDescriptor field,
827         java.lang.Object value) {
828       return super.setField(field, value);
829     }
830     @java.lang.Override
831     public Builder clearField(
832         com.google.protobuf.Descriptors.FieldDescriptor field) {
833       return super.clearField(field);
834     }
835     @java.lang.Override
836     public Builder clearOneof(
837         com.google.protobuf.Descriptors.OneofDescriptor oneof) {
838       return super.clearOneof(oneof);
839     }
840     @java.lang.Override
841     public Builder setRepeatedField(
842         com.google.protobuf.Descriptors.FieldDescriptor field,
843         int index, java.lang.Object value) {
844       return super.setRepeatedField(field, index, value);
845     }
846     @java.lang.Override
847     public Builder addRepeatedField(
848         com.google.protobuf.Descriptors.FieldDescriptor field,
849         java.lang.Object value) {
850       return super.addRepeatedField(field, value);
851     }
852     @java.lang.Override
853     public Builder mergeFrom(com.google.protobuf.Message other) {
854       if (other instanceof org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse) {
855         return mergeFrom((org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse)other);
856       } else {
857         super.mergeFrom(other);
858         return this;
859       }
860     }
861 
862     public Builder mergeFrom(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse other) {
863       if (other == org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.getDefaultInstance()) return this;
864       if (!other.getRequestId().isEmpty()) {
865         requestId_ = other.requestId_;
866         bitField0_ |= 0x00000001;
867         onChanged();
868       }
869       if (other.status_ != 0) {
870         setStatusValue(other.getStatusValue());
871       }
872       if (other.hasErrorCode()) {
873         errorCode_ = other.errorCode_;
874         bitField0_ |= 0x00000020;
875         onChanged();
876       }
877       if (other.hasErrorMessage()) {
878         errorMessage_ = other.errorMessage_;
879         bitField0_ |= 0x00000040;
880         onChanged();
881       }
882       switch (other.getResponseCase()) {
883         case SERVER_GREETING_RESULT: {
884           mergeServerGreetingResult(other.getServerGreetingResult());
885           break;
886         }
887         case STREAM_DATA_RESULT: {
888           mergeStreamDataResult(other.getStreamDataResult());
889           break;
890         }
891         case DATA_RECORD_RESULT: {
892           mergeDataRecordResult(other.getDataRecordResult());
893           break;
894         }
895         case RESPONSE_NOT_SET: {
896           break;
897         }
898       }
899       this.mergeUnknownFields(other.getUnknownFields());
900       onChanged();
901       return this;
902     }
903 
904     @java.lang.Override
905     public final boolean isInitialized() {
906       return true;
907     }
908 
909     @java.lang.Override
910     public Builder mergeFrom(
911         com.google.protobuf.CodedInputStream input,
912         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
913         throws java.io.IOException {
914       if (extensionRegistry == null) {
915         throw new java.lang.NullPointerException();
916       }
917       try {
918         boolean done = false;
919         while (!done) {
920           int tag = input.readTag();
921           switch (tag) {
922             case 0:
923               done = true;
924               break;
925             case 10: {
926               requestId_ = input.readStringRequireUtf8();
927               bitField0_ |= 0x00000001;
928               break;
929             } // case 10
930             case 16: {
931               status_ = input.readEnum();
932               bitField0_ |= 0x00000002;
933               break;
934             } // case 16
935             case 26: {
936               input.readMessage(
937                   getServerGreetingResultFieldBuilder().getBuilder(),
938                   extensionRegistry);
939               responseCase_ = 3;
940               break;
941             } // case 26
942             case 34: {
943               input.readMessage(
944                   getStreamDataResultFieldBuilder().getBuilder(),
945                   extensionRegistry);
946               responseCase_ = 4;
947               break;
948             } // case 34
949             case 42: {
950               input.readMessage(
951                   getDataRecordResultFieldBuilder().getBuilder(),
952                   extensionRegistry);
953               responseCase_ = 5;
954               break;
955             } // case 42
956             case 114: {
957               errorCode_ = input.readStringRequireUtf8();
958               bitField0_ |= 0x00000020;
959               break;
960             } // case 114
961             case 122: {
962               errorMessage_ = input.readStringRequireUtf8();
963               bitField0_ |= 0x00000040;
964               break;
965             } // case 122
966             default: {
967               if (!super.parseUnknownField(input, extensionRegistry, tag)) {
968                 done = true; // was an endgroup tag
969               }
970               break;
971             } // default:
972           } // switch (tag)
973         } // while (!done)
974       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
975         throw e.unwrapIOException();
976       } finally {
977         onChanged();
978       } // finally
979       return this;
980     }
981     private int responseCase_ = 0;
982     private java.lang.Object response_;
983     public ResponseCase
984         getResponseCase() {
985       return ResponseCase.forNumber(
986           responseCase_);
987     }
988 
989     public Builder clearResponse() {
990       responseCase_ = 0;
991       response_ = null;
992       onChanged();
993       return this;
994     }
995 
996     private int bitField0_;
997 
998     private java.lang.Object requestId_ = "";
999     /**
1000      * <code>string request_id = 1;</code>
1001      * @return The requestId.
1002      */
1003     public java.lang.String getRequestId() {
1004       java.lang.Object ref = requestId_;
1005       if (!(ref instanceof java.lang.String)) {
1006         com.google.protobuf.ByteString bs =
1007             (com.google.protobuf.ByteString) ref;
1008         java.lang.String s = bs.toStringUtf8();
1009         requestId_ = s;
1010         return s;
1011       } else {
1012         return (java.lang.String) ref;
1013       }
1014     }
1015     /**
1016      * <code>string request_id = 1;</code>
1017      * @return The bytes for requestId.
1018      */
1019     public com.google.protobuf.ByteString
1020         getRequestIdBytes() {
1021       java.lang.Object ref = requestId_;
1022       if (ref instanceof String) {
1023         com.google.protobuf.ByteString b = 
1024             com.google.protobuf.ByteString.copyFromUtf8(
1025                 (java.lang.String) ref);
1026         requestId_ = b;
1027         return b;
1028       } else {
1029         return (com.google.protobuf.ByteString) ref;
1030       }
1031     }
1032     /**
1033      * <code>string request_id = 1;</code>
1034      * @param value The requestId to set.
1035      * @return This builder for chaining.
1036      */
1037     public Builder setRequestId(
1038         java.lang.String value) {
1039       if (value == null) { throw new NullPointerException(); }
1040       requestId_ = value;
1041       bitField0_ |= 0x00000001;
1042       onChanged();
1043       return this;
1044     }
1045     /**
1046      * <code>string request_id = 1;</code>
1047      * @return This builder for chaining.
1048      */
1049     public Builder clearRequestId() {
1050       requestId_ = getDefaultInstance().getRequestId();
1051       bitField0_ = (bitField0_ & ~0x00000001);
1052       onChanged();
1053       return this;
1054     }
1055     /**
1056      * <code>string request_id = 1;</code>
1057      * @param value The bytes for requestId to set.
1058      * @return This builder for chaining.
1059      */
1060     public Builder setRequestIdBytes(
1061         com.google.protobuf.ByteString value) {
1062       if (value == null) { throw new NullPointerException(); }
1063       checkByteStringIsUtf8(value);
1064       requestId_ = value;
1065       bitField0_ |= 0x00000001;
1066       onChanged();
1067       return this;
1068     }
1069 
1070     private int status_ = 0;
1071     /**
1072      * <code>.CDCResponse.Status status = 2;</code>
1073      * @return The enum numeric value on the wire for status.
1074      */
1075     @java.lang.Override public int getStatusValue() {
1076       return status_;
1077     }
1078     /**
1079      * <code>.CDCResponse.Status status = 2;</code>
1080      * @param value The enum numeric value on the wire for status to set.
1081      * @return This builder for chaining.
1082      */
1083     public Builder setStatusValue(int value) {
1084       status_ = value;
1085       bitField0_ |= 0x00000002;
1086       onChanged();
1087       return this;
1088     }
1089     /**
1090      * <code>.CDCResponse.Status status = 2;</code>
1091      * @return The status.
1092      */
1093     @java.lang.Override
1094     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status getStatus() {
1095       org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status result = org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status.forNumber(status_);
1096       return result == null ? org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status.UNRECOGNIZED : result;
1097     }
1098     /**
1099      * <code>.CDCResponse.Status status = 2;</code>
1100      * @param value The status to set.
1101      * @return This builder for chaining.
1102      */
1103     public Builder setStatus(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse.Status value) {
1104       if (value == null) {
1105         throw new NullPointerException();
1106       }
1107       bitField0_ |= 0x00000002;
1108       status_ = value.getNumber();
1109       onChanged();
1110       return this;
1111     }
1112     /**
1113      * <code>.CDCResponse.Status status = 2;</code>
1114      * @return This builder for chaining.
1115      */
1116     public Builder clearStatus() {
1117       bitField0_ = (bitField0_ & ~0x00000002);
1118       status_ = 0;
1119       onChanged();
1120       return this;
1121     }
1122 
1123     private com.google.protobuf.SingleFieldBuilderV3<
1124         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResultOrBuilder> serverGreetingResultBuilder_;
1125     /**
1126      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1127      * @return Whether the serverGreetingResult field is set.
1128      */
1129     @java.lang.Override
1130     public boolean hasServerGreetingResult() {
1131       return responseCase_ == 3;
1132     }
1133     /**
1134      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1135      * @return The serverGreetingResult.
1136      */
1137     @java.lang.Override
1138     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult getServerGreetingResult() {
1139       if (serverGreetingResultBuilder_ == null) {
1140         if (responseCase_ == 3) {
1141           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult) response_;
1142         }
1143         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.getDefaultInstance();
1144       } else {
1145         if (responseCase_ == 3) {
1146           return serverGreetingResultBuilder_.getMessage();
1147         }
1148         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.getDefaultInstance();
1149       }
1150     }
1151     /**
1152      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1153      */
1154     public Builder setServerGreetingResult(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult value) {
1155       if (serverGreetingResultBuilder_ == null) {
1156         if (value == null) {
1157           throw new NullPointerException();
1158         }
1159         response_ = value;
1160         onChanged();
1161       } else {
1162         serverGreetingResultBuilder_.setMessage(value);
1163       }
1164       responseCase_ = 3;
1165       return this;
1166     }
1167     /**
1168      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1169      */
1170     public Builder setServerGreetingResult(
1171         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.Builder builderForValue) {
1172       if (serverGreetingResultBuilder_ == null) {
1173         response_ = builderForValue.build();
1174         onChanged();
1175       } else {
1176         serverGreetingResultBuilder_.setMessage(builderForValue.build());
1177       }
1178       responseCase_ = 3;
1179       return this;
1180     }
1181     /**
1182      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1183      */
1184     public Builder mergeServerGreetingResult(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult value) {
1185       if (serverGreetingResultBuilder_ == null) {
1186         if (responseCase_ == 3 &&
1187             response_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.getDefaultInstance()) {
1188           response_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult) response_)
1189               .mergeFrom(value).buildPartial();
1190         } else {
1191           response_ = value;
1192         }
1193         onChanged();
1194       } else {
1195         if (responseCase_ == 3) {
1196           serverGreetingResultBuilder_.mergeFrom(value);
1197         } else {
1198           serverGreetingResultBuilder_.setMessage(value);
1199         }
1200       }
1201       responseCase_ = 3;
1202       return this;
1203     }
1204     /**
1205      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1206      */
1207     public Builder clearServerGreetingResult() {
1208       if (serverGreetingResultBuilder_ == null) {
1209         if (responseCase_ == 3) {
1210           responseCase_ = 0;
1211           response_ = null;
1212           onChanged();
1213         }
1214       } else {
1215         if (responseCase_ == 3) {
1216           responseCase_ = 0;
1217           response_ = null;
1218         }
1219         serverGreetingResultBuilder_.clear();
1220       }
1221       return this;
1222     }
1223     /**
1224      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1225      */
1226     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.Builder getServerGreetingResultBuilder() {
1227       return getServerGreetingResultFieldBuilder().getBuilder();
1228     }
1229     /**
1230      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1231      */
1232     @java.lang.Override
1233     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResultOrBuilder getServerGreetingResultOrBuilder() {
1234       if ((responseCase_ == 3) && (serverGreetingResultBuilder_ != null)) {
1235         return serverGreetingResultBuilder_.getMessageOrBuilder();
1236       } else {
1237         if (responseCase_ == 3) {
1238           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult) response_;
1239         }
1240         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.getDefaultInstance();
1241       }
1242     }
1243     /**
1244      * <code>.ServerGreetingResult server_greeting_result = 3;</code>
1245      */
1246     private com.google.protobuf.SingleFieldBuilderV3<
1247         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResultOrBuilder> 
1248         getServerGreetingResultFieldBuilder() {
1249       if (serverGreetingResultBuilder_ == null) {
1250         if (!(responseCase_ == 3)) {
1251           response_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.getDefaultInstance();
1252         }
1253         serverGreetingResultBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
1254             org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResultOrBuilder>(
1255                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult) response_,
1256                 getParentForChildren(),
1257                 isClean());
1258         response_ = null;
1259       }
1260       responseCase_ = 3;
1261       onChanged();
1262       return serverGreetingResultBuilder_;
1263     }
1264 
1265     private com.google.protobuf.SingleFieldBuilderV3<
1266         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResultOrBuilder> streamDataResultBuilder_;
1267     /**
1268      * <code>.StreamDataResult stream_data_result = 4;</code>
1269      * @return Whether the streamDataResult field is set.
1270      */
1271     @java.lang.Override
1272     public boolean hasStreamDataResult() {
1273       return responseCase_ == 4;
1274     }
1275     /**
1276      * <code>.StreamDataResult stream_data_result = 4;</code>
1277      * @return The streamDataResult.
1278      */
1279     @java.lang.Override
1280     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult getStreamDataResult() {
1281       if (streamDataResultBuilder_ == null) {
1282         if (responseCase_ == 4) {
1283           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult) response_;
1284         }
1285         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.getDefaultInstance();
1286       } else {
1287         if (responseCase_ == 4) {
1288           return streamDataResultBuilder_.getMessage();
1289         }
1290         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.getDefaultInstance();
1291       }
1292     }
1293     /**
1294      * <code>.StreamDataResult stream_data_result = 4;</code>
1295      */
1296     public Builder setStreamDataResult(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult value) {
1297       if (streamDataResultBuilder_ == null) {
1298         if (value == null) {
1299           throw new NullPointerException();
1300         }
1301         response_ = value;
1302         onChanged();
1303       } else {
1304         streamDataResultBuilder_.setMessage(value);
1305       }
1306       responseCase_ = 4;
1307       return this;
1308     }
1309     /**
1310      * <code>.StreamDataResult stream_data_result = 4;</code>
1311      */
1312     public Builder setStreamDataResult(
1313         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.Builder builderForValue) {
1314       if (streamDataResultBuilder_ == null) {
1315         response_ = builderForValue.build();
1316         onChanged();
1317       } else {
1318         streamDataResultBuilder_.setMessage(builderForValue.build());
1319       }
1320       responseCase_ = 4;
1321       return this;
1322     }
1323     /**
1324      * <code>.StreamDataResult stream_data_result = 4;</code>
1325      */
1326     public Builder mergeStreamDataResult(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult value) {
1327       if (streamDataResultBuilder_ == null) {
1328         if (responseCase_ == 4 &&
1329             response_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.getDefaultInstance()) {
1330           response_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult) response_)
1331               .mergeFrom(value).buildPartial();
1332         } else {
1333           response_ = value;
1334         }
1335         onChanged();
1336       } else {
1337         if (responseCase_ == 4) {
1338           streamDataResultBuilder_.mergeFrom(value);
1339         } else {
1340           streamDataResultBuilder_.setMessage(value);
1341         }
1342       }
1343       responseCase_ = 4;
1344       return this;
1345     }
1346     /**
1347      * <code>.StreamDataResult stream_data_result = 4;</code>
1348      */
1349     public Builder clearStreamDataResult() {
1350       if (streamDataResultBuilder_ == null) {
1351         if (responseCase_ == 4) {
1352           responseCase_ = 0;
1353           response_ = null;
1354           onChanged();
1355         }
1356       } else {
1357         if (responseCase_ == 4) {
1358           responseCase_ = 0;
1359           response_ = null;
1360         }
1361         streamDataResultBuilder_.clear();
1362       }
1363       return this;
1364     }
1365     /**
1366      * <code>.StreamDataResult stream_data_result = 4;</code>
1367      */
1368     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.Builder getStreamDataResultBuilder() {
1369       return getStreamDataResultFieldBuilder().getBuilder();
1370     }
1371     /**
1372      * <code>.StreamDataResult stream_data_result = 4;</code>
1373      */
1374     @java.lang.Override
1375     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResultOrBuilder getStreamDataResultOrBuilder() {
1376       if ((responseCase_ == 4) && (streamDataResultBuilder_ != null)) {
1377         return streamDataResultBuilder_.getMessageOrBuilder();
1378       } else {
1379         if (responseCase_ == 4) {
1380           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult) response_;
1381         }
1382         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.getDefaultInstance();
1383       }
1384     }
1385     /**
1386      * <code>.StreamDataResult stream_data_result = 4;</code>
1387      */
1388     private com.google.protobuf.SingleFieldBuilderV3<
1389         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResultOrBuilder> 
1390         getStreamDataResultFieldBuilder() {
1391       if (streamDataResultBuilder_ == null) {
1392         if (!(responseCase_ == 4)) {
1393           response_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.getDefaultInstance();
1394         }
1395         streamDataResultBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
1396             org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResultOrBuilder>(
1397                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult) response_,
1398                 getParentForChildren(),
1399                 isClean());
1400         response_ = null;
1401       }
1402       responseCase_ = 4;
1403       onChanged();
1404       return streamDataResultBuilder_;
1405     }
1406 
1407     private com.google.protobuf.SingleFieldBuilderV3<
1408         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResultOrBuilder> dataRecordResultBuilder_;
1409     /**
1410      * <code>.DataRecordResult data_record_result = 5;</code>
1411      * @return Whether the dataRecordResult field is set.
1412      */
1413     @java.lang.Override
1414     public boolean hasDataRecordResult() {
1415       return responseCase_ == 5;
1416     }
1417     /**
1418      * <code>.DataRecordResult data_record_result = 5;</code>
1419      * @return The dataRecordResult.
1420      */
1421     @java.lang.Override
1422     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult getDataRecordResult() {
1423       if (dataRecordResultBuilder_ == null) {
1424         if (responseCase_ == 5) {
1425           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult) response_;
1426         }
1427         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.getDefaultInstance();
1428       } else {
1429         if (responseCase_ == 5) {
1430           return dataRecordResultBuilder_.getMessage();
1431         }
1432         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.getDefaultInstance();
1433       }
1434     }
1435     /**
1436      * <code>.DataRecordResult data_record_result = 5;</code>
1437      */
1438     public Builder setDataRecordResult(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult value) {
1439       if (dataRecordResultBuilder_ == null) {
1440         if (value == null) {
1441           throw new NullPointerException();
1442         }
1443         response_ = value;
1444         onChanged();
1445       } else {
1446         dataRecordResultBuilder_.setMessage(value);
1447       }
1448       responseCase_ = 5;
1449       return this;
1450     }
1451     /**
1452      * <code>.DataRecordResult data_record_result = 5;</code>
1453      */
1454     public Builder setDataRecordResult(
1455         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.Builder builderForValue) {
1456       if (dataRecordResultBuilder_ == null) {
1457         response_ = builderForValue.build();
1458         onChanged();
1459       } else {
1460         dataRecordResultBuilder_.setMessage(builderForValue.build());
1461       }
1462       responseCase_ = 5;
1463       return this;
1464     }
1465     /**
1466      * <code>.DataRecordResult data_record_result = 5;</code>
1467      */
1468     public Builder mergeDataRecordResult(org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult value) {
1469       if (dataRecordResultBuilder_ == null) {
1470         if (responseCase_ == 5 &&
1471             response_ != org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.getDefaultInstance()) {
1472           response_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.newBuilder((org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult) response_)
1473               .mergeFrom(value).buildPartial();
1474         } else {
1475           response_ = value;
1476         }
1477         onChanged();
1478       } else {
1479         if (responseCase_ == 5) {
1480           dataRecordResultBuilder_.mergeFrom(value);
1481         } else {
1482           dataRecordResultBuilder_.setMessage(value);
1483         }
1484       }
1485       responseCase_ = 5;
1486       return this;
1487     }
1488     /**
1489      * <code>.DataRecordResult data_record_result = 5;</code>
1490      */
1491     public Builder clearDataRecordResult() {
1492       if (dataRecordResultBuilder_ == null) {
1493         if (responseCase_ == 5) {
1494           responseCase_ = 0;
1495           response_ = null;
1496           onChanged();
1497         }
1498       } else {
1499         if (responseCase_ == 5) {
1500           responseCase_ = 0;
1501           response_ = null;
1502         }
1503         dataRecordResultBuilder_.clear();
1504       }
1505       return this;
1506     }
1507     /**
1508      * <code>.DataRecordResult data_record_result = 5;</code>
1509      */
1510     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.Builder getDataRecordResultBuilder() {
1511       return getDataRecordResultFieldBuilder().getBuilder();
1512     }
1513     /**
1514      * <code>.DataRecordResult data_record_result = 5;</code>
1515      */
1516     @java.lang.Override
1517     public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResultOrBuilder getDataRecordResultOrBuilder() {
1518       if ((responseCase_ == 5) && (dataRecordResultBuilder_ != null)) {
1519         return dataRecordResultBuilder_.getMessageOrBuilder();
1520       } else {
1521         if (responseCase_ == 5) {
1522           return (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult) response_;
1523         }
1524         return org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.getDefaultInstance();
1525       }
1526     }
1527     /**
1528      * <code>.DataRecordResult data_record_result = 5;</code>
1529      */
1530     private com.google.protobuf.SingleFieldBuilderV3<
1531         org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResultOrBuilder> 
1532         getDataRecordResultFieldBuilder() {
1533       if (dataRecordResultBuilder_ == null) {
1534         if (!(responseCase_ == 5)) {
1535           response_ = org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.getDefaultInstance();
1536         }
1537         dataRecordResultBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
1538             org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.Builder, org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResultOrBuilder>(
1539                 (org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult) response_,
1540                 getParentForChildren(),
1541                 isClean());
1542         response_ = null;
1543       }
1544       responseCase_ = 5;
1545       onChanged();
1546       return dataRecordResultBuilder_;
1547     }
1548 
1549     private java.lang.Object errorCode_ = "";
1550     /**
1551      * <code>optional string error_code = 14;</code>
1552      * @return Whether the errorCode field is set.
1553      */
1554     public boolean hasErrorCode() {
1555       return ((bitField0_ & 0x00000020) != 0);
1556     }
1557     /**
1558      * <code>optional string error_code = 14;</code>
1559      * @return The errorCode.
1560      */
1561     public java.lang.String getErrorCode() {
1562       java.lang.Object ref = errorCode_;
1563       if (!(ref instanceof java.lang.String)) {
1564         com.google.protobuf.ByteString bs =
1565             (com.google.protobuf.ByteString) ref;
1566         java.lang.String s = bs.toStringUtf8();
1567         errorCode_ = s;
1568         return s;
1569       } else {
1570         return (java.lang.String) ref;
1571       }
1572     }
1573     /**
1574      * <code>optional string error_code = 14;</code>
1575      * @return The bytes for errorCode.
1576      */
1577     public com.google.protobuf.ByteString
1578         getErrorCodeBytes() {
1579       java.lang.Object ref = errorCode_;
1580       if (ref instanceof String) {
1581         com.google.protobuf.ByteString b = 
1582             com.google.protobuf.ByteString.copyFromUtf8(
1583                 (java.lang.String) ref);
1584         errorCode_ = b;
1585         return b;
1586       } else {
1587         return (com.google.protobuf.ByteString) ref;
1588       }
1589     }
1590     /**
1591      * <code>optional string error_code = 14;</code>
1592      * @param value The errorCode to set.
1593      * @return This builder for chaining.
1594      */
1595     public Builder setErrorCode(
1596         java.lang.String value) {
1597       if (value == null) { throw new NullPointerException(); }
1598       errorCode_ = value;
1599       bitField0_ |= 0x00000020;
1600       onChanged();
1601       return this;
1602     }
1603     /**
1604      * <code>optional string error_code = 14;</code>
1605      * @return This builder for chaining.
1606      */
1607     public Builder clearErrorCode() {
1608       errorCode_ = getDefaultInstance().getErrorCode();
1609       bitField0_ = (bitField0_ & ~0x00000020);
1610       onChanged();
1611       return this;
1612     }
1613     /**
1614      * <code>optional string error_code = 14;</code>
1615      * @param value The bytes for errorCode to set.
1616      * @return This builder for chaining.
1617      */
1618     public Builder setErrorCodeBytes(
1619         com.google.protobuf.ByteString value) {
1620       if (value == null) { throw new NullPointerException(); }
1621       checkByteStringIsUtf8(value);
1622       errorCode_ = value;
1623       bitField0_ |= 0x00000020;
1624       onChanged();
1625       return this;
1626     }
1627 
1628     private java.lang.Object errorMessage_ = "";
1629     /**
1630      * <code>optional string error_message = 15;</code>
1631      * @return Whether the errorMessage field is set.
1632      */
1633     public boolean hasErrorMessage() {
1634       return ((bitField0_ & 0x00000040) != 0);
1635     }
1636     /**
1637      * <code>optional string error_message = 15;</code>
1638      * @return The errorMessage.
1639      */
1640     public java.lang.String getErrorMessage() {
1641       java.lang.Object ref = errorMessage_;
1642       if (!(ref instanceof java.lang.String)) {
1643         com.google.protobuf.ByteString bs =
1644             (com.google.protobuf.ByteString) ref;
1645         java.lang.String s = bs.toStringUtf8();
1646         errorMessage_ = s;
1647         return s;
1648       } else {
1649         return (java.lang.String) ref;
1650       }
1651     }
1652     /**
1653      * <code>optional string error_message = 15;</code>
1654      * @return The bytes for errorMessage.
1655      */
1656     public com.google.protobuf.ByteString
1657         getErrorMessageBytes() {
1658       java.lang.Object ref = errorMessage_;
1659       if (ref instanceof String) {
1660         com.google.protobuf.ByteString b = 
1661             com.google.protobuf.ByteString.copyFromUtf8(
1662                 (java.lang.String) ref);
1663         errorMessage_ = b;
1664         return b;
1665       } else {
1666         return (com.google.protobuf.ByteString) ref;
1667       }
1668     }
1669     /**
1670      * <code>optional string error_message = 15;</code>
1671      * @param value The errorMessage to set.
1672      * @return This builder for chaining.
1673      */
1674     public Builder setErrorMessage(
1675         java.lang.String value) {
1676       if (value == null) { throw new NullPointerException(); }
1677       errorMessage_ = value;
1678       bitField0_ |= 0x00000040;
1679       onChanged();
1680       return this;
1681     }
1682     /**
1683      * <code>optional string error_message = 15;</code>
1684      * @return This builder for chaining.
1685      */
1686     public Builder clearErrorMessage() {
1687       errorMessage_ = getDefaultInstance().getErrorMessage();
1688       bitField0_ = (bitField0_ & ~0x00000040);
1689       onChanged();
1690       return this;
1691     }
1692     /**
1693      * <code>optional string error_message = 15;</code>
1694      * @param value The bytes for errorMessage to set.
1695      * @return This builder for chaining.
1696      */
1697     public Builder setErrorMessageBytes(
1698         com.google.protobuf.ByteString value) {
1699       if (value == null) { throw new NullPointerException(); }
1700       checkByteStringIsUtf8(value);
1701       errorMessage_ = value;
1702       bitField0_ |= 0x00000040;
1703       onChanged();
1704       return this;
1705     }
1706     @java.lang.Override
1707     public final Builder setUnknownFields(
1708         final com.google.protobuf.UnknownFieldSet unknownFields) {
1709       return super.setUnknownFields(unknownFields);
1710     }
1711 
1712     @java.lang.Override
1713     public final Builder mergeUnknownFields(
1714         final com.google.protobuf.UnknownFieldSet unknownFields) {
1715       return super.mergeUnknownFields(unknownFields);
1716     }
1717 
1718 
1719     // @@protoc_insertion_point(builder_scope:CDCResponse)
1720   }
1721 
1722   // @@protoc_insertion_point(class_scope:CDCResponse)
1723   private static final org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse DEFAULT_INSTANCE;
1724   static {
1725     DEFAULT_INSTANCE = new org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse();
1726   }
1727 
1728   public static org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse getDefaultInstance() {
1729     return DEFAULT_INSTANCE;
1730   }
1731 
1732   private static final com.google.protobuf.Parser<CDCResponse>
1733       PARSER = new com.google.protobuf.AbstractParser<CDCResponse>() {
1734     @java.lang.Override
1735     public CDCResponse parsePartialFrom(
1736         com.google.protobuf.CodedInputStream input,
1737         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
1738         throws com.google.protobuf.InvalidProtocolBufferException {
1739       Builder builder = newBuilder();
1740       try {
1741         builder.mergeFrom(input, extensionRegistry);
1742       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
1743         throw e.setUnfinishedMessage(builder.buildPartial());
1744       } catch (com.google.protobuf.UninitializedMessageException e) {
1745         throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
1746       } catch (java.io.IOException e) {
1747         throw new com.google.protobuf.InvalidProtocolBufferException(e)
1748             .setUnfinishedMessage(builder.buildPartial());
1749       }
1750       return builder.buildPartial();
1751     }
1752   };
1753 
1754   public static com.google.protobuf.Parser<CDCResponse> parser() {
1755     return PARSER;
1756   }
1757 
1758   @java.lang.Override
1759   public com.google.protobuf.Parser<CDCResponse> getParserForType() {
1760     return PARSER;
1761   }
1762 
1763   @java.lang.Override
1764   public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.CDCResponse getDefaultInstanceForType() {
1765     return DEFAULT_INSTANCE;
1766   }
1767 
1768 }
1769