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