Java 类org.apache.hadoop.hbase.ipc.MasterCoprocessorRpcChannel 实例源码

项目：ditb 文件：HBaseAdmin.java

/**
 * Creates and returns a {@link com.google.protobuf.RpcChannel} instance
 * connected to the active master.
 *
 * <p>
 * The obtained {@link com.google.protobuf.RpcChannel} instance can be used to access a published
 * coprocessor {@link com.google.protobuf.Service} using standard protobuf service invocations:
 * </p>
 *
 * <div style="background-color: #cccccc; padding: 2px">
 * <blockquote><pre>
 * CoprocessorRpcChannel channel = myAdmin.coprocessorService();
 * MyService.BlockingInterface service = MyService.newBlockingStub(channel);
 * MyCallRequest request = MyCallRequest.newBuilder()
 *     ...
 *     .build();
 * MyCallResponse response = service.myCall(null, request);
 * </pre></blockquote></div>
 *
 * @return A MasterCoprocessorRpcChannel instance
 */
@Override
public CoprocessorRpcChannel coprocessorService() {
  return new MasterCoprocessorRpcChannel(connection);
}

项目：pbase 文件：HBaseAdmin.java

/**
 * Creates and returns a {@link com.google.protobuf.RpcChannel} instance
 * connected to the active master.
 *
 * <p>
 * The obtained {@link com.google.protobuf.RpcChannel} instance can be used to access a published
 * coprocessor {@link com.google.protobuf.Service} using standard protobuf service invocations:
 * </p>
 *
 * <div style="background-color: #cccccc; padding: 2px">
 * <blockquote><pre>
 * CoprocessorRpcChannel channel = myAdmin.coprocessorService();
 * MyService.BlockingInterface service = MyService.newBlockingStub(channel);
 * MyCallRequest request = MyCallRequest.newBuilder()
 *     ...
 *     .build();
 * MyCallResponse response = service.myCall(null, request);
 * </pre></blockquote></div>
 *
 * @return A MasterCoprocessorRpcChannel instance
 */
@Override
public CoprocessorRpcChannel coprocessorService() {
  return new MasterCoprocessorRpcChannel(connection);
}

项目：HIndex 文件：HBaseAdmin.java

/**
 * Creates and returns a {@link com.google.protobuf.RpcChannel} instance
 * connected to the active master.
 *
 * <p>
 * The obtained {@link com.google.protobuf.RpcChannel} instance can be used to access a published
 * coprocessor {@link com.google.protobuf.Service} using standard protobuf service invocations:
 * </p>
 *
 * <div style="background-color: #cccccc; padding: 2px">
 * <blockquote><pre>
 * CoprocessorRpcChannel channel = myAdmin.coprocessorService();
 * MyService.BlockingInterface service = MyService.newBlockingStub(channel);
 * MyCallRequest request = MyCallRequest.newBuilder()
 *     ...
 *     .build();
 * MyCallResponse response = service.myCall(null, request);
 * </pre></blockquote></div>
 *
 * @return A MasterCoprocessorRpcChannel instance
 */
public CoprocessorRpcChannel coprocessorService() {
  return new MasterCoprocessorRpcChannel(connection);
}

项目：PyroDB 文件：HBaseAdmin.java

/**
 * Creates and returns a {@link com.google.protobuf.RpcChannel} instance
 * connected to the active master.
 *
 * <p>
 * The obtained {@link com.google.protobuf.RpcChannel} instance can be used to access a published
 * coprocessor {@link com.google.protobuf.Service} using standard protobuf service invocations:
 * </p>
 *
 * <div style="background-color: #cccccc; padding: 2px">
 * <blockquote><pre>
 * CoprocessorRpcChannel channel = myAdmin.coprocessorService();
 * MyService.BlockingInterface service = MyService.newBlockingStub(channel);
 * MyCallRequest request = MyCallRequest.newBuilder()
 *     ...
 *     .build();
 * MyCallResponse response = service.myCall(null, request);
 * </pre></blockquote></div>
 *
 * @return A MasterCoprocessorRpcChannel instance
 */
public CoprocessorRpcChannel coprocessorService() {
  return new MasterCoprocessorRpcChannel(connection);
}

项目：c5 文件：HBaseAdmin.java

/**
 * Creates and returns a {@link com.google.protobuf.RpcChannel} instance
 * connected to the active master.
 *
 * <p>
 * The obtained {@link com.google.protobuf.RpcChannel} instance can be used to access a published
 * coprocessor {@link com.google.protobuf.Service} using standard protobuf service invocations:
 * </p>
 *
 * <div style="background-color: #cccccc; padding: 2px">
 * <blockquote><pre>
 * CoprocessorRpcChannel channel = myAdmin.coprocessorService();
 * MyService.BlockingInterface service = MyService.newBlockingStub(channel);
 * MyCallRequest request = MyCallRequest.newBuilder()
 *     ...
 *     .build();
 * MyCallResponse response = service.myCall(null, request);
 * </pre></blockquote></div>
 *
 * @return A MasterCoprocessorRpcChannel instance
 */
public CoprocessorRpcChannel coprocessorService() {
  return new MasterCoprocessorRpcChannel(connection);
}

项目：DominoHBase 文件：HBaseAdmin.java

/**
 * Creates and returns a {@link com.google.protobuf.RpcChannel} instance
 * connected to the active master.
 *
 * <p>
 * The obtained {@link com.google.protobuf.RpcChannel} instance can be used to access a published
 * coprocessor {@link com.google.protobuf.Service} using standard protobuf service invocations:
 * </p>
 *
 * <div style="background-color: #cccccc; padding: 2px">
 * <blockquote><pre>
 * CoprocessorRpcChannel channel = myAdmin.coprocessorService();
 * MyService.BlockingInterface service = MyService.newBlockingStub(channel);
 * MyCallRequest request = MyCallRequest.newBuilder()
 *     ...
 *     .build();
 * MyCallResponse response = service.myCall(null, request);
 * </pre></blockquote></div>
 *
 * @return A MasterCoprocessorRpcChannel instance
 */
public CoprocessorRpcChannel coprocessorService() {
  return new MasterCoprocessorRpcChannel(connection);
}