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