1
2
3
4 package org.apache.hadoop.hbase.protobuf.generated;
5
6 public final class AggregateProtos {
7 private AggregateProtos() {}
8 public static void registerAllExtensions(
9 com.google.protobuf.ExtensionRegistry registry) {
10 }
11 public interface AggregateArgumentOrBuilder
12 extends com.google.protobuf.MessageOrBuilder {
13
14
15 boolean hasInterpreterClassName();
16 String getInterpreterClassName();
17
18
19 boolean hasScan();
20 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan getScan();
21 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanOrBuilder getScanOrBuilder();
22
23
24 boolean hasInterpreterSpecificBytes();
25 com.google.protobuf.ByteString getInterpreterSpecificBytes();
26 }
27 public static final class AggregateArgument extends
28 com.google.protobuf.GeneratedMessage
29 implements AggregateArgumentOrBuilder {
30
31 private AggregateArgument(Builder builder) {
32 super(builder);
33 }
34 private AggregateArgument(boolean noInit) {}
35
36 private static final AggregateArgument defaultInstance;
37 public static AggregateArgument getDefaultInstance() {
38 return defaultInstance;
39 }
40
41 public AggregateArgument getDefaultInstanceForType() {
42 return defaultInstance;
43 }
44
45 public static final com.google.protobuf.Descriptors.Descriptor
46 getDescriptor() {
47 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.internal_static_AggregateArgument_descriptor;
48 }
49
50 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
51 internalGetFieldAccessorTable() {
52 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.internal_static_AggregateArgument_fieldAccessorTable;
53 }
54
55 private int bitField0_;
56
57 public static final int INTERPRETERCLASSNAME_FIELD_NUMBER = 1;
58 private java.lang.Object interpreterClassName_;
59 public boolean hasInterpreterClassName() {
60 return ((bitField0_ & 0x00000001) == 0x00000001);
61 }
62 public String getInterpreterClassName() {
63 java.lang.Object ref = interpreterClassName_;
64 if (ref instanceof String) {
65 return (String) ref;
66 } else {
67 com.google.protobuf.ByteString bs =
68 (com.google.protobuf.ByteString) ref;
69 String s = bs.toStringUtf8();
70 if (com.google.protobuf.Internal.isValidUtf8(bs)) {
71 interpreterClassName_ = s;
72 }
73 return s;
74 }
75 }
76 private com.google.protobuf.ByteString getInterpreterClassNameBytes() {
77 java.lang.Object ref = interpreterClassName_;
78 if (ref instanceof String) {
79 com.google.protobuf.ByteString b =
80 com.google.protobuf.ByteString.copyFromUtf8((String) ref);
81 interpreterClassName_ = b;
82 return b;
83 } else {
84 return (com.google.protobuf.ByteString) ref;
85 }
86 }
87
88
89 public static final int SCAN_FIELD_NUMBER = 2;
90 private org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan scan_;
91 public boolean hasScan() {
92 return ((bitField0_ & 0x00000002) == 0x00000002);
93 }
94 public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan getScan() {
95 return scan_;
96 }
97 public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanOrBuilder getScanOrBuilder() {
98 return scan_;
99 }
100
101
102 public static final int INTERPRETERSPECIFICBYTES_FIELD_NUMBER = 3;
103 private com.google.protobuf.ByteString interpreterSpecificBytes_;
104 public boolean hasInterpreterSpecificBytes() {
105 return ((bitField0_ & 0x00000004) == 0x00000004);
106 }
107 public com.google.protobuf.ByteString getInterpreterSpecificBytes() {
108 return interpreterSpecificBytes_;
109 }
110
111 private void initFields() {
112 interpreterClassName_ = "";
113 scan_ = org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.getDefaultInstance();
114 interpreterSpecificBytes_ = com.google.protobuf.ByteString.EMPTY;
115 }
116 private byte memoizedIsInitialized = -1;
117 public final boolean isInitialized() {
118 byte isInitialized = memoizedIsInitialized;
119 if (isInitialized != -1) return isInitialized == 1;
120
121 if (!hasInterpreterClassName()) {
122 memoizedIsInitialized = 0;
123 return false;
124 }
125 if (!hasScan()) {
126 memoizedIsInitialized = 0;
127 return false;
128 }
129 if (!getScan().isInitialized()) {
130 memoizedIsInitialized = 0;
131 return false;
132 }
133 memoizedIsInitialized = 1;
134 return true;
135 }
136
137 public void writeTo(com.google.protobuf.CodedOutputStream output)
138 throws java.io.IOException {
139 getSerializedSize();
140 if (((bitField0_ & 0x00000001) == 0x00000001)) {
141 output.writeBytes(1, getInterpreterClassNameBytes());
142 }
143 if (((bitField0_ & 0x00000002) == 0x00000002)) {
144 output.writeMessage(2, scan_);
145 }
146 if (((bitField0_ & 0x00000004) == 0x00000004)) {
147 output.writeBytes(3, interpreterSpecificBytes_);
148 }
149 getUnknownFields().writeTo(output);
150 }
151
152 private int memoizedSerializedSize = -1;
153 public int getSerializedSize() {
154 int size = memoizedSerializedSize;
155 if (size != -1) return size;
156
157 size = 0;
158 if (((bitField0_ & 0x00000001) == 0x00000001)) {
159 size += com.google.protobuf.CodedOutputStream
160 .computeBytesSize(1, getInterpreterClassNameBytes());
161 }
162 if (((bitField0_ & 0x00000002) == 0x00000002)) {
163 size += com.google.protobuf.CodedOutputStream
164 .computeMessageSize(2, scan_);
165 }
166 if (((bitField0_ & 0x00000004) == 0x00000004)) {
167 size += com.google.protobuf.CodedOutputStream
168 .computeBytesSize(3, interpreterSpecificBytes_);
169 }
170 size += getUnknownFields().getSerializedSize();
171 memoizedSerializedSize = size;
172 return size;
173 }
174
175 private static final long serialVersionUID = 0L;
176 @java.lang.Override
177 protected java.lang.Object writeReplace()
178 throws java.io.ObjectStreamException {
179 return super.writeReplace();
180 }
181
182 @java.lang.Override
183 public boolean equals(final java.lang.Object obj) {
184 if (obj == this) {
185 return true;
186 }
187 if (!(obj instanceof org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)) {
188 return super.equals(obj);
189 }
190 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument other = (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument) obj;
191
192 boolean result = true;
193 result = result && (hasInterpreterClassName() == other.hasInterpreterClassName());
194 if (hasInterpreterClassName()) {
195 result = result && getInterpreterClassName()
196 .equals(other.getInterpreterClassName());
197 }
198 result = result && (hasScan() == other.hasScan());
199 if (hasScan()) {
200 result = result && getScan()
201 .equals(other.getScan());
202 }
203 result = result && (hasInterpreterSpecificBytes() == other.hasInterpreterSpecificBytes());
204 if (hasInterpreterSpecificBytes()) {
205 result = result && getInterpreterSpecificBytes()
206 .equals(other.getInterpreterSpecificBytes());
207 }
208 result = result &&
209 getUnknownFields().equals(other.getUnknownFields());
210 return result;
211 }
212
213 @java.lang.Override
214 public int hashCode() {
215 int hash = 41;
216 hash = (19 * hash) + getDescriptorForType().hashCode();
217 if (hasInterpreterClassName()) {
218 hash = (37 * hash) + INTERPRETERCLASSNAME_FIELD_NUMBER;
219 hash = (53 * hash) + getInterpreterClassName().hashCode();
220 }
221 if (hasScan()) {
222 hash = (37 * hash) + SCAN_FIELD_NUMBER;
223 hash = (53 * hash) + getScan().hashCode();
224 }
225 if (hasInterpreterSpecificBytes()) {
226 hash = (37 * hash) + INTERPRETERSPECIFICBYTES_FIELD_NUMBER;
227 hash = (53 * hash) + getInterpreterSpecificBytes().hashCode();
228 }
229 hash = (29 * hash) + getUnknownFields().hashCode();
230 return hash;
231 }
232
233 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseFrom(
234 com.google.protobuf.ByteString data)
235 throws com.google.protobuf.InvalidProtocolBufferException {
236 return newBuilder().mergeFrom(data).buildParsed();
237 }
238 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseFrom(
239 com.google.protobuf.ByteString data,
240 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
241 throws com.google.protobuf.InvalidProtocolBufferException {
242 return newBuilder().mergeFrom(data, extensionRegistry)
243 .buildParsed();
244 }
245 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseFrom(byte[] data)
246 throws com.google.protobuf.InvalidProtocolBufferException {
247 return newBuilder().mergeFrom(data).buildParsed();
248 }
249 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseFrom(
250 byte[] data,
251 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
252 throws com.google.protobuf.InvalidProtocolBufferException {
253 return newBuilder().mergeFrom(data, extensionRegistry)
254 .buildParsed();
255 }
256 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseFrom(java.io.InputStream input)
257 throws java.io.IOException {
258 return newBuilder().mergeFrom(input).buildParsed();
259 }
260 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseFrom(
261 java.io.InputStream input,
262 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
263 throws java.io.IOException {
264 return newBuilder().mergeFrom(input, extensionRegistry)
265 .buildParsed();
266 }
267 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseDelimitedFrom(java.io.InputStream input)
268 throws java.io.IOException {
269 Builder builder = newBuilder();
270 if (builder.mergeDelimitedFrom(input)) {
271 return builder.buildParsed();
272 } else {
273 return null;
274 }
275 }
276 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseDelimitedFrom(
277 java.io.InputStream input,
278 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
279 throws java.io.IOException {
280 Builder builder = newBuilder();
281 if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
282 return builder.buildParsed();
283 } else {
284 return null;
285 }
286 }
287 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseFrom(
288 com.google.protobuf.CodedInputStream input)
289 throws java.io.IOException {
290 return newBuilder().mergeFrom(input).buildParsed();
291 }
292 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument parseFrom(
293 com.google.protobuf.CodedInputStream input,
294 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
295 throws java.io.IOException {
296 return newBuilder().mergeFrom(input, extensionRegistry)
297 .buildParsed();
298 }
299
300 public static Builder newBuilder() { return Builder.create(); }
301 public Builder newBuilderForType() { return newBuilder(); }
302 public static Builder newBuilder(org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument prototype) {
303 return newBuilder().mergeFrom(prototype);
304 }
305 public Builder toBuilder() { return newBuilder(this); }
306
307 @java.lang.Override
308 protected Builder newBuilderForType(
309 com.google.protobuf.GeneratedMessage.BuilderParent parent) {
310 Builder builder = new Builder(parent);
311 return builder;
312 }
313 public static final class Builder extends
314 com.google.protobuf.GeneratedMessage.Builder<Builder>
315 implements org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgumentOrBuilder {
316 public static final com.google.protobuf.Descriptors.Descriptor
317 getDescriptor() {
318 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.internal_static_AggregateArgument_descriptor;
319 }
320
321 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
322 internalGetFieldAccessorTable() {
323 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.internal_static_AggregateArgument_fieldAccessorTable;
324 }
325
326
327 private Builder() {
328 maybeForceBuilderInitialization();
329 }
330
331 private Builder(BuilderParent parent) {
332 super(parent);
333 maybeForceBuilderInitialization();
334 }
335 private void maybeForceBuilderInitialization() {
336 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
337 getScanFieldBuilder();
338 }
339 }
340 private static Builder create() {
341 return new Builder();
342 }
343
344 public Builder clear() {
345 super.clear();
346 interpreterClassName_ = "";
347 bitField0_ = (bitField0_ & ~0x00000001);
348 if (scanBuilder_ == null) {
349 scan_ = org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.getDefaultInstance();
350 } else {
351 scanBuilder_.clear();
352 }
353 bitField0_ = (bitField0_ & ~0x00000002);
354 interpreterSpecificBytes_ = com.google.protobuf.ByteString.EMPTY;
355 bitField0_ = (bitField0_ & ~0x00000004);
356 return this;
357 }
358
359 public Builder clone() {
360 return create().mergeFrom(buildPartial());
361 }
362
363 public com.google.protobuf.Descriptors.Descriptor
364 getDescriptorForType() {
365 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDescriptor();
366 }
367
368 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument getDefaultInstanceForType() {
369 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
370 }
371
372 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument build() {
373 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument result = buildPartial();
374 if (!result.isInitialized()) {
375 throw newUninitializedMessageException(result);
376 }
377 return result;
378 }
379
380 private org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument buildParsed()
381 throws com.google.protobuf.InvalidProtocolBufferException {
382 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument result = buildPartial();
383 if (!result.isInitialized()) {
384 throw newUninitializedMessageException(
385 result).asInvalidProtocolBufferException();
386 }
387 return result;
388 }
389
390 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument buildPartial() {
391 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument result = new org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument(this);
392 int from_bitField0_ = bitField0_;
393 int to_bitField0_ = 0;
394 if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
395 to_bitField0_ |= 0x00000001;
396 }
397 result.interpreterClassName_ = interpreterClassName_;
398 if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
399 to_bitField0_ |= 0x00000002;
400 }
401 if (scanBuilder_ == null) {
402 result.scan_ = scan_;
403 } else {
404 result.scan_ = scanBuilder_.build();
405 }
406 if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
407 to_bitField0_ |= 0x00000004;
408 }
409 result.interpreterSpecificBytes_ = interpreterSpecificBytes_;
410 result.bitField0_ = to_bitField0_;
411 onBuilt();
412 return result;
413 }
414
415 public Builder mergeFrom(com.google.protobuf.Message other) {
416 if (other instanceof org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument) {
417 return mergeFrom((org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)other);
418 } else {
419 super.mergeFrom(other);
420 return this;
421 }
422 }
423
424 public Builder mergeFrom(org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument other) {
425 if (other == org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance()) return this;
426 if (other.hasInterpreterClassName()) {
427 setInterpreterClassName(other.getInterpreterClassName());
428 }
429 if (other.hasScan()) {
430 mergeScan(other.getScan());
431 }
432 if (other.hasInterpreterSpecificBytes()) {
433 setInterpreterSpecificBytes(other.getInterpreterSpecificBytes());
434 }
435 this.mergeUnknownFields(other.getUnknownFields());
436 return this;
437 }
438
439 public final boolean isInitialized() {
440 if (!hasInterpreterClassName()) {
441
442 return false;
443 }
444 if (!hasScan()) {
445
446 return false;
447 }
448 if (!getScan().isInitialized()) {
449
450 return false;
451 }
452 return true;
453 }
454
455 public Builder mergeFrom(
456 com.google.protobuf.CodedInputStream input,
457 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
458 throws java.io.IOException {
459 com.google.protobuf.UnknownFieldSet.Builder unknownFields =
460 com.google.protobuf.UnknownFieldSet.newBuilder(
461 this.getUnknownFields());
462 while (true) {
463 int tag = input.readTag();
464 switch (tag) {
465 case 0:
466 this.setUnknownFields(unknownFields.build());
467 onChanged();
468 return this;
469 default: {
470 if (!parseUnknownField(input, unknownFields,
471 extensionRegistry, tag)) {
472 this.setUnknownFields(unknownFields.build());
473 onChanged();
474 return this;
475 }
476 break;
477 }
478 case 10: {
479 bitField0_ |= 0x00000001;
480 interpreterClassName_ = input.readBytes();
481 break;
482 }
483 case 18: {
484 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.Builder subBuilder = org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.newBuilder();
485 if (hasScan()) {
486 subBuilder.mergeFrom(getScan());
487 }
488 input.readMessage(subBuilder, extensionRegistry);
489 setScan(subBuilder.buildPartial());
490 break;
491 }
492 case 26: {
493 bitField0_ |= 0x00000004;
494 interpreterSpecificBytes_ = input.readBytes();
495 break;
496 }
497 }
498 }
499 }
500
501 private int bitField0_;
502
503
504 private java.lang.Object interpreterClassName_ = "";
505 public boolean hasInterpreterClassName() {
506 return ((bitField0_ & 0x00000001) == 0x00000001);
507 }
508 public String getInterpreterClassName() {
509 java.lang.Object ref = interpreterClassName_;
510 if (!(ref instanceof String)) {
511 String s = ((com.google.protobuf.ByteString) ref).toStringUtf8();
512 interpreterClassName_ = s;
513 return s;
514 } else {
515 return (String) ref;
516 }
517 }
518 public Builder setInterpreterClassName(String value) {
519 if (value == null) {
520 throw new NullPointerException();
521 }
522 bitField0_ |= 0x00000001;
523 interpreterClassName_ = value;
524 onChanged();
525 return this;
526 }
527 public Builder clearInterpreterClassName() {
528 bitField0_ = (bitField0_ & ~0x00000001);
529 interpreterClassName_ = getDefaultInstance().getInterpreterClassName();
530 onChanged();
531 return this;
532 }
533 void setInterpreterClassName(com.google.protobuf.ByteString value) {
534 bitField0_ |= 0x00000001;
535 interpreterClassName_ = value;
536 onChanged();
537 }
538
539
540 private org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan scan_ = org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.getDefaultInstance();
541 private com.google.protobuf.SingleFieldBuilder<
542 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.Builder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanOrBuilder> scanBuilder_;
543 public boolean hasScan() {
544 return ((bitField0_ & 0x00000002) == 0x00000002);
545 }
546 public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan getScan() {
547 if (scanBuilder_ == null) {
548 return scan_;
549 } else {
550 return scanBuilder_.getMessage();
551 }
552 }
553 public Builder setScan(org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan value) {
554 if (scanBuilder_ == null) {
555 if (value == null) {
556 throw new NullPointerException();
557 }
558 scan_ = value;
559 onChanged();
560 } else {
561 scanBuilder_.setMessage(value);
562 }
563 bitField0_ |= 0x00000002;
564 return this;
565 }
566 public Builder setScan(
567 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.Builder builderForValue) {
568 if (scanBuilder_ == null) {
569 scan_ = builderForValue.build();
570 onChanged();
571 } else {
572 scanBuilder_.setMessage(builderForValue.build());
573 }
574 bitField0_ |= 0x00000002;
575 return this;
576 }
577 public Builder mergeScan(org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan value) {
578 if (scanBuilder_ == null) {
579 if (((bitField0_ & 0x00000002) == 0x00000002) &&
580 scan_ != org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.getDefaultInstance()) {
581 scan_ =
582 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.newBuilder(scan_).mergeFrom(value).buildPartial();
583 } else {
584 scan_ = value;
585 }
586 onChanged();
587 } else {
588 scanBuilder_.mergeFrom(value);
589 }
590 bitField0_ |= 0x00000002;
591 return this;
592 }
593 public Builder clearScan() {
594 if (scanBuilder_ == null) {
595 scan_ = org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.getDefaultInstance();
596 onChanged();
597 } else {
598 scanBuilder_.clear();
599 }
600 bitField0_ = (bitField0_ & ~0x00000002);
601 return this;
602 }
603 public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.Builder getScanBuilder() {
604 bitField0_ |= 0x00000002;
605 onChanged();
606 return getScanFieldBuilder().getBuilder();
607 }
608 public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanOrBuilder getScanOrBuilder() {
609 if (scanBuilder_ != null) {
610 return scanBuilder_.getMessageOrBuilder();
611 } else {
612 return scan_;
613 }
614 }
615 private com.google.protobuf.SingleFieldBuilder<
616 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.Builder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanOrBuilder>
617 getScanFieldBuilder() {
618 if (scanBuilder_ == null) {
619 scanBuilder_ = new com.google.protobuf.SingleFieldBuilder<
620 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Scan.Builder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanOrBuilder>(
621 scan_,
622 getParentForChildren(),
623 isClean());
624 scan_ = null;
625 }
626 return scanBuilder_;
627 }
628
629
630 private com.google.protobuf.ByteString interpreterSpecificBytes_ = com.google.protobuf.ByteString.EMPTY;
631 public boolean hasInterpreterSpecificBytes() {
632 return ((bitField0_ & 0x00000004) == 0x00000004);
633 }
634 public com.google.protobuf.ByteString getInterpreterSpecificBytes() {
635 return interpreterSpecificBytes_;
636 }
637 public Builder setInterpreterSpecificBytes(com.google.protobuf.ByteString value) {
638 if (value == null) {
639 throw new NullPointerException();
640 }
641 bitField0_ |= 0x00000004;
642 interpreterSpecificBytes_ = value;
643 onChanged();
644 return this;
645 }
646 public Builder clearInterpreterSpecificBytes() {
647 bitField0_ = (bitField0_ & ~0x00000004);
648 interpreterSpecificBytes_ = getDefaultInstance().getInterpreterSpecificBytes();
649 onChanged();
650 return this;
651 }
652
653
654 }
655
656 static {
657 defaultInstance = new AggregateArgument(true);
658 defaultInstance.initFields();
659 }
660
661
662 }
663
664 public interface AggregateResponseOrBuilder
665 extends com.google.protobuf.MessageOrBuilder {
666
667
668 java.util.List<com.google.protobuf.ByteString> getFirstPartList();
669 int getFirstPartCount();
670 com.google.protobuf.ByteString getFirstPart(int index);
671
672
673 boolean hasSecondPart();
674 com.google.protobuf.ByteString getSecondPart();
675 }
676 public static final class AggregateResponse extends
677 com.google.protobuf.GeneratedMessage
678 implements AggregateResponseOrBuilder {
679
680 private AggregateResponse(Builder builder) {
681 super(builder);
682 }
683 private AggregateResponse(boolean noInit) {}
684
685 private static final AggregateResponse defaultInstance;
686 public static AggregateResponse getDefaultInstance() {
687 return defaultInstance;
688 }
689
690 public AggregateResponse getDefaultInstanceForType() {
691 return defaultInstance;
692 }
693
694 public static final com.google.protobuf.Descriptors.Descriptor
695 getDescriptor() {
696 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.internal_static_AggregateResponse_descriptor;
697 }
698
699 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
700 internalGetFieldAccessorTable() {
701 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.internal_static_AggregateResponse_fieldAccessorTable;
702 }
703
704 private int bitField0_;
705
706 public static final int FIRSTPART_FIELD_NUMBER = 1;
707 private java.util.List<com.google.protobuf.ByteString> firstPart_;
708 public java.util.List<com.google.protobuf.ByteString>
709 getFirstPartList() {
710 return firstPart_;
711 }
712 public int getFirstPartCount() {
713 return firstPart_.size();
714 }
715 public com.google.protobuf.ByteString getFirstPart(int index) {
716 return firstPart_.get(index);
717 }
718
719
720 public static final int SECONDPART_FIELD_NUMBER = 2;
721 private com.google.protobuf.ByteString secondPart_;
722 public boolean hasSecondPart() {
723 return ((bitField0_ & 0x00000001) == 0x00000001);
724 }
725 public com.google.protobuf.ByteString getSecondPart() {
726 return secondPart_;
727 }
728
729 private void initFields() {
730 firstPart_ = java.util.Collections.emptyList();;
731 secondPart_ = com.google.protobuf.ByteString.EMPTY;
732 }
733 private byte memoizedIsInitialized = -1;
734 public final boolean isInitialized() {
735 byte isInitialized = memoizedIsInitialized;
736 if (isInitialized != -1) return isInitialized == 1;
737
738 memoizedIsInitialized = 1;
739 return true;
740 }
741
742 public void writeTo(com.google.protobuf.CodedOutputStream output)
743 throws java.io.IOException {
744 getSerializedSize();
745 for (int i = 0; i < firstPart_.size(); i++) {
746 output.writeBytes(1, firstPart_.get(i));
747 }
748 if (((bitField0_ & 0x00000001) == 0x00000001)) {
749 output.writeBytes(2, secondPart_);
750 }
751 getUnknownFields().writeTo(output);
752 }
753
754 private int memoizedSerializedSize = -1;
755 public int getSerializedSize() {
756 int size = memoizedSerializedSize;
757 if (size != -1) return size;
758
759 size = 0;
760 {
761 int dataSize = 0;
762 for (int i = 0; i < firstPart_.size(); i++) {
763 dataSize += com.google.protobuf.CodedOutputStream
764 .computeBytesSizeNoTag(firstPart_.get(i));
765 }
766 size += dataSize;
767 size += 1 * getFirstPartList().size();
768 }
769 if (((bitField0_ & 0x00000001) == 0x00000001)) {
770 size += com.google.protobuf.CodedOutputStream
771 .computeBytesSize(2, secondPart_);
772 }
773 size += getUnknownFields().getSerializedSize();
774 memoizedSerializedSize = size;
775 return size;
776 }
777
778 private static final long serialVersionUID = 0L;
779 @java.lang.Override
780 protected java.lang.Object writeReplace()
781 throws java.io.ObjectStreamException {
782 return super.writeReplace();
783 }
784
785 @java.lang.Override
786 public boolean equals(final java.lang.Object obj) {
787 if (obj == this) {
788 return true;
789 }
790 if (!(obj instanceof org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse)) {
791 return super.equals(obj);
792 }
793 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse other = (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) obj;
794
795 boolean result = true;
796 result = result && getFirstPartList()
797 .equals(other.getFirstPartList());
798 result = result && (hasSecondPart() == other.hasSecondPart());
799 if (hasSecondPart()) {
800 result = result && getSecondPart()
801 .equals(other.getSecondPart());
802 }
803 result = result &&
804 getUnknownFields().equals(other.getUnknownFields());
805 return result;
806 }
807
808 @java.lang.Override
809 public int hashCode() {
810 int hash = 41;
811 hash = (19 * hash) + getDescriptorForType().hashCode();
812 if (getFirstPartCount() > 0) {
813 hash = (37 * hash) + FIRSTPART_FIELD_NUMBER;
814 hash = (53 * hash) + getFirstPartList().hashCode();
815 }
816 if (hasSecondPart()) {
817 hash = (37 * hash) + SECONDPART_FIELD_NUMBER;
818 hash = (53 * hash) + getSecondPart().hashCode();
819 }
820 hash = (29 * hash) + getUnknownFields().hashCode();
821 return hash;
822 }
823
824 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseFrom(
825 com.google.protobuf.ByteString data)
826 throws com.google.protobuf.InvalidProtocolBufferException {
827 return newBuilder().mergeFrom(data).buildParsed();
828 }
829 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseFrom(
830 com.google.protobuf.ByteString data,
831 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
832 throws com.google.protobuf.InvalidProtocolBufferException {
833 return newBuilder().mergeFrom(data, extensionRegistry)
834 .buildParsed();
835 }
836 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseFrom(byte[] data)
837 throws com.google.protobuf.InvalidProtocolBufferException {
838 return newBuilder().mergeFrom(data).buildParsed();
839 }
840 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseFrom(
841 byte[] data,
842 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
843 throws com.google.protobuf.InvalidProtocolBufferException {
844 return newBuilder().mergeFrom(data, extensionRegistry)
845 .buildParsed();
846 }
847 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseFrom(java.io.InputStream input)
848 throws java.io.IOException {
849 return newBuilder().mergeFrom(input).buildParsed();
850 }
851 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseFrom(
852 java.io.InputStream input,
853 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
854 throws java.io.IOException {
855 return newBuilder().mergeFrom(input, extensionRegistry)
856 .buildParsed();
857 }
858 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseDelimitedFrom(java.io.InputStream input)
859 throws java.io.IOException {
860 Builder builder = newBuilder();
861 if (builder.mergeDelimitedFrom(input)) {
862 return builder.buildParsed();
863 } else {
864 return null;
865 }
866 }
867 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseDelimitedFrom(
868 java.io.InputStream input,
869 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
870 throws java.io.IOException {
871 Builder builder = newBuilder();
872 if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
873 return builder.buildParsed();
874 } else {
875 return null;
876 }
877 }
878 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseFrom(
879 com.google.protobuf.CodedInputStream input)
880 throws java.io.IOException {
881 return newBuilder().mergeFrom(input).buildParsed();
882 }
883 public static org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse parseFrom(
884 com.google.protobuf.CodedInputStream input,
885 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
886 throws java.io.IOException {
887 return newBuilder().mergeFrom(input, extensionRegistry)
888 .buildParsed();
889 }
890
891 public static Builder newBuilder() { return Builder.create(); }
892 public Builder newBuilderForType() { return newBuilder(); }
893 public static Builder newBuilder(org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse prototype) {
894 return newBuilder().mergeFrom(prototype);
895 }
896 public Builder toBuilder() { return newBuilder(this); }
897
898 @java.lang.Override
899 protected Builder newBuilderForType(
900 com.google.protobuf.GeneratedMessage.BuilderParent parent) {
901 Builder builder = new Builder(parent);
902 return builder;
903 }
904 public static final class Builder extends
905 com.google.protobuf.GeneratedMessage.Builder<Builder>
906 implements org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponseOrBuilder {
907 public static final com.google.protobuf.Descriptors.Descriptor
908 getDescriptor() {
909 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.internal_static_AggregateResponse_descriptor;
910 }
911
912 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
913 internalGetFieldAccessorTable() {
914 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.internal_static_AggregateResponse_fieldAccessorTable;
915 }
916
917
918 private Builder() {
919 maybeForceBuilderInitialization();
920 }
921
922 private Builder(BuilderParent parent) {
923 super(parent);
924 maybeForceBuilderInitialization();
925 }
926 private void maybeForceBuilderInitialization() {
927 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
928 }
929 }
930 private static Builder create() {
931 return new Builder();
932 }
933
934 public Builder clear() {
935 super.clear();
936 firstPart_ = java.util.Collections.emptyList();;
937 bitField0_ = (bitField0_ & ~0x00000001);
938 secondPart_ = com.google.protobuf.ByteString.EMPTY;
939 bitField0_ = (bitField0_ & ~0x00000002);
940 return this;
941 }
942
943 public Builder clone() {
944 return create().mergeFrom(buildPartial());
945 }
946
947 public com.google.protobuf.Descriptors.Descriptor
948 getDescriptorForType() {
949 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDescriptor();
950 }
951
952 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getDefaultInstanceForType() {
953 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
954 }
955
956 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse build() {
957 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse result = buildPartial();
958 if (!result.isInitialized()) {
959 throw newUninitializedMessageException(result);
960 }
961 return result;
962 }
963
964 private org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse buildParsed()
965 throws com.google.protobuf.InvalidProtocolBufferException {
966 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse result = buildPartial();
967 if (!result.isInitialized()) {
968 throw newUninitializedMessageException(
969 result).asInvalidProtocolBufferException();
970 }
971 return result;
972 }
973
974 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse buildPartial() {
975 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse result = new org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse(this);
976 int from_bitField0_ = bitField0_;
977 int to_bitField0_ = 0;
978 if (((bitField0_ & 0x00000001) == 0x00000001)) {
979 firstPart_ = java.util.Collections.unmodifiableList(firstPart_);
980 bitField0_ = (bitField0_ & ~0x00000001);
981 }
982 result.firstPart_ = firstPart_;
983 if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
984 to_bitField0_ |= 0x00000001;
985 }
986 result.secondPart_ = secondPart_;
987 result.bitField0_ = to_bitField0_;
988 onBuilt();
989 return result;
990 }
991
992 public Builder mergeFrom(com.google.protobuf.Message other) {
993 if (other instanceof org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) {
994 return mergeFrom((org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse)other);
995 } else {
996 super.mergeFrom(other);
997 return this;
998 }
999 }
1000
1001 public Builder mergeFrom(org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse other) {
1002 if (other == org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance()) return this;
1003 if (!other.firstPart_.isEmpty()) {
1004 if (firstPart_.isEmpty()) {
1005 firstPart_ = other.firstPart_;
1006 bitField0_ = (bitField0_ & ~0x00000001);
1007 } else {
1008 ensureFirstPartIsMutable();
1009 firstPart_.addAll(other.firstPart_);
1010 }
1011 onChanged();
1012 }
1013 if (other.hasSecondPart()) {
1014 setSecondPart(other.getSecondPart());
1015 }
1016 this.mergeUnknownFields(other.getUnknownFields());
1017 return this;
1018 }
1019
1020 public final boolean isInitialized() {
1021 return true;
1022 }
1023
1024 public Builder mergeFrom(
1025 com.google.protobuf.CodedInputStream input,
1026 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
1027 throws java.io.IOException {
1028 com.google.protobuf.UnknownFieldSet.Builder unknownFields =
1029 com.google.protobuf.UnknownFieldSet.newBuilder(
1030 this.getUnknownFields());
1031 while (true) {
1032 int tag = input.readTag();
1033 switch (tag) {
1034 case 0:
1035 this.setUnknownFields(unknownFields.build());
1036 onChanged();
1037 return this;
1038 default: {
1039 if (!parseUnknownField(input, unknownFields,
1040 extensionRegistry, tag)) {
1041 this.setUnknownFields(unknownFields.build());
1042 onChanged();
1043 return this;
1044 }
1045 break;
1046 }
1047 case 10: {
1048 ensureFirstPartIsMutable();
1049 firstPart_.add(input.readBytes());
1050 break;
1051 }
1052 case 18: {
1053 bitField0_ |= 0x00000002;
1054 secondPart_ = input.readBytes();
1055 break;
1056 }
1057 }
1058 }
1059 }
1060
1061 private int bitField0_;
1062
1063
1064 private java.util.List<com.google.protobuf.ByteString> firstPart_ = java.util.Collections.emptyList();;
1065 private void ensureFirstPartIsMutable() {
1066 if (!((bitField0_ & 0x00000001) == 0x00000001)) {
1067 firstPart_ = new java.util.ArrayList<com.google.protobuf.ByteString>(firstPart_);
1068 bitField0_ |= 0x00000001;
1069 }
1070 }
1071 public java.util.List<com.google.protobuf.ByteString>
1072 getFirstPartList() {
1073 return java.util.Collections.unmodifiableList(firstPart_);
1074 }
1075 public int getFirstPartCount() {
1076 return firstPart_.size();
1077 }
1078 public com.google.protobuf.ByteString getFirstPart(int index) {
1079 return firstPart_.get(index);
1080 }
1081 public Builder setFirstPart(
1082 int index, com.google.protobuf.ByteString value) {
1083 if (value == null) {
1084 throw new NullPointerException();
1085 }
1086 ensureFirstPartIsMutable();
1087 firstPart_.set(index, value);
1088 onChanged();
1089 return this;
1090 }
1091 public Builder addFirstPart(com.google.protobuf.ByteString value) {
1092 if (value == null) {
1093 throw new NullPointerException();
1094 }
1095 ensureFirstPartIsMutable();
1096 firstPart_.add(value);
1097 onChanged();
1098 return this;
1099 }
1100 public Builder addAllFirstPart(
1101 java.lang.Iterable<? extends com.google.protobuf.ByteString> values) {
1102 ensureFirstPartIsMutable();
1103 super.addAll(values, firstPart_);
1104 onChanged();
1105 return this;
1106 }
1107 public Builder clearFirstPart() {
1108 firstPart_ = java.util.Collections.emptyList();;
1109 bitField0_ = (bitField0_ & ~0x00000001);
1110 onChanged();
1111 return this;
1112 }
1113
1114
1115 private com.google.protobuf.ByteString secondPart_ = com.google.protobuf.ByteString.EMPTY;
1116 public boolean hasSecondPart() {
1117 return ((bitField0_ & 0x00000002) == 0x00000002);
1118 }
1119 public com.google.protobuf.ByteString getSecondPart() {
1120 return secondPart_;
1121 }
1122 public Builder setSecondPart(com.google.protobuf.ByteString value) {
1123 if (value == null) {
1124 throw new NullPointerException();
1125 }
1126 bitField0_ |= 0x00000002;
1127 secondPart_ = value;
1128 onChanged();
1129 return this;
1130 }
1131 public Builder clearSecondPart() {
1132 bitField0_ = (bitField0_ & ~0x00000002);
1133 secondPart_ = getDefaultInstance().getSecondPart();
1134 onChanged();
1135 return this;
1136 }
1137
1138
1139 }
1140
1141 static {
1142 defaultInstance = new AggregateResponse(true);
1143 defaultInstance.initFields();
1144 }
1145
1146
1147 }
1148
1149 public static abstract class AggregateService
1150 implements com.google.protobuf.Service {
1151 protected AggregateService() {}
1152
1153 public interface Interface {
1154 public abstract void getMax(
1155 com.google.protobuf.RpcController controller,
1156 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1157 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1158
1159 public abstract void getMin(
1160 com.google.protobuf.RpcController controller,
1161 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1162 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1163
1164 public abstract void getSum(
1165 com.google.protobuf.RpcController controller,
1166 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1167 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1168
1169 public abstract void getRowNum(
1170 com.google.protobuf.RpcController controller,
1171 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1172 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1173
1174 public abstract void getAvg(
1175 com.google.protobuf.RpcController controller,
1176 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1177 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1178
1179 public abstract void getStd(
1180 com.google.protobuf.RpcController controller,
1181 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1182 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1183
1184 public abstract void getMedian(
1185 com.google.protobuf.RpcController controller,
1186 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1187 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1188
1189 }
1190
1191 public static com.google.protobuf.Service newReflectiveService(
1192 final Interface impl) {
1193 return new AggregateService() {
1194 @java.lang.Override
1195 public void getMax(
1196 com.google.protobuf.RpcController controller,
1197 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1198 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1199 impl.getMax(controller, request, done);
1200 }
1201
1202 @java.lang.Override
1203 public void getMin(
1204 com.google.protobuf.RpcController controller,
1205 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1206 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1207 impl.getMin(controller, request, done);
1208 }
1209
1210 @java.lang.Override
1211 public void getSum(
1212 com.google.protobuf.RpcController controller,
1213 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1214 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1215 impl.getSum(controller, request, done);
1216 }
1217
1218 @java.lang.Override
1219 public void getRowNum(
1220 com.google.protobuf.RpcController controller,
1221 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1222 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1223 impl.getRowNum(controller, request, done);
1224 }
1225
1226 @java.lang.Override
1227 public void getAvg(
1228 com.google.protobuf.RpcController controller,
1229 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1230 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1231 impl.getAvg(controller, request, done);
1232 }
1233
1234 @java.lang.Override
1235 public void getStd(
1236 com.google.protobuf.RpcController controller,
1237 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1238 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1239 impl.getStd(controller, request, done);
1240 }
1241
1242 @java.lang.Override
1243 public void getMedian(
1244 com.google.protobuf.RpcController controller,
1245 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1246 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1247 impl.getMedian(controller, request, done);
1248 }
1249
1250 };
1251 }
1252
1253 public static com.google.protobuf.BlockingService
1254 newReflectiveBlockingService(final BlockingInterface impl) {
1255 return new com.google.protobuf.BlockingService() {
1256 public final com.google.protobuf.Descriptors.ServiceDescriptor
1257 getDescriptorForType() {
1258 return getDescriptor();
1259 }
1260
1261 public final com.google.protobuf.Message callBlockingMethod(
1262 com.google.protobuf.Descriptors.MethodDescriptor method,
1263 com.google.protobuf.RpcController controller,
1264 com.google.protobuf.Message request)
1265 throws com.google.protobuf.ServiceException {
1266 if (method.getService() != getDescriptor()) {
1267 throw new java.lang.IllegalArgumentException(
1268 "Service.callBlockingMethod() given method descriptor for " +
1269 "wrong service type.");
1270 }
1271 switch(method.getIndex()) {
1272 case 0:
1273 return impl.getMax(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request);
1274 case 1:
1275 return impl.getMin(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request);
1276 case 2:
1277 return impl.getSum(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request);
1278 case 3:
1279 return impl.getRowNum(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request);
1280 case 4:
1281 return impl.getAvg(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request);
1282 case 5:
1283 return impl.getStd(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request);
1284 case 6:
1285 return impl.getMedian(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request);
1286 default:
1287 throw new java.lang.AssertionError("Can't get here.");
1288 }
1289 }
1290
1291 public final com.google.protobuf.Message
1292 getRequestPrototype(
1293 com.google.protobuf.Descriptors.MethodDescriptor method) {
1294 if (method.getService() != getDescriptor()) {
1295 throw new java.lang.IllegalArgumentException(
1296 "Service.getRequestPrototype() given method " +
1297 "descriptor for wrong service type.");
1298 }
1299 switch(method.getIndex()) {
1300 case 0:
1301 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1302 case 1:
1303 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1304 case 2:
1305 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1306 case 3:
1307 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1308 case 4:
1309 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1310 case 5:
1311 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1312 case 6:
1313 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1314 default:
1315 throw new java.lang.AssertionError("Can't get here.");
1316 }
1317 }
1318
1319 public final com.google.protobuf.Message
1320 getResponsePrototype(
1321 com.google.protobuf.Descriptors.MethodDescriptor method) {
1322 if (method.getService() != getDescriptor()) {
1323 throw new java.lang.IllegalArgumentException(
1324 "Service.getResponsePrototype() given method " +
1325 "descriptor for wrong service type.");
1326 }
1327 switch(method.getIndex()) {
1328 case 0:
1329 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1330 case 1:
1331 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1332 case 2:
1333 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1334 case 3:
1335 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1336 case 4:
1337 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1338 case 5:
1339 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1340 case 6:
1341 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1342 default:
1343 throw new java.lang.AssertionError("Can't get here.");
1344 }
1345 }
1346
1347 };
1348 }
1349
1350 public abstract void getMax(
1351 com.google.protobuf.RpcController controller,
1352 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1353 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1354
1355 public abstract void getMin(
1356 com.google.protobuf.RpcController controller,
1357 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1358 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1359
1360 public abstract void getSum(
1361 com.google.protobuf.RpcController controller,
1362 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1363 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1364
1365 public abstract void getRowNum(
1366 com.google.protobuf.RpcController controller,
1367 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1368 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1369
1370 public abstract void getAvg(
1371 com.google.protobuf.RpcController controller,
1372 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1373 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1374
1375 public abstract void getStd(
1376 com.google.protobuf.RpcController controller,
1377 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1378 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1379
1380 public abstract void getMedian(
1381 com.google.protobuf.RpcController controller,
1382 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1383 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done);
1384
1385 public static final
1386 com.google.protobuf.Descriptors.ServiceDescriptor
1387 getDescriptor() {
1388 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.getDescriptor().getServices().get(0);
1389 }
1390 public final com.google.protobuf.Descriptors.ServiceDescriptor
1391 getDescriptorForType() {
1392 return getDescriptor();
1393 }
1394
1395 public final void callMethod(
1396 com.google.protobuf.Descriptors.MethodDescriptor method,
1397 com.google.protobuf.RpcController controller,
1398 com.google.protobuf.Message request,
1399 com.google.protobuf.RpcCallback<
1400 com.google.protobuf.Message> done) {
1401 if (method.getService() != getDescriptor()) {
1402 throw new java.lang.IllegalArgumentException(
1403 "Service.callMethod() given method descriptor for wrong " +
1404 "service type.");
1405 }
1406 switch(method.getIndex()) {
1407 case 0:
1408 this.getMax(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request,
1409 com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>specializeCallback(
1410 done));
1411 return;
1412 case 1:
1413 this.getMin(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request,
1414 com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>specializeCallback(
1415 done));
1416 return;
1417 case 2:
1418 this.getSum(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request,
1419 com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>specializeCallback(
1420 done));
1421 return;
1422 case 3:
1423 this.getRowNum(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request,
1424 com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>specializeCallback(
1425 done));
1426 return;
1427 case 4:
1428 this.getAvg(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request,
1429 com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>specializeCallback(
1430 done));
1431 return;
1432 case 5:
1433 this.getStd(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request,
1434 com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>specializeCallback(
1435 done));
1436 return;
1437 case 6:
1438 this.getMedian(controller, (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument)request,
1439 com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>specializeCallback(
1440 done));
1441 return;
1442 default:
1443 throw new java.lang.AssertionError("Can't get here.");
1444 }
1445 }
1446
1447 public final com.google.protobuf.Message
1448 getRequestPrototype(
1449 com.google.protobuf.Descriptors.MethodDescriptor method) {
1450 if (method.getService() != getDescriptor()) {
1451 throw new java.lang.IllegalArgumentException(
1452 "Service.getRequestPrototype() given method " +
1453 "descriptor for wrong service type.");
1454 }
1455 switch(method.getIndex()) {
1456 case 0:
1457 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1458 case 1:
1459 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1460 case 2:
1461 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1462 case 3:
1463 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1464 case 4:
1465 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1466 case 5:
1467 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1468 case 6:
1469 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.getDefaultInstance();
1470 default:
1471 throw new java.lang.AssertionError("Can't get here.");
1472 }
1473 }
1474
1475 public final com.google.protobuf.Message
1476 getResponsePrototype(
1477 com.google.protobuf.Descriptors.MethodDescriptor method) {
1478 if (method.getService() != getDescriptor()) {
1479 throw new java.lang.IllegalArgumentException(
1480 "Service.getResponsePrototype() given method " +
1481 "descriptor for wrong service type.");
1482 }
1483 switch(method.getIndex()) {
1484 case 0:
1485 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1486 case 1:
1487 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1488 case 2:
1489 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1490 case 3:
1491 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1492 case 4:
1493 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1494 case 5:
1495 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1496 case 6:
1497 return org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance();
1498 default:
1499 throw new java.lang.AssertionError("Can't get here.");
1500 }
1501 }
1502
1503 public static Stub newStub(
1504 com.google.protobuf.RpcChannel channel) {
1505 return new Stub(channel);
1506 }
1507
1508 public static final class Stub extends org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateService implements Interface {
1509 private Stub(com.google.protobuf.RpcChannel channel) {
1510 this.channel = channel;
1511 }
1512
1513 private final com.google.protobuf.RpcChannel channel;
1514
1515 public com.google.protobuf.RpcChannel getChannel() {
1516 return channel;
1517 }
1518
1519 public void getMax(
1520 com.google.protobuf.RpcController controller,
1521 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1522 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1523 channel.callMethod(
1524 getDescriptor().getMethods().get(0),
1525 controller,
1526 request,
1527 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance(),
1528 com.google.protobuf.RpcUtil.generalizeCallback(
1529 done,
1530 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.class,
1531 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance()));
1532 }
1533
1534 public void getMin(
1535 com.google.protobuf.RpcController controller,
1536 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1537 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1538 channel.callMethod(
1539 getDescriptor().getMethods().get(1),
1540 controller,
1541 request,
1542 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance(),
1543 com.google.protobuf.RpcUtil.generalizeCallback(
1544 done,
1545 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.class,
1546 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance()));
1547 }
1548
1549 public void getSum(
1550 com.google.protobuf.RpcController controller,
1551 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1552 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1553 channel.callMethod(
1554 getDescriptor().getMethods().get(2),
1555 controller,
1556 request,
1557 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance(),
1558 com.google.protobuf.RpcUtil.generalizeCallback(
1559 done,
1560 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.class,
1561 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance()));
1562 }
1563
1564 public void getRowNum(
1565 com.google.protobuf.RpcController controller,
1566 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1567 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1568 channel.callMethod(
1569 getDescriptor().getMethods().get(3),
1570 controller,
1571 request,
1572 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance(),
1573 com.google.protobuf.RpcUtil.generalizeCallback(
1574 done,
1575 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.class,
1576 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance()));
1577 }
1578
1579 public void getAvg(
1580 com.google.protobuf.RpcController controller,
1581 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1582 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1583 channel.callMethod(
1584 getDescriptor().getMethods().get(4),
1585 controller,
1586 request,
1587 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance(),
1588 com.google.protobuf.RpcUtil.generalizeCallback(
1589 done,
1590 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.class,
1591 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance()));
1592 }
1593
1594 public void getStd(
1595 com.google.protobuf.RpcController controller,
1596 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1597 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1598 channel.callMethod(
1599 getDescriptor().getMethods().get(5),
1600 controller,
1601 request,
1602 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance(),
1603 com.google.protobuf.RpcUtil.generalizeCallback(
1604 done,
1605 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.class,
1606 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance()));
1607 }
1608
1609 public void getMedian(
1610 com.google.protobuf.RpcController controller,
1611 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request,
1612 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse> done) {
1613 channel.callMethod(
1614 getDescriptor().getMethods().get(6),
1615 controller,
1616 request,
1617 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance(),
1618 com.google.protobuf.RpcUtil.generalizeCallback(
1619 done,
1620 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.class,
1621 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance()));
1622 }
1623 }
1624
1625 public static BlockingInterface newBlockingStub(
1626 com.google.protobuf.BlockingRpcChannel channel) {
1627 return new BlockingStub(channel);
1628 }
1629
1630 public interface BlockingInterface {
1631 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getMax(
1632 com.google.protobuf.RpcController controller,
1633 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1634 throws com.google.protobuf.ServiceException;
1635
1636 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getMin(
1637 com.google.protobuf.RpcController controller,
1638 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1639 throws com.google.protobuf.ServiceException;
1640
1641 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getSum(
1642 com.google.protobuf.RpcController controller,
1643 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1644 throws com.google.protobuf.ServiceException;
1645
1646 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getRowNum(
1647 com.google.protobuf.RpcController controller,
1648 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1649 throws com.google.protobuf.ServiceException;
1650
1651 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getAvg(
1652 com.google.protobuf.RpcController controller,
1653 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1654 throws com.google.protobuf.ServiceException;
1655
1656 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getStd(
1657 com.google.protobuf.RpcController controller,
1658 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1659 throws com.google.protobuf.ServiceException;
1660
1661 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getMedian(
1662 com.google.protobuf.RpcController controller,
1663 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1664 throws com.google.protobuf.ServiceException;
1665 }
1666
1667 private static final class BlockingStub implements BlockingInterface {
1668 private BlockingStub(com.google.protobuf.BlockingRpcChannel channel) {
1669 this.channel = channel;
1670 }
1671
1672 private final com.google.protobuf.BlockingRpcChannel channel;
1673
1674 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getMax(
1675 com.google.protobuf.RpcController controller,
1676 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1677 throws com.google.protobuf.ServiceException {
1678 return (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) channel.callBlockingMethod(
1679 getDescriptor().getMethods().get(0),
1680 controller,
1681 request,
1682 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance());
1683 }
1684
1685
1686 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getMin(
1687 com.google.protobuf.RpcController controller,
1688 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1689 throws com.google.protobuf.ServiceException {
1690 return (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) channel.callBlockingMethod(
1691 getDescriptor().getMethods().get(1),
1692 controller,
1693 request,
1694 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance());
1695 }
1696
1697
1698 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getSum(
1699 com.google.protobuf.RpcController controller,
1700 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1701 throws com.google.protobuf.ServiceException {
1702 return (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) channel.callBlockingMethod(
1703 getDescriptor().getMethods().get(2),
1704 controller,
1705 request,
1706 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance());
1707 }
1708
1709
1710 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getRowNum(
1711 com.google.protobuf.RpcController controller,
1712 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1713 throws com.google.protobuf.ServiceException {
1714 return (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) channel.callBlockingMethod(
1715 getDescriptor().getMethods().get(3),
1716 controller,
1717 request,
1718 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance());
1719 }
1720
1721
1722 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getAvg(
1723 com.google.protobuf.RpcController controller,
1724 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1725 throws com.google.protobuf.ServiceException {
1726 return (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) channel.callBlockingMethod(
1727 getDescriptor().getMethods().get(4),
1728 controller,
1729 request,
1730 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance());
1731 }
1732
1733
1734 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getStd(
1735 com.google.protobuf.RpcController controller,
1736 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1737 throws com.google.protobuf.ServiceException {
1738 return (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) channel.callBlockingMethod(
1739 getDescriptor().getMethods().get(5),
1740 controller,
1741 request,
1742 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance());
1743 }
1744
1745
1746 public org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse getMedian(
1747 com.google.protobuf.RpcController controller,
1748 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument request)
1749 throws com.google.protobuf.ServiceException {
1750 return (org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse) channel.callBlockingMethod(
1751 getDescriptor().getMethods().get(6),
1752 controller,
1753 request,
1754 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.getDefaultInstance());
1755 }
1756
1757 }
1758 }
1759
1760 private static com.google.protobuf.Descriptors.Descriptor
1761 internal_static_AggregateArgument_descriptor;
1762 private static
1763 com.google.protobuf.GeneratedMessage.FieldAccessorTable
1764 internal_static_AggregateArgument_fieldAccessorTable;
1765 private static com.google.protobuf.Descriptors.Descriptor
1766 internal_static_AggregateResponse_descriptor;
1767 private static
1768 com.google.protobuf.GeneratedMessage.FieldAccessorTable
1769 internal_static_AggregateResponse_fieldAccessorTable;
1770
1771 public static com.google.protobuf.Descriptors.FileDescriptor
1772 getDescriptor() {
1773 return descriptor;
1774 }
1775 private static com.google.protobuf.Descriptors.FileDescriptor
1776 descriptor;
1777 static {
1778 java.lang.String[] descriptorData = {
1779 "\n\017Aggregate.proto\032\014Client.proto\"h\n\021Aggre" +
1780 "gateArgument\022\034\n\024interpreterClassName\030\001 \002" +
1781 "(\t\022\023\n\004scan\030\002 \002(\0132\005.Scan\022 \n\030interpreterSp" +
1782 "ecificBytes\030\003 \001(\014\":\n\021AggregateResponse\022\021" +
1783 "\n\tfirstPart\030\001 \003(\014\022\022\n\nsecondPart\030\002 \001(\0142\366\002" +
1784 "\n\020AggregateService\0220\n\006getMax\022\022.Aggregate" +
1785 "Argument\032\022.AggregateResponse\0220\n\006getMin\022\022" +
1786 ".AggregateArgument\032\022.AggregateResponse\0220" +
1787 "\n\006getSum\022\022.AggregateArgument\032\022.Aggregate" +
1788 "Response\0223\n\tgetRowNum\022\022.AggregateArgumen",
1789 "t\032\022.AggregateResponse\0220\n\006getAvg\022\022.Aggreg" +
1790 "ateArgument\032\022.AggregateResponse\0220\n\006getSt" +
1791 "d\022\022.AggregateArgument\032\022.AggregateRespons" +
1792 "e\0223\n\tgetMedian\022\022.AggregateArgument\032\022.Agg" +
1793 "regateResponseBE\n*org.apache.hadoop.hbas" +
1794 "e.protobuf.generatedB\017AggregateProtosH\001\210" +
1795 "\001\001\240\001\001"
1796 };
1797 com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
1798 new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
1799 public com.google.protobuf.ExtensionRegistry assignDescriptors(
1800 com.google.protobuf.Descriptors.FileDescriptor root) {
1801 descriptor = root;
1802 internal_static_AggregateArgument_descriptor =
1803 getDescriptor().getMessageTypes().get(0);
1804 internal_static_AggregateArgument_fieldAccessorTable = new
1805 com.google.protobuf.GeneratedMessage.FieldAccessorTable(
1806 internal_static_AggregateArgument_descriptor,
1807 new java.lang.String[] { "InterpreterClassName", "Scan", "InterpreterSpecificBytes", },
1808 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.class,
1809 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateArgument.Builder.class);
1810 internal_static_AggregateResponse_descriptor =
1811 getDescriptor().getMessageTypes().get(1);
1812 internal_static_AggregateResponse_fieldAccessorTable = new
1813 com.google.protobuf.GeneratedMessage.FieldAccessorTable(
1814 internal_static_AggregateResponse_descriptor,
1815 new java.lang.String[] { "FirstPart", "SecondPart", },
1816 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.class,
1817 org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse.Builder.class);
1818 return null;
1819 }
1820 };
1821 com.google.protobuf.Descriptors.FileDescriptor
1822 .internalBuildGeneratedFileFrom(descriptorData,
1823 new com.google.protobuf.Descriptors.FileDescriptor[] {
1824 org.apache.hadoop.hbase.protobuf.generated.ClientProtos.getDescriptor(),
1825 }, assigner);
1826 }
1827
1828
1829 }