【发布时间】:2015-09-12 11:00:56
【问题描述】:
我写了一个EndPoint服务器如下:
public class HelloWorldEndPoint extends ServerHelloworld.HelloWorld implements Coprocessor, CoprocessorService {
private RegionCoprocessorEnvironment env;
@Override
public void sendHello(RpcController controller, HelloRequest request,
RpcCallback<HelloResponse> done) {
System.out.println("request HelloRequest:" + request.getAskWord());
HelloResponse resp = HelloResponse.newBuilder().setRetWord(ByteString.copyFromUtf8("hello world!!!")).build();
done.run(resp);
}
@Override
public void question(RpcController controller, AskRequest request,
RpcCallback<AnsResponse> done) {
System.out.println("request question:" + request.getAsk());
AnsResponse resp = AnsResponse.newBuilder().setAns(ByteString.copyFromUtf8("helloworld," + request.getAsk().toStringUtf8())).build();
done.run(resp);
}
@Override
public Service getService() {
return this;
}
@Override
public void start(CoprocessorEnvironment env) throws IOException {
if (env instanceof RegionCoprocessorEnvironment) {
this.env = (RegionCoprocessorEnvironment) env;
} else {
throw new CoprocessorException("Must be loaded on a table region!");
}
}
}
问题是我看不到我的日志,比如:
System.out.println("request question:" + request.getAsk());
我不知道在哪里可以看到这个
【问题讨论】: