Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Method and Description |
---|---|
protected <T extends org.apache.hbase.thirdparty.com.google.protobuf.Message> |
AbstractRpcBasedConnectionRegistry.call(AbstractRpcBasedConnectionRegistry.Callable<T> callable,
Predicate<T> isValidResp,
String debug) |
private <T extends org.apache.hbase.thirdparty.com.google.protobuf.Message> |
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> |
AbstractRpcBasedConnectionRegistry.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.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.