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