Package | Description |
---|---|
alluxio.hub.manager.process | |
alluxio.hub.manager.util | |
alluxio.hub.proto |
Modifier and Type | Method and Description |
---|---|
<T> Map<HubNodeAddress,T> |
HubCluster.exec(Set<HubNodeAddress> hosts,
AlluxioConfiguration conf,
java.util.function.Function<AgentManagerServiceGrpc.AgentManagerServiceBlockingStub,T> action,
ExecutorService svc)
Execute an RPC action on all nodes in the cluster.
|
Modifier and Type | Method and Description |
---|---|
protected AgentManagerServiceGrpc.AgentManagerServiceBlockingStub |
AgentManagerServiceGrpc.AgentManagerServiceBlockingStub.build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
static AgentManagerServiceGrpc.AgentManagerServiceBlockingStub |
AgentManagerServiceGrpc.newBlockingStub(io.grpc.Channel channel)
Creates a new blocking-style stub that supports unary and streaming output calls on the service
|
Copyright © 2023. All Rights Reserved.