AsyncTable.java 文件源码

/**
 * Execute a coprocessor call on the regions which are covered by a range.
 * <p>
 * Use the returned {@link CoprocessorServiceBuilder} construct your request and then execute it.
 * <p>
 * The {@code stubMaker} is just a delegation to the {@code xxxService.newStub} call. Usually it
 * is only a one line lambda expression, like:
 *
 * <pre>
 * <code>
 * channel -> xxxService.newStub(channel)
 * </code>
 * </pre>
 *
 * @param stubMaker a delegation to the actual {@code newStub} call.
 * @param callable a delegation to the actual protobuf rpc call. See the comment of
 *          {@link ServiceCaller} for more details.
 * @param callback callback to get the response. See the comment of {@link CoprocessorCallback}
 *          for more details.
 */
<S, R> CoprocessorServiceBuilder<S, R> coprocessorService(Function<RpcChannel, S> stubMaker,
    ServiceCaller<S, R> callable, CoprocessorCallback<R> callback);