1
2
3
4 package org.apache.shardingsphere.data.pipeline.cdc.protocol.request;
5
6
7
8
9 public final class StartStreamingRequestBody extends
10 com.google.protobuf.GeneratedMessageV3 implements
11
12 StartStreamingRequestBodyOrBuilder {
13 private static final long serialVersionUID = 0L;
14
15 private StartStreamingRequestBody(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
16 super(builder);
17 }
18 private StartStreamingRequestBody() {
19 streamingId_ = "";
20 }
21
22 @java.lang.Override
23 @SuppressWarnings({"unused"})
24 protected java.lang.Object newInstance(
25 UnusedPrivateParameter unused) {
26 return new StartStreamingRequestBody();
27 }
28
29 @java.lang.Override
30 public final com.google.protobuf.UnknownFieldSet
31 getUnknownFields() {
32 return this.unknownFields;
33 }
34 public static final com.google.protobuf.Descriptors.Descriptor
35 getDescriptor() {
36 return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StartStreamingRequestBody_descriptor;
37 }
38
39 @java.lang.Override
40 protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
41 internalGetFieldAccessorTable() {
42 return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StartStreamingRequestBody_fieldAccessorTable
43 .ensureFieldAccessorsInitialized(
44 org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.class, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.Builder.class);
45 }
46
47 public static final int STREAMING_ID_FIELD_NUMBER = 1;
48 @SuppressWarnings("serial")
49 private volatile java.lang.Object streamingId_ = "";
50
51
52
53
54 @java.lang.Override
55 public java.lang.String getStreamingId() {
56 java.lang.Object ref = streamingId_;
57 if (ref instanceof java.lang.String) {
58 return (java.lang.String) ref;
59 } else {
60 com.google.protobuf.ByteString bs =
61 (com.google.protobuf.ByteString) ref;
62 java.lang.String s = bs.toStringUtf8();
63 streamingId_ = s;
64 return s;
65 }
66 }
67
68
69
70
71 @java.lang.Override
72 public com.google.protobuf.ByteString
73 getStreamingIdBytes() {
74 java.lang.Object ref = streamingId_;
75 if (ref instanceof java.lang.String) {
76 com.google.protobuf.ByteString b =
77 com.google.protobuf.ByteString.copyFromUtf8(
78 (java.lang.String) ref);
79 streamingId_ = b;
80 return b;
81 } else {
82 return (com.google.protobuf.ByteString) ref;
83 }
84 }
85
86 private byte memoizedIsInitialized = -1;
87 @java.lang.Override
88 public final boolean isInitialized() {
89 byte isInitialized = memoizedIsInitialized;
90 if (isInitialized == 1) return true;
91 if (isInitialized == 0) return false;
92
93 memoizedIsInitialized = 1;
94 return true;
95 }
96
97 @java.lang.Override
98 public void writeTo(com.google.protobuf.CodedOutputStream output)
99 throws java.io.IOException {
100 if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(streamingId_)) {
101 com.google.protobuf.GeneratedMessageV3.writeString(output, 1, streamingId_);
102 }
103 getUnknownFields().writeTo(output);
104 }
105
106 @java.lang.Override
107 public int getSerializedSize() {
108 int size = memoizedSize;
109 if (size != -1) return size;
110
111 size = 0;
112 if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(streamingId_)) {
113 size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, streamingId_);
114 }
115 size += getUnknownFields().getSerializedSize();
116 memoizedSize = size;
117 return size;
118 }
119
120 @java.lang.Override
121 public boolean equals(final java.lang.Object obj) {
122 if (obj == this) {
123 return true;
124 }
125 if (!(obj instanceof org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody)) {
126 return super.equals(obj);
127 }
128 org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody other = (org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) obj;
129
130 if (!getStreamingId()
131 .equals(other.getStreamingId())) return false;
132 if (!getUnknownFields().equals(other.getUnknownFields())) return false;
133 return true;
134 }
135
136 @java.lang.Override
137 public int hashCode() {
138 if (memoizedHashCode != 0) {
139 return memoizedHashCode;
140 }
141 int hash = 41;
142 hash = (19 * hash) + getDescriptor().hashCode();
143 hash = (37 * hash) + STREAMING_ID_FIELD_NUMBER;
144 hash = (53 * hash) + getStreamingId().hashCode();
145 hash = (29 * hash) + getUnknownFields().hashCode();
146 memoizedHashCode = hash;
147 return hash;
148 }
149
150 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(
151 java.nio.ByteBuffer data)
152 throws com.google.protobuf.InvalidProtocolBufferException {
153 return PARSER.parseFrom(data);
154 }
155 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(
156 java.nio.ByteBuffer data,
157 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
158 throws com.google.protobuf.InvalidProtocolBufferException {
159 return PARSER.parseFrom(data, extensionRegistry);
160 }
161 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(
162 com.google.protobuf.ByteString data)
163 throws com.google.protobuf.InvalidProtocolBufferException {
164 return PARSER.parseFrom(data);
165 }
166 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(
167 com.google.protobuf.ByteString data,
168 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
169 throws com.google.protobuf.InvalidProtocolBufferException {
170 return PARSER.parseFrom(data, extensionRegistry);
171 }
172 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(byte[] data)
173 throws com.google.protobuf.InvalidProtocolBufferException {
174 return PARSER.parseFrom(data);
175 }
176 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(
177 byte[] data,
178 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
179 throws com.google.protobuf.InvalidProtocolBufferException {
180 return PARSER.parseFrom(data, extensionRegistry);
181 }
182 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(java.io.InputStream input)
183 throws java.io.IOException {
184 return com.google.protobuf.GeneratedMessageV3
185 .parseWithIOException(PARSER, input);
186 }
187 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(
188 java.io.InputStream input,
189 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
190 throws java.io.IOException {
191 return com.google.protobuf.GeneratedMessageV3
192 .parseWithIOException(PARSER, input, extensionRegistry);
193 }
194 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseDelimitedFrom(java.io.InputStream input)
195 throws java.io.IOException {
196 return com.google.protobuf.GeneratedMessageV3
197 .parseDelimitedWithIOException(PARSER, input);
198 }
199 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseDelimitedFrom(
200 java.io.InputStream input,
201 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
202 throws java.io.IOException {
203 return com.google.protobuf.GeneratedMessageV3
204 .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
205 }
206 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(
207 com.google.protobuf.CodedInputStream input)
208 throws java.io.IOException {
209 return com.google.protobuf.GeneratedMessageV3
210 .parseWithIOException(PARSER, input);
211 }
212 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody parseFrom(
213 com.google.protobuf.CodedInputStream input,
214 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
215 throws java.io.IOException {
216 return com.google.protobuf.GeneratedMessageV3
217 .parseWithIOException(PARSER, input, extensionRegistry);
218 }
219
220 @java.lang.Override
221 public Builder newBuilderForType() { return newBuilder(); }
222 public static Builder newBuilder() {
223 return DEFAULT_INSTANCE.toBuilder();
224 }
225 public static Builder newBuilder(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody prototype) {
226 return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
227 }
228 @java.lang.Override
229 public Builder toBuilder() {
230 return this == DEFAULT_INSTANCE
231 ? new Builder() : new Builder().mergeFrom(this);
232 }
233
234 @java.lang.Override
235 protected Builder newBuilderForType(
236 com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
237 Builder builder = new Builder(parent);
238 return builder;
239 }
240
241
242
243 public static final class Builder extends
244 com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
245
246 org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBodyOrBuilder {
247 public static final com.google.protobuf.Descriptors.Descriptor
248 getDescriptor() {
249 return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StartStreamingRequestBody_descriptor;
250 }
251
252 @java.lang.Override
253 protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
254 internalGetFieldAccessorTable() {
255 return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StartStreamingRequestBody_fieldAccessorTable
256 .ensureFieldAccessorsInitialized(
257 org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.class, org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.Builder.class);
258 }
259
260
261 private Builder() {
262
263 }
264
265 private Builder(
266 com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
267 super(parent);
268
269 }
270 @java.lang.Override
271 public Builder clear() {
272 super.clear();
273 bitField0_ = 0;
274 streamingId_ = "";
275 return this;
276 }
277
278 @java.lang.Override
279 public com.google.protobuf.Descriptors.Descriptor
280 getDescriptorForType() {
281 return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.CDCRequestProtocol.internal_static_StartStreamingRequestBody_descriptor;
282 }
283
284 @java.lang.Override
285 public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody getDefaultInstanceForType() {
286 return org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance();
287 }
288
289 @java.lang.Override
290 public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody build() {
291 org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody result = buildPartial();
292 if (!result.isInitialized()) {
293 throw newUninitializedMessageException(result);
294 }
295 return result;
296 }
297
298 @java.lang.Override
299 public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody buildPartial() {
300 org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody result = new org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody(this);
301 if (bitField0_ != 0) { buildPartial0(result); }
302 onBuilt();
303 return result;
304 }
305
306 private void buildPartial0(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody result) {
307 int from_bitField0_ = bitField0_;
308 if (((from_bitField0_ & 0x00000001) != 0)) {
309 result.streamingId_ = streamingId_;
310 }
311 }
312
313 @java.lang.Override
314 public Builder clone() {
315 return super.clone();
316 }
317 @java.lang.Override
318 public Builder setField(
319 com.google.protobuf.Descriptors.FieldDescriptor field,
320 java.lang.Object value) {
321 return super.setField(field, value);
322 }
323 @java.lang.Override
324 public Builder clearField(
325 com.google.protobuf.Descriptors.FieldDescriptor field) {
326 return super.clearField(field);
327 }
328 @java.lang.Override
329 public Builder clearOneof(
330 com.google.protobuf.Descriptors.OneofDescriptor oneof) {
331 return super.clearOneof(oneof);
332 }
333 @java.lang.Override
334 public Builder setRepeatedField(
335 com.google.protobuf.Descriptors.FieldDescriptor field,
336 int index, java.lang.Object value) {
337 return super.setRepeatedField(field, index, value);
338 }
339 @java.lang.Override
340 public Builder addRepeatedField(
341 com.google.protobuf.Descriptors.FieldDescriptor field,
342 java.lang.Object value) {
343 return super.addRepeatedField(field, value);
344 }
345 @java.lang.Override
346 public Builder mergeFrom(com.google.protobuf.Message other) {
347 if (other instanceof org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody) {
348 return mergeFrom((org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody)other);
349 } else {
350 super.mergeFrom(other);
351 return this;
352 }
353 }
354
355 public Builder mergeFrom(org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody other) {
356 if (other == org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody.getDefaultInstance()) return this;
357 if (!other.getStreamingId().isEmpty()) {
358 streamingId_ = other.streamingId_;
359 bitField0_ |= 0x00000001;
360 onChanged();
361 }
362 this.mergeUnknownFields(other.getUnknownFields());
363 onChanged();
364 return this;
365 }
366
367 @java.lang.Override
368 public final boolean isInitialized() {
369 return true;
370 }
371
372 @java.lang.Override
373 public Builder mergeFrom(
374 com.google.protobuf.CodedInputStream input,
375 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
376 throws java.io.IOException {
377 if (extensionRegistry == null) {
378 throw new java.lang.NullPointerException();
379 }
380 try {
381 boolean done = false;
382 while (!done) {
383 int tag = input.readTag();
384 switch (tag) {
385 case 0:
386 done = true;
387 break;
388 case 10: {
389 streamingId_ = input.readStringRequireUtf8();
390 bitField0_ |= 0x00000001;
391 break;
392 }
393 default: {
394 if (!super.parseUnknownField(input, extensionRegistry, tag)) {
395 done = true;
396 }
397 break;
398 }
399 }
400 }
401 } catch (com.google.protobuf.InvalidProtocolBufferException e) {
402 throw e.unwrapIOException();
403 } finally {
404 onChanged();
405 }
406 return this;
407 }
408 private int bitField0_;
409
410 private java.lang.Object streamingId_ = "";
411
412
413
414
415 public java.lang.String getStreamingId() {
416 java.lang.Object ref = streamingId_;
417 if (!(ref instanceof java.lang.String)) {
418 com.google.protobuf.ByteString bs =
419 (com.google.protobuf.ByteString) ref;
420 java.lang.String s = bs.toStringUtf8();
421 streamingId_ = s;
422 return s;
423 } else {
424 return (java.lang.String) ref;
425 }
426 }
427
428
429
430
431 public com.google.protobuf.ByteString
432 getStreamingIdBytes() {
433 java.lang.Object ref = streamingId_;
434 if (ref instanceof String) {
435 com.google.protobuf.ByteString b =
436 com.google.protobuf.ByteString.copyFromUtf8(
437 (java.lang.String) ref);
438 streamingId_ = b;
439 return b;
440 } else {
441 return (com.google.protobuf.ByteString) ref;
442 }
443 }
444
445
446
447
448
449 public Builder setStreamingId(
450 java.lang.String value) {
451 if (value == null) { throw new NullPointerException(); }
452 streamingId_ = value;
453 bitField0_ |= 0x00000001;
454 onChanged();
455 return this;
456 }
457
458
459
460
461 public Builder clearStreamingId() {
462 streamingId_ = getDefaultInstance().getStreamingId();
463 bitField0_ = (bitField0_ & ~0x00000001);
464 onChanged();
465 return this;
466 }
467
468
469
470
471
472 public Builder setStreamingIdBytes(
473 com.google.protobuf.ByteString value) {
474 if (value == null) { throw new NullPointerException(); }
475 checkByteStringIsUtf8(value);
476 streamingId_ = value;
477 bitField0_ |= 0x00000001;
478 onChanged();
479 return this;
480 }
481 @java.lang.Override
482 public final Builder setUnknownFields(
483 final com.google.protobuf.UnknownFieldSet unknownFields) {
484 return super.setUnknownFields(unknownFields);
485 }
486
487 @java.lang.Override
488 public final Builder mergeUnknownFields(
489 final com.google.protobuf.UnknownFieldSet unknownFields) {
490 return super.mergeUnknownFields(unknownFields);
491 }
492
493
494
495 }
496
497
498 private static final org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody DEFAULT_INSTANCE;
499 static {
500 DEFAULT_INSTANCE = new org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody();
501 }
502
503 public static org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody getDefaultInstance() {
504 return DEFAULT_INSTANCE;
505 }
506
507 private static final com.google.protobuf.Parser<StartStreamingRequestBody>
508 PARSER = new com.google.protobuf.AbstractParser<StartStreamingRequestBody>() {
509 @java.lang.Override
510 public StartStreamingRequestBody parsePartialFrom(
511 com.google.protobuf.CodedInputStream input,
512 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
513 throws com.google.protobuf.InvalidProtocolBufferException {
514 Builder builder = newBuilder();
515 try {
516 builder.mergeFrom(input, extensionRegistry);
517 } catch (com.google.protobuf.InvalidProtocolBufferException e) {
518 throw e.setUnfinishedMessage(builder.buildPartial());
519 } catch (com.google.protobuf.UninitializedMessageException e) {
520 throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
521 } catch (java.io.IOException e) {
522 throw new com.google.protobuf.InvalidProtocolBufferException(e)
523 .setUnfinishedMessage(builder.buildPartial());
524 }
525 return builder.buildPartial();
526 }
527 };
528
529 public static com.google.protobuf.Parser<StartStreamingRequestBody> parser() {
530 return PARSER;
531 }
532
533 @java.lang.Override
534 public com.google.protobuf.Parser<StartStreamingRequestBody> getParserForType() {
535 return PARSER;
536 }
537
538 @java.lang.Override
539 public org.apache.shardingsphere.data.pipeline.cdc.protocol.request.StartStreamingRequestBody getDefaultInstanceForType() {
540 return DEFAULT_INSTANCE;
541 }
542
543 }
544