1
2
3
4 package org.apache.shardingsphere.data.pipeline.cdc.protocol.response;
5
6
7
8
9 public final class CDCResponse extends
10 com.google.protobuf.GeneratedMessageV3 implements
11
12 CDCResponseOrBuilder {
13 private static final long serialVersionUID = 0L;
14
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
52
53 public enum Status
54 implements com.google.protobuf.ProtocolMessageEnum {
55
56
57
58 UNKNOWN(0),
59
60
61
62 SUCCEED(1),
63
64
65
66 FAILED(2),
67 UNRECOGNIZED(-1),
68 ;
69
70
71
72
73 public static final int UNKNOWN_VALUE = 0;
74
75
76
77 public static final int SUCCEED_VALUE = 1;
78
79
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
94
95
96
97 @java.lang.Deprecated
98 public static Status valueOf(int value) {
99 return forNumber(value);
100 }
101
102
103
104
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
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
183
184
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
216
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
233
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
254
255
256 @java.lang.Override public int getStatusValue() {
257 return status_;
258 }
259
260
261
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
271
272
273 @java.lang.Override
274 public boolean hasServerGreetingResult() {
275 return responseCase_ == 3;
276 }
277
278
279
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
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
302
303
304 @java.lang.Override
305 public boolean hasStreamDataResult() {
306 return responseCase_ == 4;
307 }
308
309
310
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
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
333
334
335 @java.lang.Override
336 public boolean hasDataRecordResult() {
337 return responseCase_ == 5;
338 }
339
340
341
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
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
366
367
368 @java.lang.Override
369 public boolean hasErrorCode() {
370 return ((bitField0_ & 0x00000001) != 0);
371 }
372
373
374
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
391
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
413
414
415 @java.lang.Override
416 public boolean hasErrorMessage() {
417 return ((bitField0_ & 0x00000002) != 0);
418 }
419
420
421
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
438
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
705
706 public static final class Builder extends
707 com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
708
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
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 }
931 case 16: {
932 status_ = input.readEnum();
933 bitField0_ |= 0x00000002;
934 break;
935 }
936 case 26: {
937 input.readMessage(
938 getServerGreetingResultFieldBuilder().getBuilder(),
939 extensionRegistry);
940 responseCase_ = 3;
941 break;
942 }
943 case 34: {
944 input.readMessage(
945 getStreamDataResultFieldBuilder().getBuilder(),
946 extensionRegistry);
947 responseCase_ = 4;
948 break;
949 }
950 case 42: {
951 input.readMessage(
952 getDataRecordResultFieldBuilder().getBuilder(),
953 extensionRegistry);
954 responseCase_ = 5;
955 break;
956 }
957 case 114: {
958 errorCode_ = input.readStringRequireUtf8();
959 bitField0_ |= 0x00000020;
960 break;
961 }
962 case 122: {
963 errorMessage_ = input.readStringRequireUtf8();
964 bitField0_ |= 0x00000040;
965 break;
966 }
967 default: {
968 if (!super.parseUnknownField(input, extensionRegistry, tag)) {
969 done = true;
970 }
971 break;
972 }
973 }
974 }
975 } catch (com.google.protobuf.InvalidProtocolBufferException e) {
976 throw e.unwrapIOException();
977 } finally {
978 onChanged();
979 }
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
1002
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
1018
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
1035
1036
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
1048
1049
1050 public Builder clearRequestId() {
1051 requestId_ = getDefaultInstance().getRequestId();
1052 bitField0_ = (bitField0_ & ~0x00000001);
1053 onChanged();
1054 return this;
1055 }
1056
1057
1058
1059
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
1074
1075
1076 @java.lang.Override public int getStatusValue() {
1077 return status_;
1078 }
1079
1080
1081
1082
1083
1084 public Builder setStatusValue(int value) {
1085 status_ = value;
1086 bitField0_ |= 0x00000002;
1087 onChanged();
1088 return this;
1089 }
1090
1091
1092
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
1101
1102
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
1115
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
1128
1129
1130 @java.lang.Override
1131 public boolean hasServerGreetingResult() {
1132 return responseCase_ == 3;
1133 }
1134
1135
1136
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
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
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
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
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
1226
1227 public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.ServerGreetingResult.Builder getServerGreetingResultBuilder() {
1228 return getServerGreetingResultFieldBuilder().getBuilder();
1229 }
1230
1231
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
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
1270
1271
1272 @java.lang.Override
1273 public boolean hasStreamDataResult() {
1274 return responseCase_ == 4;
1275 }
1276
1277
1278
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
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
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
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
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
1368
1369 public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.StreamDataResult.Builder getStreamDataResultBuilder() {
1370 return getStreamDataResultFieldBuilder().getBuilder();
1371 }
1372
1373
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
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
1412
1413
1414 @java.lang.Override
1415 public boolean hasDataRecordResult() {
1416 return responseCase_ == 5;
1417 }
1418
1419
1420
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
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
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
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
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
1510
1511 public org.apache.shardingsphere.data.pipeline.cdc.protocol.response.DataRecordResult.Builder getDataRecordResultBuilder() {
1512 return getDataRecordResultFieldBuilder().getBuilder();
1513 }
1514
1515
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
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
1553
1554
1555 public boolean hasErrorCode() {
1556 return ((bitField0_ & 0x00000020) != 0);
1557 }
1558
1559
1560
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
1576
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
1593
1594
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
1606
1607
1608 public Builder clearErrorCode() {
1609 errorCode_ = getDefaultInstance().getErrorCode();
1610 bitField0_ = (bitField0_ & ~0x00000020);
1611 onChanged();
1612 return this;
1613 }
1614
1615
1616
1617
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
1632
1633
1634 public boolean hasErrorMessage() {
1635 return ((bitField0_ & 0x00000040) != 0);
1636 }
1637
1638
1639
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
1655
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
1672
1673
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
1685
1686
1687 public Builder clearErrorMessage() {
1688 errorMessage_ = getDefaultInstance().getErrorMessage();
1689 bitField0_ = (bitField0_ & ~0x00000040);
1690 onChanged();
1691 return this;
1692 }
1693
1694
1695
1696
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
1721 }
1722
1723
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