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