View Javadoc
1   // Generated by the protocol buffer compiler.  DO NOT EDIT!
2   // source: CDCRequestProtocol.proto
3   
4   package org.apache.shardingsphere.data.pipeline.cdc.protocol.request;
5   
6   /**
7    * Protobuf type {@code StreamDataRequestBody}
8    */
9   public final class StreamDataRequestBody extends
10      com.google.protobuf.GeneratedMessageV3 implements
11      // @@protoc_insertion_point(message_implements:StreamDataRequestBody)
12      StreamDataRequestBodyOrBuilder {
13  private static final long serialVersionUID = 0L;
14    // Use StreamDataRequestBody.newBuilder() to construct.
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        // @@protoc_insertion_point(interface_extends:StreamDataRequestBody.SchemaTable)
50        com.google.protobuf.MessageOrBuilder {
51  
52      /**
53       * <code>string schema = 1;</code>
54       * @return The schema.
55       */
56      java.lang.String getSchema();
57      /**
58       * <code>string schema = 1;</code>
59       * @return The bytes for schema.
60       */
61      com.google.protobuf.ByteString
62          getSchemaBytes();
63  
64      /**
65       * <code>string table = 2;</code>
66       * @return The table.
67       */
68      java.lang.String getTable();
69      /**
70       * <code>string table = 2;</code>
71       * @return The bytes for table.
72       */
73      com.google.protobuf.ByteString
74          getTableBytes();
75    }
76    /**
77     * Protobuf type {@code StreamDataRequestBody.SchemaTable}
78     */
79    public static final class SchemaTable extends
80        com.google.protobuf.GeneratedMessageV3 implements
81        // @@protoc_insertion_point(message_implements:StreamDataRequestBody.SchemaTable)
82        SchemaTableOrBuilder {
83    private static final long serialVersionUID = 0L;
84      // Use SchemaTable.newBuilder() to construct.
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      * <code>string schema = 1;</code>
123      * @return The schema.
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      * <code>string schema = 1;</code>
140      * @return The bytes for schema.
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      * <code>string table = 2;</code>
162      * @return The table.
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      * <code>string table = 2;</code>
179      * @return The bytes for table.
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      * Protobuf type {@code StreamDataRequestBody.SchemaTable}
362      */
363     public static final class Builder extends
364         com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
365         // @@protoc_insertion_point(builder_implements:StreamDataRequestBody.SchemaTable)
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       // Construct using org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.SchemaTable.newBuilder()
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               } // case 10
522               case 18: {
523                 table_ = input.readStringRequireUtf8();
524                 bitField0_ |= 0x00000002;
525                 break;
526               } // case 18
527               default: {
528                 if (!super.parseUnknownField(input, extensionRegistry, tag)) {
529                   done = true; // was an endgroup tag
530                 }
531                 break;
532               } // default:
533             } // switch (tag)
534           } // while (!done)
535         } catch (com.google.protobuf.InvalidProtocolBufferException e) {
536           throw e.unwrapIOException();
537         } finally {
538           onChanged();
539         } // finally
540         return this;
541       }
542       private int bitField0_;
543 
544       private java.lang.Object schema_ = "";
545       /**
546        * <code>string schema = 1;</code>
547        * @return The schema.
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        * <code>string schema = 1;</code>
563        * @return The bytes for schema.
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        * <code>string schema = 1;</code>
580        * @param value The schema to set.
581        * @return This builder for chaining.
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        * <code>string schema = 1;</code>
593        * @return This builder for chaining.
594        */
595       public Builder clearSchema() {
596         schema_ = getDefaultInstance().getSchema();
597         bitField0_ = (bitField0_ & ~0x00000001);
598         onChanged();
599         return this;
600       }
601       /**
602        * <code>string schema = 1;</code>
603        * @param value The bytes for schema to set.
604        * @return This builder for chaining.
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        * <code>string table = 2;</code>
619        * @return The table.
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        * <code>string table = 2;</code>
635        * @return The bytes for table.
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        * <code>string table = 2;</code>
652        * @param value The table to set.
653        * @return This builder for chaining.
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        * <code>string table = 2;</code>
665        * @return This builder for chaining.
666        */
667       public Builder clearTable() {
668         table_ = getDefaultInstance().getTable();
669         bitField0_ = (bitField0_ & ~0x00000002);
670         onChanged();
671         return this;
672       }
673       /**
674        * <code>string table = 2;</code>
675        * @param value The bytes for table to set.
676        * @return This builder for chaining.
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       // @@protoc_insertion_point(builder_scope:StreamDataRequestBody.SchemaTable)
701     }
702 
703     // @@protoc_insertion_point(class_scope:StreamDataRequestBody.SchemaTable)
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    * <code>string database = 1;</code>
756    * @return The database.
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    * <code>string database = 1;</code>
773    * @return The bytes for database.
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    * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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    * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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    * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
810    */
811   @java.lang.Override
812   public int getSourceSchemaTableCount() {
813     return sourceSchemaTable_.size();
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.SchemaTable getSourceSchemaTable(int index) {
820     return sourceSchemaTable_.get(index);
821   }
822   /**
823    * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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    * <code>bool full = 3;</code>
835    * @return The full.
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    * Protobuf type {@code StreamDataRequestBody}
1023    */
1024   public static final class Builder extends
1025       com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
1026       // @@protoc_insertion_point(builder_implements:StreamDataRequestBody)
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     // Construct using org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StreamDataRequestBody.newBuilder()
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             } // case 10
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             } // case 18
1240             case 24: {
1241               full_ = input.readBool();
1242               bitField0_ |= 0x00000004;
1243               break;
1244             } // case 24
1245             default: {
1246               if (!super.parseUnknownField(input, extensionRegistry, tag)) {
1247                 done = true; // was an endgroup tag
1248               }
1249               break;
1250             } // default:
1251           } // switch (tag)
1252         } // while (!done)
1253       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
1254         throw e.unwrapIOException();
1255       } finally {
1256         onChanged();
1257       } // finally
1258       return this;
1259     }
1260     private int bitField0_;
1261 
1262     private java.lang.Object database_ = "";
1263     /**
1264      * <code>string database = 1;</code>
1265      * @return The database.
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      * <code>string database = 1;</code>
1281      * @return The bytes for database.
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      * <code>string database = 1;</code>
1298      * @param value The database to set.
1299      * @return This builder for chaining.
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      * <code>string database = 1;</code>
1311      * @return This builder for chaining.
1312      */
1313     public Builder clearDatabase() {
1314       database_ = getDefaultInstance().getDatabase();
1315       bitField0_ = (bitField0_ & ~0x00000001);
1316       onChanged();
1317       return this;
1318     }
1319     /**
1320      * <code>string database = 1;</code>
1321      * @param value The bytes for database to set.
1322      * @return This builder for chaining.
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
1358      */
1359     public int getSourceSchemaTableCount() {
1360       if (sourceSchemaTableBuilder_ == null) {
1361         return sourceSchemaTable_.size();
1362       } else {
1363         return sourceSchemaTableBuilder_.getCount();
1364       }
1365     }
1366     /**
1367      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>repeated .StreamDataRequestBody.SchemaTable source_schema_table = 2;</code>
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      * <code>bool full = 3;</code>
1577      * @return The full.
1578      */
1579     @java.lang.Override
1580     public boolean getFull() {
1581       return full_;
1582     }
1583     /**
1584      * <code>bool full = 3;</code>
1585      * @param value The full to set.
1586      * @return This builder for chaining.
1587      */
1588     public Builder setFull(boolean value) {
1589       
1590       full_ = value;
1591       bitField0_ |= 0x00000004;
1592       onChanged();
1593       return this;
1594     }
1595     /**
1596      * <code>bool full = 3;</code>
1597      * @return This builder for chaining.
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     // @@protoc_insertion_point(builder_scope:StreamDataRequestBody)
1619   }
1620 
1621   // @@protoc_insertion_point(class_scope:StreamDataRequestBody)
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