Observer协处理器通常在一个特定的事件（诸如Get或Put）之前或之后发生，相当于RDBMS中的触发器。Endpoint协处理器则类似于RDBMS中的存储过程，因为它可以让你在RegionServer上对数据执行自定义计算，而不是在客户端上执行计算。
本文是以上两者的简单实例，使用的环境：环境 jdk1.8 hadoop2.6.5 hbase1.2.4。
1、Endpoint实例
1> 编写适用于protobuf的proto文件，如下，尽量不要带注释，因为编译时可能出现乱码
option java_package = "com.endpoint.test";
option java_outer_classname = "Sum";
option java_generic_services = true;
option java_generate_equals_and_hash = true;
option optimize_for = SPEED;
message SumRequest {
required string family = 1;
required string column = 2;
}
message SumResponse {
required int64 sum = 1 [default = 0];
}
service SumService {
rpc getSum(SumRequest)
returns (SumResponse);
}
2> 编译上面的proto文件
使用protoc程序进行编译，linux下或者windows均可，protoc程序可以直接从github下载:https://github.com/google/protobuf/releases，也可以自己编译生成，参见protobuf的编译安装
注意，编译的版本要与hadoop以及hbase使用的版本相同，或者略高，但最好不要过高，hadoop2.6.5 hbase1.2.4使用的都是protobuf2.5.0的版本，写此篇文章时的最新版为3.1.0
（高版本必须指定syntax，例如proto3的syntax在第一行非空白非注释行，必须写：syntax = "proto3"，字段规则移除了 “required”，并把 “optional” 改名为 “singular”,移除了 default 选项。可搜索Protobuf 的 proto3 与 proto2 的区别进行了解。）下载的话选择带win或linux的版本，这是编译好的版本。有很多带具体语言的版本，是一些具体某种语言的发行版源码包。，为了与hbase以及hadoop统一起来，此处用的是protoc-2.5.0-win32.zip。
解压文件：
使用windows命令行进入上面的目录，执行以下命令即可：
protoc.exe sum1.proto --java_out=./
高版本有编译好的适用于linux下的protoc程序文件，低版本没有。在linux下执行以下命令：
protoc sum.proto --java_out=./
结果都一样，生成的代码参见折叠部分，有很多，因为上面文件中指定java_outer_classname = "Sum"，所以会生成Sum类，将这个类引入到项目中，注意项目的包名称与上面文件中指定（option java_package = "com.endpoint.test"）的名称要一致。
1 // Generated by the protocol buffer compiler. DO NOT EDIT!
2 // source: sumcode.proto
3
4 package com.endpoint.test;
5
6 public final class Sum {
7 private Sum() {}
8 public static void registerAllExtensions(
9 com.google.protobuf.ExtensionRegistry registry) {
10 }
11 public interface SumRequestOrBuilder
12 extends com.google.protobuf.MessageOrBuilder {
13
14 // required string family = 1;
15 /**
16 * <code>required string family = 1;</code>
17 */
18 boolean hasFamily();
19 /**
20 * <code>required string family = 1;</code>
21 */
22 java.lang.String getFamily();
23 /**
24 * <code>required string family = 1;</code>
25 */
26 com.google.protobuf.ByteString
27 getFamilyBytes();
28
29 // required string column = 2;
30 /**
31 * <code>required string column = 2;</code>
32 */
33 boolean hasColumn();
34 /**
35 * <code>required string column = 2;</code>
36 */
37 java.lang.String getColumn();
38 /**
39 * <code>required string column = 2;</code>
40 */
41 com.google.protobuf.ByteString
42 getColumnBytes();
43 }
44 /**
45 * Protobuf type {@code SumRequest}
46 */
47 public static final class SumRequest extends
48 com.google.protobuf.GeneratedMessage
49 implements SumRequestOrBuilder {
50 // Use SumRequest.newBuilder() to construct.
51 private SumRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
52 super(builder);
53 this.unknownFields = builder.getUnknownFields();
54 }
55 private SumRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
56
57 private static final SumRequest defaultInstance;
58 public static SumRequest getDefaultInstance() {
59 return defaultInstance;
60 }
61
62 public SumRequest getDefaultInstanceForType() {
63 return defaultInstance;
64 }
65
66 private final com.google.protobuf.UnknownFieldSet unknownFields;
67 @java.lang.Override
68 public final com.google.protobuf.UnknownFieldSet
69 getUnknownFields() {
70 return this.unknownFields;
71 }
72 private SumRequest(
73 com.google.protobuf.CodedInputStream input,
74 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
75 throws com.google.protobuf.InvalidProtocolBufferException {
76 initFields();
77 int mutable_bitField0_ = 0;
78 com.google.protobuf.UnknownFieldSet.Builder unknownFields =
79 com.google.protobuf.UnknownFieldSet.newBuilder();
80 try {
81 boolean done = false;
82 while (!done) {
83 int tag = input.readTag();
84 switch (tag) {
85 case 0:
86 done = true;
87 break;
88 default: {
89 if (!parseUnknownField(input, unknownFields,
90 extensionRegistry, tag)) {
91 done = true;
92 }
93 break;
94 }
95 case 10: {
96 bitField0_ |= 0x00000001;
97 family_ = input.readBytes();
98 break;
99 }
100 case 18: {
101 bitField0_ |= 0x00000002;
102 column_ = input.readBytes();
103 break;
104 }
105 }
106 }
107 } catch (com.google.protobuf.InvalidProtocolBufferException e) {
108 throw e.setUnfinishedMessage(this);
109 } catch (java.io.IOException e) {
110 throw new com.google.protobuf.InvalidProtocolBufferException(
111 e.getMessage()).setUnfinishedMessage(this);
112 } finally {
113 this.unknownFields = unknownFields.build();
114 makeExtensionsImmutable();
115 }
116 }
117 public static final com.google.protobuf.Descriptors.Descriptor
118 getDescriptor() {
119 return com.endpoint.test.Sum.internal_static_SumRequest_descriptor;
120 }
121
122 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
123 internalGetFieldAccessorTable() {
124 return com.endpoint.test.Sum.internal_static_SumRequest_fieldAccessorTable
125 .ensureFieldAccessorsInitialized(
126 com.endpoint.test.Sum.SumRequest.class, com.endpoint.test.Sum.SumRequest.Builder.class);
127 }
128
129 public static com.google.protobuf.Parser<SumRequest> PARSER =
130 new com.google.protobuf.AbstractParser<SumRequest>() {
131 public SumRequest parsePartialFrom(
132 com.google.protobuf.CodedInputStream input,
133 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
134 throws com.google.protobuf.InvalidProtocolBufferException {
135 return new SumRequest(input, extensionRegistry);
136 }
137 };
138
139 @java.lang.Override
140 public com.google.protobuf.Parser<SumRequest> getParserForType() {
141 return PARSER;
142 }
143
144 private int bitField0_;
145 // required string family = 1;
146 public static final int FAMILY_FIELD_NUMBER = 1;
147 private java.lang.Object family_;
148 /**
149 * <code>required string family = 1;</code>
150 */
151 public boolean hasFamily() {
152 return ((bitField0_ & 0x00000001) == 0x00000001);
153 }
154 /**
155 * <code>required string family = 1;</code>
156 */
157 public java.lang.String getFamily() {
158 java.lang.Object ref = family_;
159 if (ref instanceof java.lang.String) {
160 return (java.lang.String) ref;
161 } else {
162 com.google.protobuf.ByteString bs =
163 (com.google.protobuf.ByteString) ref;
164 java.lang.String s = bs.toStringUtf8();
165 if (bs.isValidUtf8()) {
166 family_ = s;
167 }
168 return s;
169 }
170 }
171 /**
172 * <code>required string family = 1;</code>
173 */
174 public com.google.protobuf.ByteString
175 getFamilyBytes() {
176 java.lang.Object ref = family_;
177 if (ref instanceof java.lang.String) {
178 com.google.protobuf.ByteString b =
179 com.google.protobuf.ByteString.copyFromUtf8(
180 (java.lang.String) ref);
181 family_ = b;
182 return b;
183 } else {
184 return (com.google.protobuf.ByteString) ref;
185 }
186 }
187
188 // required string column = 2;
189 public static final int COLUMN_FIELD_NUMBER = 2;
190 private java.lang.Object column_;
191 /**
192 * <code>required string column = 2;</code>
193 */
194 public boolean hasColumn() {
195 return ((bitField0_ & 0x00000002) == 0x00000002);
196 }
197 /**
198 * <code>required string column = 2;</code>
199 */
200 public java.lang.String getColumn() {
201 java.lang.Object ref = column_;
202 if (ref instanceof java.lang.String) {
203 return (java.lang.String) ref;
204 } else {
205 com.google.protobuf.ByteString bs =
206 (com.google.protobuf.ByteString) ref;
207 java.lang.String s = bs.toStringUtf8();
208 if (bs.isValidUtf8()) {
209 column_ = s;
210 }
211 return s;
212 }
213 }
214 /**
215 * <code>required string column = 2;</code>
216 */
217 public com.google.protobuf.ByteString
218 getColumnBytes() {
219 java.lang.Object ref = column_;
220 if (ref instanceof java.lang.String) {
221 com.google.protobuf.ByteString b =
222 com.google.protobuf.ByteString.copyFromUtf8(
223 (java.lang.String) ref);
224 column_ = b;
225 return b;
226 } else {
227 return (com.google.protobuf.ByteString) ref;
228 }
229 }
230
231 private void initFields() {
232 family_ = "";
233 column_ = "";
234 }
235 private byte memoizedIsInitialized = -1;
236 public final boolean isInitialized() {
237 byte isInitialized = memoizedIsInitialized;
238 if (isInitialized != -1) return isInitialized == 1;
239
240 if (!hasFamily()) {
241 memoizedIsInitialized = 0;
242 return false;
243 }
244 if (!hasColumn()) {
245 memoizedIsInitialized = 0;
246 return false;
247 }
248 memoizedIsInitialized = 1;
249 return true;
250 }
251
252 public void writeTo(com.google.protobuf.CodedOutputStream output)
253 throws java.io.IOException {
254 getSerializedSize();
255 if (((bitField0_ & 0x00000001) == 0x00000001)) {
256 output.writeBytes(1, getFamilyBytes());
257 }
258 if (((bitField0_ & 0x00000002) == 0x00000002)) {
259 output.writeBytes(2, getColumnBytes());
260 }
261 getUnknownFields().writeTo(output);
262 }
263
264 private int memoizedSerializedSize = -1;
265 public int getSerializedSize() {
266 int size = memoizedSerializedSize;
267 if (size != -1) return size;
268
269 size = 0;
270 if (((bitField0_ & 0x00000001) == 0x00000001)) {
271 size += com.google.protobuf.CodedOutputStream
272 .computeBytesSize(1, getFamilyBytes());
273 }
274 if (((bitField0_ & 0x00000002) == 0x00000002)) {
275 size += com.google.protobuf.CodedOutputStream
276 .computeBytesSize(2, getColumnBytes());
277 }
278 size += getUnknownFields().getSerializedSize();
279 memoizedSerializedSize = size;
280 return size;
281 }
282
283 private static final long serialVersionUID = 0L;
284 @java.lang.Override
285 protected java.lang.Object writeReplace()
286 throws java.io.ObjectStreamException {
287 return super.writeReplace();
288 }
289
290 @java.lang.Override
291 public boolean equals(final java.lang.Object obj) {
292 if (obj == this) {
293 return true;
294 }
295 if (!(obj instanceof com.endpoint.test.Sum.SumRequest)) {
296 return super.equals(obj);
297 }
298 com.endpoint.test.Sum.SumRequest other = (com.endpoint.test.Sum.SumRequest) obj;
299
300 boolean result = true;
301 result = result && (hasFamily() == other.hasFamily());
302 if (hasFamily()) {
303 result = result && getFamily()
304 .equals(other.getFamily());
305 }
306 result = result && (hasColumn() == other.hasColumn());
307 if (hasColumn()) {
308 result = result && getColumn()
309 .equals(other.getColumn());
310 }
311 result = result &&
312 getUnknownFields().equals(other.getUnknownFields());
313 return result;
314 }
315
316 private int memoizedHashCode = 0;
317 @java.lang.Override
318 public int hashCode() {
319 if (memoizedHashCode != 0) {
320 return memoizedHashCode;
321 }
322 int hash = 41;
323 hash = (19 * hash) + getDescriptorForType().hashCode();
324 if (hasFamily()) {
325 hash = (37 * hash) + FAMILY_FIELD_NUMBER;
326 hash = (53 * hash) + getFamily().hashCode();
327 }
328 if (hasColumn()) {
329 hash = (37 * hash) + COLUMN_FIELD_NUMBER;
330 hash = (53 * hash) + getColumn().hashCode();
331 }
332 hash = (29 * hash) + getUnknownFields().hashCode();
333 memoizedHashCode = hash;
334 return hash;
335 }
336
337 public static com.endpoint.test.Sum.SumRequest parseFrom(
338 com.google.protobuf.ByteString data)
339 throws com.google.protobuf.InvalidProtocolBufferException {
340 return PARSER.parseFrom(data);
341 }
342 public static com.endpoint.test.Sum.SumRequest parseFrom(
343 com.google.protobuf.ByteString data,
344 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
345 throws com.google.protobuf.InvalidProtocolBufferException {
346 return PARSER.parseFrom(data, extensionRegistry);
347 }
348 public static com.endpoint.test.Sum.SumRequest parseFrom(byte[] data)
349 throws com.google.protobuf.InvalidProtocolBufferException {
350 return PARSER.parseFrom(data);
351 }
352 public static com.endpoint.test.Sum.SumRequest parseFrom(
353 byte[] data,
354 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
355 throws com.google.protobuf.InvalidProtocolBufferException {
356 return PARSER.parseFrom(data, extensionRegistry);
357 }
358 public static com.endpoint.test.Sum.SumRequest parseFrom(java.io.InputStream input)
359 throws java.io.IOException {
360 return PARSER.parseFrom(input);
361 }
362 public static com.endpoint.test.Sum.SumRequest parseFrom(
363 java.io.InputStream input,
364 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
365 throws java.io.IOException {
366 return PARSER.parseFrom(input, extensionRegistry);
367 }
368 public static com.endpoint.test.Sum.SumRequest parseDelimitedFrom(java.io.InputStream input)
369 throws java.io.IOException {
370 return PARSER.parseDelimitedFrom(input);
371 }
372 public static com.endpoint.test.Sum.SumRequest parseDelimitedFrom(
373 java.io.InputStream input,
374 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
375 throws java.io.IOException {
376 return PARSER.parseDelimitedFrom(input, extensionRegistry);
377 }
378 public static com.endpoint.test.Sum.SumRequest parseFrom(
379 com.google.protobuf.CodedInputStream input)
380 throws java.io.IOException {
381 return PARSER.parseFrom(input);
382 }
383 public static com.endpoint.test.Sum.SumRequest parseFrom(
384 com.google.protobuf.CodedInputStream input,
385 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
386 throws java.io.IOException {
387 return PARSER.parseFrom(input, extensionRegistry);
388 }
389
390 public static Builder newBuilder() { return Builder.create(); }
391 public Builder newBuilderForType() { return newBuilder(); }
392 public static Builder newBuilder(com.endpoint.test.Sum.SumRequest prototype) {
393 return newBuilder().mergeFrom(prototype);
394 }
395 public Builder toBuilder() { return newBuilder(this); }
396
397 @java.lang.Override
398 protected Builder newBuilderForType(
399 com.google.protobuf.GeneratedMessage.BuilderParent parent) {
400 Builder builder = new Builder(parent);
401 return builder;
402 }
403 /**
404 * Protobuf type {@code SumRequest}
405 */
406 public static final class Builder extends
407 com.google.protobuf.GeneratedMessage.Builder<Builder>
408 implements com.endpoint.test.Sum.SumRequestOrBuilder {
409 public static final com.google.protobuf.Descriptors.Descriptor
410 getDescriptor() {
411 return com.endpoint.test.Sum.internal_static_SumRequest_descriptor;
412 }
413
414 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
415 internalGetFieldAccessorTable() {
416 return com.endpoint.test.Sum.internal_static_SumRequest_fieldAccessorTable
417 .ensureFieldAccessorsInitialized(
418 com.endpoint.test.Sum.SumRequest.class, com.endpoint.test.Sum.SumRequest.Builder.class);
419 }
420
421 // Construct using com.endpoint.test.Sum.SumRequest.newBuilder()
422 private Builder() {
423 maybeForceBuilderInitialization();
424 }
425
426 private Builder(
427 com.google.protobuf.GeneratedMessage.BuilderParent parent) {
428 super(parent);
429 maybeForceBuilderInitialization();
430 }
431 private void maybeForceBuilderInitialization() {
432 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
433 }
434 }
435 private static Builder create() {
436 return new Builder();
437 }
438
439 public Builder clear() {
440 super.clear();
441 family_ = "";
442 bitField0_ = (bitField0_ & ~0x00000001);
443 column_ = "";
444 bitField0_ = (bitField0_ & ~0x00000002);
445 return this;
446 }
447
448 public Builder clone() {
449 return create().mergeFrom(buildPartial());
450 }
451
452 public com.google.protobuf.Descriptors.Descriptor
453 getDescriptorForType() {
454 return com.endpoint.test.Sum.internal_static_SumRequest_descriptor;
455 }
456
457 public com.endpoint.test.Sum.SumRequest getDefaultInstanceForType() {
458 return com.endpoint.test.Sum.SumRequest.getDefaultInstance();
459 }
460
461 public com.endpoint.test.Sum.SumRequest build() {
462 com.endpoint.test.Sum.SumRequest result = buildPartial();
463 if (!result.isInitialized()) {
464 throw newUninitializedMessageException(result);
465 }
466 return result;
467 }
468
469 public com.endpoint.test.Sum.SumRequest buildPartial() {
470 com.endpoint.test.Sum.SumRequest result = new com.endpoint.test.Sum.SumRequest(this);
471 int from_bitField0_ = bitField0_;
472 int to_bitField0_ = 0;
473 if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
474 to_bitField0_ |= 0x00000001;
475 }
476 result.family_ = family_;
477 if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
478 to_bitField0_ |= 0x00000002;
479 }
480 result.column_ = column_;
481 result.bitField0_ = to_bitField0_;
482 onBuilt();
483 return result;
484 }
485
486 public Builder mergeFrom(com.google.protobuf.Message other) {
487 if (other instanceof com.endpoint.test.Sum.SumRequest) {
488 return mergeFrom((com.endpoint.test.Sum.SumRequest)other);
489 } else {
490 super.mergeFrom(other);
491 return this;
492 }
493 }
494
495 public Builder mergeFrom(com.endpoint.test.Sum.SumRequest other) {
496 if (other == com.endpoint.test.Sum.SumRequest.getDefaultInstance()) return this;
497 if (other.hasFamily()) {
498 bitField0_ |= 0x00000001;
499 family_ = other.family_;
500 onChanged();
501 }
502 if (other.hasColumn()) {
503 bitField0_ |= 0x00000002;
504 column_ = other.column_;
505 onChanged();
506 }
507 this.mergeUnknownFields(other.getUnknownFields());
508 return this;
509 }
510
511 public final boolean isInitialized() {
512 if (!hasFamily()) {
513
514 return false;
515 }
516 if (!hasColumn()) {
517
518 return false;
519 }
520 return true;
521 }
522
523 public Builder mergeFrom(
524 com.google.protobuf.CodedInputStream input,
525 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
526 throws java.io.IOException {
527 com.endpoint.test.Sum.SumRequest parsedMessage = null;
528 try {
529 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
530 } catch (com.google.protobuf.InvalidProtocolBufferException e) {
531 parsedMessage = (com.endpoint.test.Sum.SumRequest) e.getUnfinishedMessage();
532 throw e;
533 } finally {
534 if (parsedMessage != null) {
535 mergeFrom(parsedMessage);
536 }
537 }
538 return this;
539 }
540 private int bitField0_;
541
542 // required string family = 1;
543 private java.lang.Object family_ = "";
544 /**
545 * <code>required string family = 1;</code>
546 */
547 public boolean hasFamily() {
548 return ((bitField0_ & 0x00000001) == 0x00000001);
549 }
550 /**
551 * <code>required string family = 1;</code>
552 */
553 public java.lang.String getFamily() {
554 java.lang.Object ref = family_;
555 if (!(ref instanceof java.lang.String)) {
556 java.lang.String s = ((com.google.protobuf.ByteString) ref)
557 .toStringUtf8();
558 family_ = s;
559 return s;
560 } else {
561 return (java.lang.String) ref;
562 }
563 }
564 /**
565 * <code>required string family = 1;</code>
566 */
567 public com.google.protobuf.ByteString
568 getFamilyBytes() {
569 java.lang.Object ref = family_;
570 if (ref instanceof String) {
571 com.google.protobuf.ByteString b =
572 com.google.protobuf.ByteString.copyFromUtf8(
573 (java.lang.String) ref);
574 family_ = b;
575 return b;
576 } else {
577 return (com.google.protobuf.ByteString) ref;
578 }
579 }
580 /**
581 * <code>required string family = 1;</code>
582 */
583 public Builder setFamily(
584 java.lang.String value) {
585 if (value == null) {
586 throw new NullPointerException();
587 }
588 bitField0_ |= 0x00000001;
589 family_ = value;
590 onChanged();
591 return this;
592 }
593 /**
594 * <code>required string family = 1;</code>
595 */
596 public Builder clearFamily() {
597 bitField0_ = (bitField0_ & ~0x00000001);
598 family_ = getDefaultInstance().getFamily();
599 onChanged();
600 return this;
601 }
602 /**
603 * <code>required string family = 1;</code>
604 */
605 public Builder setFamilyBytes(
606 com.google.protobuf.ByteString value) {
607 if (value == null) {
608 throw new NullPointerException();
609 }
610 bitField0_ |= 0x00000001;
611 family_ = value;
612 onChanged();
613 return this;
614 }
615
616 // required string column = 2;
617 private java.lang.Object column_ = "";
618 /**
619 * <code>required string column = 2;</code>
620 */
621 public boolean hasColumn() {
622 return ((bitField0_ & 0x00000002) == 0x00000002);
623 }
624 /**
625 * <code>required string column = 2;</code>
626 */
627 public java.lang.String getColumn() {
628 java.lang.Object ref = column_;
629 if (!(ref instanceof java.lang.String)) {
630 java.lang.String s = ((com.google.protobuf.ByteString) ref)
631 .toStringUtf8();
632 column_ = s;
633 return s;
634 } else {
635 return (java.lang.String) ref;
636 }
637 }
638 /**
639 * <code>required string column = 2;</code>
640 */
641 public com.google.protobuf.ByteString
642 getColumnBytes() {
643 java.lang.Object ref = column_;
644 if (ref instanceof String) {
645 com.google.protobuf.ByteString b =
646 com.google.protobuf.ByteString.copyFromUtf8(
647 (java.lang.String) ref);
648 column_ = b;
649 return b;
650 } else {
651 return (com.google.protobuf.ByteString) ref;
652 }
653 }
654 /**
655 * <code>required string column = 2;</code>
656 */
657 public Builder setColumn(
658 java.lang.String value) {
659 if (value == null) {
660 throw new NullPointerException();
661 }
662 bitField0_ |= 0x00000002;
663 column_ = value;
664 onChanged();
665 return this;
666 }
667 /**
668 * <code>required string column = 2;</code>
669 */
670 public Builder clearColumn() {
671 bitField0_ = (bitField0_ & ~0x00000002);
672 column_ = getDefaultInstance().getColumn();
673 onChanged();
674 return this;
675 }
676 /**
677 * <code>required string column = 2;</code>
678 */
679 public Builder setColumnBytes(
680 com.google.protobuf.ByteString value) {
681 if (value == null) {
682 throw new NullPointerException();
683 }
684 bitField0_ |= 0x00000002;
685 column_ = value;
686 onChanged();
687 return this;
688 }
689
690 // @@protoc_insertion_point(builder_scope:SumRequest)
691 }
692
693 static {
694 defaultInstance = new SumRequest(true);
695 defaultInstance.initFields();
696 }
697
698 // @@protoc_insertion_point(class_scope:SumRequest)
699 }
700
701 public interface SumResponseOrBuilder
702 extends com.google.protobuf.MessageOrBuilder {
703
704 // required int64 sum = 1 [default = 0];
705 /**
706 * <code>required int64 sum = 1 [default = 0];</code>
707 */
708 boolean hasSum();
709 /**
710 * <code>required int64 sum = 1 [default = 0];</code>
711 */
712 long getSum();
713 }
714 /**
715 * Protobuf type {@code SumResponse}
716 */
717 public static final class SumResponse extends
718 com.google.protobuf.GeneratedMessage
719 implements SumResponseOrBuilder {
720 // Use SumResponse.newBuilder() to construct.
721 private SumResponse(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
722 super(builder);
723 this.unknownFields = builder.getUnknownFields();
724 }
725 private SumResponse(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
726
727 private static final SumResponse defaultInstance;
728 public static SumResponse getDefaultInstance() {
729 return defaultInstance;
730 }
731
732 public SumResponse getDefaultInstanceForType() {
733 return defaultInstance;
734 }
735
736 private final com.google.protobuf.UnknownFieldSet unknownFields;
737 @java.lang.Override
738 public final com.google.protobuf.UnknownFieldSet
739 getUnknownFields() {
740 return this.unknownFields;
741 }
742 private SumResponse(
743 com.google.protobuf.CodedInputStream input,
744 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
745 throws com.google.protobuf.InvalidProtocolBufferException {
746 initFields();
747 int mutable_bitField0_ = 0;
748 com.google.protobuf.UnknownFieldSet.Builder unknownFields =
749 com.google.protobuf.UnknownFieldSet.newBuilder();
750 try {
751 boolean done = false;
752 while (!done) {
753 int tag = input.readTag();
754 switch (tag) {
755 case 0:
756 done = true;
757 break;
758 default: {
759 if (!parseUnknownField(input, unknownFields,
760 extensionRegistry, tag)) {
761 done = true;
762 }
763 break;
764 }
765 case 8: {
766 bitField0_ |= 0x00000001;
767 sum_ = input.readInt64();
768 break;
769 }
770 }
771 }
772 } catch (com.google.protobuf.InvalidProtocolBufferException e) {
773 throw e.setUnfinishedMessage(this);
774 } catch (java.io.IOException e) {
775 throw new com.google.protobuf.InvalidProtocolBufferException(
776 e.getMessage()).setUnfinishedMessage(this);
777 } finally {
778 this.unknownFields = unknownFields.build();
779 makeExtensionsImmutable();
780 }
781 }
782 public static final com.google.protobuf.Descriptors.Descriptor
783 getDescriptor() {
784 return com.endpoint.test.Sum.internal_static_SumResponse_descriptor;
785 }
786
787 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
788 internalGetFieldAccessorTable() {
789 return com.endpoint.test.Sum.internal_static_SumResponse_fieldAccessorTable
790 .ensureFieldAccessorsInitialized(
791 com.endpoint.test.Sum.SumResponse.class, com.endpoint.test.Sum.SumResponse.Builder.class);
792 }
793
794 public static com.google.protobuf.Parser<SumResponse> PARSER =
795 new com.google.protobuf.AbstractParser<SumResponse>() {
796 public SumResponse parsePartialFrom(
797 com.google.protobuf.CodedInputStream input,
798 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
799 throws com.google.protobuf.InvalidProtocolBufferException {
800 return new SumResponse(input, extensionRegistry);
801 }
802 };
803
804 @java.lang.Override
805 public com.google.protobuf.Parser<SumResponse> getParserForType() {
806 return PARSER;
807 }
808
809 private int bitField0_;
810 // required int64 sum = 1 [default = 0];
811 public static final int SUM_FIELD_NUMBER = 1;
812 private long sum_;
813 /**
814 * <code>required int64 sum = 1 [default = 0];</code>
815 */
816 public boolean hasSum() {
817 return ((bitField0_ & 0x00000001) == 0x00000001);
818 }
819 /**
820 * <code>required int64 sum = 1 [default = 0];</code>
821 */
822 public long getSum() {
823 return sum_;
824 }
825
826 private void initFields() {
827 sum_ = 0L;
828 }
829 private byte memoizedIsInitialized = -1;
830 public final boolean isInitialized() {
831 byte isInitialized = memoizedIsInitialized;
832 if (isInitialized != -1) return isInitialized == 1;
833
834 if (!hasSum()) {
835 memoizedIsInitialized = 0;
836 return false;
837 }
838 memoizedIsInitialized = 1;
839 return true;
840 }
841
842 public void writeTo(com.google.protobuf.CodedOutputStream output)
843 throws java.io.IOException {
844 getSerializedSize();
845 if (((bitField0_ & 0x00000001) == 0x00000001)) {
846 output.writeInt64(1, sum_);
847 }
848 getUnknownFields().writeTo(output);
849 }
850
851 private int memoizedSerializedSize = -1;
852 public int getSerializedSize() {
853 int size = memoizedSerializedSize;
854 if (size != -1) return size;
855
856 size = 0;
857 if (((bitField0_ & 0x00000001) == 0x00000001)) {
858 size += com.google.protobuf.CodedOutputStream
859 .computeInt64Size(1, sum_);
860 }
861 size += getUnknownFields().getSerializedSize();
862 memoizedSerializedSize = size;
863 return size;
864 }
865
866 private static final long serialVersionUID = 0L;
867 @java.lang.Override
868 protected java.lang.Object writeReplace()
869 throws java.io.ObjectStreamException {
870 return super.writeReplace();
871 }
872
873 @java.lang.Override
874 public boolean equals(final java.lang.Object obj) {
875 if (obj == this) {
876 return true;
877 }
878 if (!(obj instanceof com.endpoint.test.Sum.SumResponse)) {
879 return super.equals(obj);
880 }
881 com.endpoint.test.Sum.SumResponse other = (com.endpoint.test.Sum.SumResponse) obj;
882
883 boolean result = true;
884 result = result && (hasSum() == other.hasSum());
885 if (hasSum()) {
886 result = result && (getSum()
887 == other.getSum());
888 }
889 result = result &&
890 getUnknownFields().equals(other.getUnknownFields());
891 return result;
892 }
893
894 private int memoizedHashCode = 0;
895 @java.lang.Override
896 public int hashCode() {
897 if (memoizedHashCode != 0) {
898 return memoizedHashCode;
899 }
900 int hash = 41;
901 hash = (19 * hash) + getDescriptorForType().hashCode();
902 if (hasSum()) {
903 hash = (37 * hash) + SUM_FIELD_NUMBER;
904 hash = (53 * hash) + hashLong(getSum());
905 }
906 hash = (29 * hash) + getUnknownFields().hashCode();
907 memoizedHashCode = hash;
908 return hash;
909 }
910
911 public static com.endpoint.test.Sum.SumResponse parseFrom(
912 com.google.protobuf.ByteString data)
913 throws com.google.protobuf.InvalidProtocolBufferException {
914 return PARSER.parseFrom(data);
915 }
916 public static com.endpoint.test.Sum.SumResponse parseFrom(
917 com.google.protobuf.ByteString data,
918 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
919 throws com.google.protobuf.InvalidProtocolBufferException {
920 return PARSER.parseFrom(data, extensionRegistry);
921 }
922 public static com.endpoint.test.Sum.SumResponse parseFrom(byte[] data)
923 throws com.google.protobuf.InvalidProtocolBufferException {
924 return PARSER.parseFrom(data);
925 }
926 public static com.endpoint.test.Sum.SumResponse parseFrom(
927 byte[] data,
928 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
929 throws com.google.protobuf.InvalidProtocolBufferException {
930 return PARSER.parseFrom(data, extensionRegistry);
931 }
932 public static com.endpoint.test.Sum.SumResponse parseFrom(java.io.InputStream input)
933 throws java.io.IOException {
934 return PARSER.parseFrom(input);
935 }
936 public static com.endpoint.test.Sum.SumResponse parseFrom(
937 java.io.InputStream input,
938 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
939 throws java.io.IOException {
940 return PARSER.parseFrom(input, extensionRegistry);
941 }
942 public static com.endpoint.test.Sum.SumResponse parseDelimitedFrom(java.io.InputStream input)
943 throws java.io.IOException {
944 return PARSER.parseDelimitedFrom(input);
945 }
946 public static com.endpoint.test.Sum.SumResponse parseDelimitedFrom(
947 java.io.InputStream input,
948 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
949 throws java.io.IOException {
950 return PARSER.parseDelimitedFrom(input, extensionRegistry);
951 }
952 public static com.endpoint.test.Sum.SumResponse parseFrom(
953 com.google.protobuf.CodedInputStream input)
954 throws java.io.IOException {
955 return PARSER.parseFrom(input);
956 }
957 public static com.endpoint.test.Sum.SumResponse parseFrom(
958 com.google.protobuf.CodedInputStream input,
959 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
960 throws java.io.IOException {
961 return PARSER.parseFrom(input, extensionRegistry);
962 }
963
964 public static Builder newBuilder() { return Builder.create(); }
965 public Builder newBuilderForType() { return newBuilder(); }
966 public static Builder newBuilder(com.endpoint.test.Sum.SumResponse prototype) {
967 return newBuilder().mergeFrom(prototype);
968 }
969 public Builder toBuilder() { return newBuilder(this); }
970
971 @java.lang.Override
972 protected Builder newBuilderForType(
973 com.google.protobuf.GeneratedMessage.BuilderParent parent) {
974 Builder builder = new Builder(parent);
975 return builder;
976 }
977 /**
978 * Protobuf type {@code SumResponse}
979 */
980 public static final class Builder extends
981 com.google.protobuf.GeneratedMessage.Builder<Builder>
982 implements com.endpoint.test.Sum.SumResponseOrBuilder {
983 public static final com.google.protobuf.Descriptors.Descriptor
984 getDescriptor() {
985 return com.endpoint.test.Sum.internal_static_SumResponse_descriptor;
986 }
987
988 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
989 internalGetFieldAccessorTable() {
990 return com.endpoint.test.Sum.internal_static_SumResponse_fieldAccessorTable
991 .ensureFieldAccessorsInitialized(
992 com.endpoint.test.Sum.SumResponse.class, com.endpoint.test.Sum.SumResponse.Builder.class);
993 }
994
995 // Construct using com.endpoint.test.Sum.SumResponse.newBuilder()
996 private Builder() {
997 maybeForceBuilderInitialization();
998 }
999
1000 private Builder(
1001 com.google.protobuf.GeneratedMessage.BuilderParent parent) {
1002 super(parent);
1003 maybeForceBuilderInitialization();
1004 }
1005 private void maybeForceBuilderInitialization() {
1006 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
1007 }
1008 }
1009 private static Builder create() {
1010 return new Builder();
1011 }
1012
1013 public Builder clear() {
1014 super.clear();
1015 sum_ = 0L;
1016 bitField0_ = (bitField0_ & ~0x00000001);
1017 return this;
1018 }
1019
1020 public Builder clone() {
1021 return create().mergeFrom(buildPartial());
1022 }
1023
1024 public com.google.protobuf.Descriptors.Descriptor
1025 getDescriptorForType() {
1026 return com.endpoint.test.Sum.internal_static_SumResponse_descriptor;
1027 }
1028
1029 public com.endpoint.test.Sum.SumResponse getDefaultInstanceForType() {
1030 return com.endpoint.test.Sum.SumResponse.getDefaultInstance();
1031 }
1032
1033 public com.endpoint.test.Sum.SumResponse build() {
1034 com.endpoint.test.Sum.SumResponse result = buildPartial();
1035 if (!result.isInitialized()) {
1036 throw newUninitializedMessageException(result);
1037 }
1038 return result;
1039 }
1040
1041 public com.endpoint.test.Sum.SumResponse buildPartial() {
1042 com.endpoint.test.Sum.SumResponse result = new com.endpoint.test.Sum.SumResponse(this);
1043 int from_bitField0_ = bitField0_;
1044 int to_bitField0_ = 0;
1045 if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
1046 to_bitField0_ |= 0x00000001;
1047 }
1048 result.sum_ = sum_;
1049 result.bitField0_ = to_bitField0_;
1050 onBuilt();
1051 return result;
1052 }
1053
1054 public Builder mergeFrom(com.google.protobuf.Message other) {
1055 if (other instanceof com.endpoint.test.Sum.SumResponse) {
1056 return mergeFrom((com.endpoint.test.Sum.SumResponse)other);
1057 } else {
1058 super.mergeFrom(other);
1059 return this;
1060 }
1061 }
1062
1063 public Builder mergeFrom(com.endpoint.test.Sum.SumResponse other) {
1064 if (other == com.endpoint.test.Sum.SumResponse.getDefaultInstance()) return this;
1065 if (other.hasSum()) {
1066 setSum(other.getSum());
1067 }
1068 this.mergeUnknownFields(other.getUnknownFields());
1069 return this;
1070 }
1071
1072 public final boolean isInitialized() {
1073 if (!hasSum()) {
1074
1075 return false;
1076 }
1077 return true;
1078 }
1079
1080 public Builder mergeFrom(
1081 com.google.protobuf.CodedInputStream input,
1082 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
1083 throws java.io.IOException {
1084 com.endpoint.test.Sum.SumResponse parsedMessage = null;
1085 try {
1086 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
1087 } catch (com.google.protobuf.InvalidProtocolBufferException e) {
1088 parsedMessage = (com.endpoint.test.Sum.SumResponse) e.getUnfinishedMessage();
1089 throw e;
1090 } finally {
1091 if (parsedMessage != null) {
1092 mergeFrom(parsedMessage);
1093 }
1094 }
1095 return this;
1096 }
1097 private int bitField0_;
1098
1099 // required int64 sum = 1 [default = 0];
1100 private long sum_ ;
1101 /**
1102 * <code>required int64 sum = 1 [default = 0];</code>
1103 */
1104 public boolean hasSum() {
1105 return ((bitField0_ & 0x00000001) == 0x00000001);
1106 }
1107 /**
1108 * <code>required int64 sum = 1 [default = 0];</code>
1109 */
1110 public long getSum() {
1111 return sum_;
1112 }
1113 /**
1114 * <code>required int64 sum = 1 [default = 0];</code>
1115 */
1116 public Builder setSum(long value) {
1117 bitField0_ |= 0x00000001;
1118 sum_ = value;
1119 onChanged();
1120 return this;
1121 }
1122 /**
1123 * <code>required int64 sum = 1 [default = 0];</code>
1124 */
1125 public Builder clearSum() {
1126 bitField0_ = (bitField0_ & ~0x00000001);
1127 sum_ = 0L;
1128 onChanged();
1129 return this;
1130 }
1131
1132 // @@protoc_insertion_point(builder_scope:SumResponse)
1133 }
1134
1135 static {
1136 defaultInstance = new SumResponse(true);
1137 defaultInstance.initFields();
1138 }
1139
1140 // @@protoc_insertion_point(class_scope:SumResponse)
1141 }
1142
1143 /**
1144 * Protobuf service {@code SumService}
1145 */
1146 public static abstract class SumService
1147 implements com.google.protobuf.Service {
1148 protected SumService() {}
1149
1150 public interface Interface {
1151 /**
1152 * <code>rpc getSum(.SumRequest) returns (.SumResponse);</code>
1153 */
1154 public abstract void getSum(
1155 com.google.protobuf.RpcController controller,
1156 com.endpoint.test.Sum.SumRequest request,
1157 com.google.protobuf.RpcCallback<com.endpoint.test.Sum.SumResponse> done);
1158
1159 }
1160
1161 public static com.google.protobuf.Service newReflectiveService(
1162 final Interface impl) {
1163 return new SumService() {
1164 @java.lang.Override
1165 public void getSum(
1166 com.google.protobuf.RpcController controller,
1167 com.endpoint.test.Sum.SumRequest request,
1168 com.google.protobuf.RpcCallback<com.endpoint.test.Sum.SumResponse> done) {
1169 impl.getSum(controller, request, done);
1170 }
1171
1172 };
1173 }
1174
1175 public static com.google.protobuf.BlockingService
1176 newReflectiveBlockingService(final BlockingInterface impl) {
1177 return new com.google.protobuf.BlockingService() {
1178 public final com.google.protobuf.Descriptors.ServiceDescriptor
1179 getDescriptorForType() {
1180 return getDescriptor();
1181 }
1182
1183 public final com.google.protobuf.Message callBlockingMethod(
1184 com.google.protobuf.Descriptors.MethodDescriptor method,
1185 com.google.protobuf.RpcController controller,
1186 com.google.protobuf.Message request)
1187 throws com.google.protobuf.ServiceException {
1188 if (method.getService() != getDescriptor()) {
1189 throw new java.lang.IllegalArgumentException(
1190 "Service.callBlockingMethod() given method descriptor for " +
1191 "wrong service type.");
1192 }
1193 switch(method.getIndex()) {
1194 case 0:
1195 return impl.getSum(controller, (com.endpoint.test.Sum.SumRequest)request);
1196 default:
1197 throw new java.lang.AssertionError("Can‘t get here.");
1198 }
1199 }
1200
1201 public final com.google.protobuf.Message
1202 getRequestPrototype(
1203 com.google.protobuf.Descriptors.MethodDescriptor method) {
1204 if (method.getService() != getDescriptor()) {
1205 throw new java.lang.IllegalArgumentException(
1206 "Service.getRequestPrototype() given method " +
1207 "descriptor for wrong service type.");
1208 }
1209 switch(method.getIndex()) {
1210 case 0:
1211 return com.endpoint.test.Sum.SumRequest.getDefaultInstance();
1212 default:
1213 throw new java.lang.AssertionError("Can‘t get here.");
1214 }
1215 }
1216
1217 public final com.google.protobuf.Message
1218 getResponsePrototype(
1219 com.google.protobuf.Descriptors.MethodDescriptor method) {
1220 if (method.getService() != getDescriptor()) {
1221 throw new java.lang.IllegalArgumentException(
1222 "Service.getResponsePrototype() given method " +
1223 "descriptor for wrong service type.");
1224 }
1225 switch(method.getIndex()) {
1226 case 0:
1227 return com.endpoint.test.Sum.SumResponse.getDefaultInstance();
1228 default:
1229 throw new java.lang.AssertionError("Can‘t get here.");
1230 }
1231 }
1232
1233 };
1234 }
1235
1236 /**
1237 * <code>rpc getSum(.SumRequest) returns (.SumResponse);</code>
1238 */
1239 public abstract void getSum(
1240 com.google.protobuf.RpcController controller,
1241 com.endpoint.test.Sum.SumRequest request,
1242 com.google.protobuf.RpcCallback<com.endpoint.test.Sum.SumResponse> done);
1243
1244 public static final
1245 com.google.protobuf.Descriptors.ServiceDescriptor
1246 getDescriptor() {
1247 return com.endpoint.test.Sum.getDescriptor().getServices().get(0);
1248 }
1249 public final com.google.protobuf.Descriptors.ServiceDescriptor
1250 getDescriptorForType() {
1251 return getDescriptor();
1252 }
1253
1254 public final void callMethod(
1255 com.google.protobuf.Descriptors.MethodDescriptor method,
1256 com.google.protobuf.RpcController controller,
1257 com.google.protobuf.Message request,
1258 com.google.protobuf.RpcCallback<
1259 com.google.protobuf.Message> done) {
1260 if (method.getService() != getDescriptor()) {
1261 throw new java.lang.IllegalArgumentException(
1262 "Service.callMethod() given method descriptor for wrong " +
1263 "service type.");
1264 }
1265 switch(method.getIndex()) {
1266 case 0:
1267 this.getSum(controller, (com.endpoint.test.Sum.SumRequest)request,
1268 com.google.protobuf.RpcUtil.<com.endpoint.test.Sum.SumResponse>specializeCallback(
1269 done));
1270 return;
1271 default:
1272 throw new java.lang.AssertionError("Can‘t get here.");
1273 }
1274 }
1275
1276 public final com.google.protobuf.Message
1277 getRequestPrototype(
1278 com.google.protobuf.Descriptors.MethodDescriptor method) {
1279 if (method.getService() != getDescriptor()) {
1280 throw new java.lang.IllegalArgumentException(
1281 "Service.getRequestPrototype() given method " +
1282 "descriptor for wrong service type.");
1283 }
1284 switch(method.getIndex()) {
1285 case 0:
1286 return com.endpoint.test.Sum.SumRequest.getDefaultInstance();
1287 default:
1288 throw new java.lang.AssertionError("Can‘t get here.");
1289 }
1290 }
1291
1292 public final com.google.protobuf.Message
1293 getResponsePrototype(
1294 com.google.protobuf.Descriptors.MethodDescriptor method) {
1295 if (method.getService() != getDescriptor()) {
1296 throw new java.lang.IllegalArgumentException(
1297 "Service.getResponsePrototype() given method " +
1298 "descriptor for wrong service type.");
1299 }
1300 switch(method.getIndex()) {
1301 case 0:
1302 return com.endpoint.test.Sum.SumResponse.getDefaultInstance();
1303 default:
1304 throw new java.lang.AssertionError("Can‘t get here.");
1305 }
1306 }
1307
1308 public static Stub newStub(
1309 com.google.protobuf.RpcChannel channel) {
1310 return new Stub(channel);
1311 }
1312
1313 public static final class Stub extends com.endpoint.test.Sum.SumService implements Interface {
1314 private Stub(com.google.protobuf.RpcChannel channel) {
1315 this.channel = channel;
1316 }
1317
1318 private final com.google.protobuf.RpcChannel channel;
1319
1320 public com.google.protobuf.RpcChannel getChannel() {
1321 return channel;
1322 }
1323
1324 public void getSum(
1325 com.google.protobuf.RpcController controller,
1326 com.endpoint.test.Sum.SumRequest request,
1327 com.google.protobuf.RpcCallback<com.endpoint.test.Sum.SumResponse> done) {
1328 channel.callMethod(
1329 getDescriptor().getMethods().get(0),
1330 controller,
1331 request,
1332 com.endpoint.test.Sum.SumResponse.getDefaultInstance(),
1333 com.google.protobuf.RpcUtil.generalizeCallback(
1334 done,
1335 com.endpoint.test.Sum.SumResponse.class,
1336 com.endpoint.test.Sum.SumResponse.getDefaultInstance()));
1337 }
1338 }
1339
1340 public static BlockingInterface newBlockingStub(
1341 com.google.protobuf.BlockingRpcChannel channel) {
1342 return new BlockingStub(channel);
1343 }
1344
1345 public interface BlockingInterface {
1346 public com.endpoint.test.Sum.SumResponse getSum(
1347 com.google.protobuf.RpcController controller,
1348 com.endpoint.test.Sum.SumRequest request)
1349 throws com.google.protobuf.ServiceException;
1350 }
1351
1352 private static final class BlockingStub implements BlockingInterface {
1353 private BlockingStub(com.google.protobuf.BlockingRpcChannel channel) {
1354 this.channel = channel;
1355 }
1356
1357 private final com.google.protobuf.BlockingRpcChannel channel;
1358
1359 public com.endpoint.test.Sum.SumResponse getSum(
1360 com.google.protobuf.RpcController controller,
1361 com.endpoint.test.Sum.SumRequest request)
1362 throws com.google.protobuf.ServiceException {
1363 return (com.endpoint.test.Sum.SumResponse) channel.callBlockingMethod(
1364 getDescriptor().getMethods().get(0),
1365 controller,
1366 request,
1367 com.endpoint.test.Sum.SumResponse.getDefaultInstance());
1368 }
1369
1370 }
1371
1372 // @@protoc_insertion_point(class_scope:SumService)
1373 }
1374
1375 private static com.google.protobuf.Descriptors.Descriptor
1376 internal_static_SumRequest_descriptor;
1377 private static
1378 com.google.protobuf.GeneratedMessage.FieldAccessorTable
1379 internal_static_SumRequest_fieldAccessorTable;
1380 private static com.google.protobuf.Descriptors.Descriptor
1381 internal_static_SumResponse_descriptor;
1382 private static
1383 com.google.protobuf.GeneratedMessage.FieldAccessorTable
1384 internal_static_SumResponse_fieldAccessorTable;
1385
1386 public static com.google.protobuf.Descriptors.FileDescriptor
1387 getDescriptor() {
1388 return descriptor;
1389 }
1390 private static com.google.protobuf.Descriptors.FileDescriptor
1391 descriptor;
1392 static {
1393 java.lang.String[] descriptorData = {
1394 "\n\rsumcode.proto\",\n\nSumRequest\022\016\n\006family\030" +
1395 "\001 \002(\t\022\016\n\006column\030\002 \002(\t\"\035\n\013SumResponse\022\016\n\003" +
1396 "sum\030\001 \002(\003:\001021\n\nSumService\022#\n\006getSum\022\013.S" +
1397 "umRequest\032\014.SumResponseB \n\021com.endpoint." +
1398 "testB\003SumH\001\210\001\001\240\001\001"
1399 };
1400 com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
1401 new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
1402 public com.google.protobuf.ExtensionRegistry assignDescriptors(
1403 com.google.protobuf.Descriptors.FileDescriptor root) {
1404 descriptor = root;
1405 internal_static_SumRequest_descriptor =
1406 getDescriptor().getMessageTypes().get(0);
1407 internal_static_SumRequest_fieldAccessorTable = new
1408 com.google.protobuf.GeneratedMessage.FieldAccessorTable(
1409 internal_static_SumRequest_descriptor,
1410 new java.lang.String[] { "Family", "Column", });
1411 internal_static_SumResponse_descriptor =
1412 getDescriptor().getMessageTypes().get(1);
1413 internal_static_SumResponse_fieldAccessorTable = new
1414 com.google.protobuf.GeneratedMessage.FieldAccessorTable(
1415 internal_static_SumResponse_descriptor,
1416 new java.lang.String[] { "Sum", });
1417 return null;
1418 }
1419 };
1420 com.google.protobuf.Descriptors.FileDescriptor
1421 .internalBuildGeneratedFileFrom(descriptorData,
1422 new com.google.protobuf.Descriptors.FileDescriptor[] {
1423 }, assigner);
1424 }
1425
1426 // @@protoc_insertion_point(outer_class_scope)
1427 }
2> 编写服务器端的代码
1 package com.endpoint.test;
2
3 import java.io.IOException;
4 import java.util.ArrayList;
5 import java.util.List;
6 import org.apache.hadoop.hbase.Cell;
7 import org.apache.hadoop.hbase.CellUtil;
8 import org.apache.hadoop.hbase.Coprocessor;
9 import org.apache.hadoop.hbase.CoprocessorEnvironment;
10 import org.apache.hadoop.hbase.client.Scan;
11 import org.apache.hadoop.hbase.coprocessor.CoprocessorException;
12 import org.apache.hadoop.hbase.coprocessor.CoprocessorService;
13 import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment;
14 import org.apache.hadoop.hbase.protobuf.ResponseConverter;
15 import org.apache.hadoop.hbase.regionserver.InternalScanner;
16 import org.apache.hadoop.hbase.util.Bytes;
17 import com.endpoint.test.Sum.SumRequest;
18 import com.endpoint.test.Sum.SumResponse;
19 import com.endpoint.test.Sum.SumService;
20 import com.google.protobuf.RpcCallback;
21 import com.google.protobuf.RpcController;
22 import com.google.protobuf.Service;
23
24 public class SumEndPoint extends SumService implements Coprocessor,CoprocessorService{
25
26 private RegionCoprocessorEnvironment env; // 定义环境
27 @Override
28 public Service getService() {
29
30 return this;
31 }
32
33 @Override
34 public void start(CoprocessorEnvironment env) throws IOException {
35 if (env instanceof RegionCoprocessorEnvironment) {
36 this.env = (RegionCoprocessorEnvironment)env;
37 } else {
38 throw new CoprocessorException("no load region");
39 }
40
41 }
42
43 @Override
44 public void stop(CoprocessorEnvironment env) throws IOException {
45
46 }
47
48 @Override
49 public void getSum(RpcController controller, SumRequest request, RpcCallback<SumResponse> done) {
50
51 // 设置扫描对象
52 Scan scan = new Scan();
53 scan.addFamily(Bytes.toBytes(request.getFamily()));
54 scan.addColumn(Bytes.toBytes(request.getFamily()), Bytes.toBytes(request.getColumn()));
55
56 // 定义变量
57 SumResponse response = null;
58 InternalScanner scanner = null;
59
60 // 扫描每个region，取值后求和
61 try {
62 scanner = env.getRegion().getScanner(scan);
63 List<Cell> results = new ArrayList<Cell>();
64 boolean hasMore = false;
65 Long sum = 0L;
66 do {
67 hasMore = scanner.next(results);
68 for (Cell cell : results) {
69 sum += Long.parseLong(new String(CellUtil.cloneValue(cell)));
70 }
71 results.clear();
72 } while (hasMore);
73 // 设置返回结果
74 response = SumResponse.newBuilder().setSum(sum).build();
75 } catch (IOException e) {
76 ResponseConverter.setControllerException(controller, e);
77 } finally {
78 if (scanner != null) {
79 try {
80 scanner.close();
81 } catch (IOException e) {
82 //e.printStackTrace();
83 }
84 }
85 }
86 // 将rpc结果返回给客户端
87 done.run(response);
88
89 }
90
91 }
3> 客户端测试代码
1 package com.endpoint.test;
2
3 import java.io.IOException;
4 import java.util.Map;
5 import org.apache.hadoop.conf.Configuration;
6 import org.apache.hadoop.hbase.HBaseConfiguration;
7 import org.apache.hadoop.hbase.TableName;
8 import org.apache.hadoop.hbase.client.Connection;
9 import org.apache.hadoop.hbase.client.ConnectionFactory;
10 import org.apache.hadoop.hbase.client.HTable;
11 import org.apache.hadoop.hbase.client.coprocessor.Batch;
12 import org.apache.hadoop.hbase.ipc.BlockingRpcCallback;
13 import com.endpoint.test.Sum.SumRequest;
14 import com.endpoint.test.Sum.SumResponse;
15 import com.endpoint.test.Sum.SumService;
16 import com.google.protobuf.ServiceException;
17
18 public class TestClient {
19
20 public static void main(String[] args) throws Exception {
21
22 // 配置HBse
23 Configuration conf = HBaseConfiguration.create();
24 conf.set("hbase.zookeeper.quorum", "master,data1,data2");
25 conf.set("hbase.zookeeper.property.clientPort", "2181");
26 conf.setLong("hbase.rpc.timeout", 600000);
27 System.setProperty("hadoop.home.dir", "C:/hadoopfiles/hadoop-common-2.2.0-bin-master");
28
29 // 建立一个数据库的连接
30 Connection conn = ConnectionFactory.createConnection(conf);
31 // 获取表
32 HTable table = (HTable) conn.getTable(TableName.valueOf("etable"));
33
34 long sum = 0L;
35
36 // 设置请求对象
37 final SumRequest request = SumRequest.newBuilder().setFamily("cf").setColumn("value").build();
38
39 try {
40 // 获得返回值
41 Map<byte[], Long> result = table.coprocessorService(SumService.class, null, null,
42 new Batch.Call<SumService, Long>() {
43
44 @Override
45 public Long call(SumService service) throws IOException {
46 BlockingRpcCallback<SumResponse> rpcCallback = new BlockingRpcCallback<SumResponse>();
47 service.getSum(null, request, rpcCallback);
48 SumResponse response = (SumResponse) rpcCallback.get();
49 return response.hasSum() ? response.getSum() : 0L;
50 }
51 });
52 // 将返回值进行迭代相加
53 for (Long v : result.values()) {
54 sum += v;
55 }
56 // 结果输出
57 System.out.println("sum: " + sum);
58
59 } catch (ServiceException e) {
60 e.printStackTrace();
61 }catch (Throwable e) {
62 e.printStackTrace();
63 }
64 table.close();
65 conn.close();
66
67 }
68
69 }
System.setProperty("hadoop.home.dir", "C:/hadoopfiles/hadoop-common-2.2.0-bin-master"); 这句代码是防错误用的，不具有实际意义，在hadoop-common-2.2.0-bin-master下建立bin目录放一个winutils.exe文件即可，否则会出现提示“Could not locate executable null\bin\winutils.exe in the Hadoop binaries”
此外，需要在windows下设置一下hosts文件，因为conf.set("hbase.zookeeper.quorum", "master,data1,data2");
4> 使用Endpoint协处理器
将上面的Sum类文件与用于服务端的SumEndPoint 类文件打包上传到服务器
chown hadoop:hadoop datacode.jar chmod g+w datacode.jar
先改一下权限，之后
hadoop fs -copyFromLocal sumtest.jar /input/
下面是要使用协处理器的hbase表
要将协处理器加载到这个表上
disable ‘etable‘# 包名.类名|权重 com.endpoint.test.SumEndPoint|100alter‘etable‘,METHOD =>‘table_att‘,‘coprocessor‘ =>‘/input/sumcode.jar|com.endpoint.test.SumEndPoint|100‘ enable ‘etable‘
包名.类名|权重 com.endpoint.test.SumEndPoint|100
# 这样也是可以的，但是在集群变换主节点的情况下，不是很好 # alter‘etable‘,METHOD =>‘table_att‘,‘coprocessor‘ =>‘hdfs://192.168.1.215:9000/input/sumcode.jar|com.endpoint.test.SumEndPoint|100‘
此外，值得注意的一点，在集群中，最好在hbase-site.xml中设置以下属性：
<property>
<name>hbase.coprocessor.abortonerror</name>
<value>false</value>
</property>
设置为false目的在于提高容错性，如果这个属性没有设置为false，则在上传的jar包存在错误的情况下，会导致表不能enable或disable，从而导致集群中的这张表无法使用，甚至会影响到其他表。
在windows中的客户端运行客户端的代码，结果如下：
2、Observer实例
这个是一个二级索引实例，即假定在initialtable表中的数据格式是这样的
row1 E 151 row2 Y 158
在向initialtable表中写入数据时，自动将以下数据写入indextable表作为二级索引，indextable第二列成为indextable的键
Y 158
1> 编写服务端代码
1 package com.observer.test;
2
3 import java.io.IOException;
4 import java.util.List;
5 import org.apache.hadoop.hbase.Cell;
6 import org.apache.hadoop.hbase.CellUtil;
7 import org.apache.hadoop.hbase.TableName;
8 import org.apache.hadoop.hbase.client.Durability;
9 import org.apache.hadoop.hbase.client.HTableInterface;
10 import org.apache.hadoop.hbase.client.Put;
11 import org.apache.hadoop.hbase.coprocessor.BaseRegionObserver;
12 import org.apache.hadoop.hbase.coprocessor.ObserverContext;
13 import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment;
14 import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
15 import org.apache.hadoop.hbase.util.Bytes;
16
17 public class TestObserver extends BaseRegionObserver {
18 @Override
19 public void postPut(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability)
20 throws IOException {
21 // indextable作为二级索引表
22 HTableInterface table = e.getEnvironment().getTable(TableName.valueOf("indextable"));
23 // 获取值
24 List<Cell> cellList1 = put.get(Bytes.toBytes("cf"), Bytes.toBytes("name"));
25 List<Cell> cellList2 = put.get(Bytes.toBytes("cf"), Bytes.toBytes("value"));
26 // 写入数据
27 for (Cell cell1 : cellList1) {
28 // 原表的列cf:name的值作为indextable的rowkey，添加行
29 Put indexPut = new Put(CellUtil.cloneValue(cell1));
30 for (Cell cell2 : cellList2) {
31 // 原表的列cf:value的值作为indextable表中列cf:value的值 。
32 indexPut.add(Bytes.toBytes("cf"), Bytes.toBytes("value"), CellUtil.cloneValue(cell2));
33 }
34
35 table.put(indexPut);
36 }
37
38 table.close();
39 }
40
41 }
2> 编写客户段代码
1 package com.observer.test;
2
3 import java.io.IOException;
4
5 import org.apache.hadoop.conf.Configuration;
6 import org.apache.hadoop.hbase.HBaseConfiguration;
7 import org.apache.hadoop.hbase.TableName;
8 import org.apache.hadoop.hbase.client.Connection;
9 import org.apache.hadoop.hbase.client.ConnectionFactory;
10 import org.apache.hadoop.hbase.client.HTable;
11 import org.apache.hadoop.hbase.client.Put;
12 import org.apache.hadoop.hbase.util.Bytes;
13
14 public class DataClient {
15
16 public static void main(String[] args) throws IOException {
17 //配置
18 Configuration conf = HBaseConfiguration.create();
19 conf.set("hbase.zookeeper.quorum", "master,data1,data2");
20 conf.set("hbase.zookeeper.property.clientPort", "2181");
21 //连接
22 Connection conn = ConnectionFactory.createConnection(conf);
23 HTable table = (HTable) conn.getTable(TableName.valueOf("initialtable"));
24 // 写入数据
25 Put put = new Put(Bytes.toBytes("row01"));
26 put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("name"), Bytes.toBytes("E"));
27 put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("value"), Bytes.toBytes("151"));
28 table.put(put);
29 // 关闭资源
30 table.close();
31 conn.close();
32
33 }
34
35 }
3> 创建需要的表
4> 加载协处理器
将服务端代码打包上传集群服务器的hdfs上
chown hadoop:hadoop datacode.jar chmod g+w datacode.jar hadoop dfs -put datacode.jar /input/
之后，将协处理器加载到初始表中
disable ‘initialtable‘ alter‘initialtable‘,METHOD =>‘table_att‘,‘coprocessor‘ =>‘/input/datacode.jar|com.observer.test.TestObserver|100‘ enable ‘initialtable‘
5> 执行客户端代码，显示结果
时间： 2024-10-14 04:59:26