1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.coprocessor;
20
21 import com.google.protobuf.RpcCallback;
22 import com.google.protobuf.RpcController;
23 import com.google.protobuf.Service;
24 import org.apache.hadoop.hbase.Coprocessor;
25 import org.apache.hadoop.hbase.CoprocessorEnvironment;
26 import org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos;
27 import org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos;
28 import org.apache.hadoop.hbase.protobuf.ResponseConverter;
29
30 import java.io.IOException;
31
32
33
34
35
36
37 public class ProtobufCoprocessorService
38 extends TestRpcServiceProtos.TestProtobufRpcProto
39 implements CoprocessorService, Coprocessor {
40 public ProtobufCoprocessorService() {
41 }
42
43 @Override
44 public Service getService() {
45 return this;
46 }
47
48 @Override
49 public void ping(RpcController controller, TestProtos.EmptyRequestProto request,
50 RpcCallback<TestProtos.EmptyResponseProto> done) {
51 done.run(TestProtos.EmptyResponseProto.getDefaultInstance());
52 }
53
54 @Override
55 public void echo(RpcController controller, TestProtos.EchoRequestProto request,
56 RpcCallback<TestProtos.EchoResponseProto> done) {
57 String message = request.getMessage();
58 done.run(TestProtos.EchoResponseProto.newBuilder().setMessage(message).build());
59 }
60
61 @Override
62 public void error(RpcController controller, TestProtos.EmptyRequestProto request,
63 RpcCallback<TestProtos.EmptyResponseProto> done) {
64 ResponseConverter.setControllerException(controller, new IOException("Test exception"));
65 done.run(null);
66 }
67
68 @Override
69 public void start(CoprocessorEnvironment env) throws IOException {
70
71 }
72
73 @Override
74 public void stop(CoprocessorEnvironment env) throws IOException {
75
76 }
77 }