Uses of Interface
org.apache.hadoop.hbase.client.AbstractRpcBasedConnectionRegistry.Callable
-
Uses of AbstractRpcBasedConnectionRegistry.Callable in org.apache.hadoop.hbase.client
Modifier and TypeMethodDescriptionprotected final <T extends org.apache.hbase.thirdparty.com.google.protobuf.Message>
CompletableFuture<T>AbstractRpcBasedConnectionRegistry.call
(AbstractRpcBasedConnectionRegistry.Callable<T> callable, Predicate<T> isValidResp, String debug) private <T extends org.apache.hbase.thirdparty.com.google.protobuf.Message>
CompletableFuture<T>AbstractRpcBasedConnectionRegistry.call
(org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface stub, AbstractRpcBasedConnectionRegistry.Callable<T> callable) private <T extends org.apache.hbase.thirdparty.com.google.protobuf.Message>
voidAbstractRpcBasedConnectionRegistry.groupCall
(CompletableFuture<T> future, Set<ServerName> servers, List<org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface> stubs, int startIndexInclusive, AbstractRpcBasedConnectionRegistry.Callable<T> callable, Predicate<T> isValidResp, String debug, ConcurrentLinkedQueue<Throwable> errors) send requests concurrently to hedgedReadsFanout end points.