Package | Description |
---|---|
alluxio.hub.agent.process | |
alluxio.hub.manager.process | |
alluxio.hub.manager.util | |
alluxio.hub.proto |
Modifier and Type | Method and Description |
---|---|
protected HubNodeAddress |
AgentProcessContext.getNodeAddress() |
Modifier and Type | Method and Description |
---|---|
<T> Map<HubNodeAddress,T> |
ManagerProcessContext.execOnHub(java.util.function.Function<AgentManagerServiceGrpc.AgentManagerServiceBlockingStub,T> action)
Execute a function across all Hub agents.
|
<T> Map<HubNodeAddress,T> |
ManagerProcessContext.execOnHub(java.util.function.Function<AgentManagerServiceGrpc.AgentManagerServiceBlockingStub,T> action,
AlluxioNodeType type)
Execute a function across a set of Alluxio nodes on the cluster.
|
<T> Map<HubNodeAddress,T> |
ManagerProcessContext.execOnHub(java.util.function.Function<AgentManagerServiceGrpc.AgentManagerServiceBlockingStub,T> action,
AlluxioNodeType type,
ExecutionType executionType)
Execute a function across a set of Alluxio nodes on the cluster.
|
<T> Map<HubNodeAddress,T> |
ManagerProcessContext.execOnHub(java.util.function.Function<AgentManagerServiceGrpc.AgentManagerServiceBlockingStub,T> action,
String hostname)
Execute a function across a set of Alluxio nodes on the cluster.
|
Set<HubNodeAddress> |
ManagerProcessContext.updateConfigurationFor(AlluxioNodeType type,
AlluxioConfigurationSet conf)
Updates the configuration for a set of Alluxio nodes.
|
Modifier and Type | Method and Description |
---|---|
Set<HubNodeAddress> |
HubCluster.allNodes() |
<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.
|
Set<HubNodeAddress> |
HubCluster.nodesFromAlluxio(AlluxioCluster cluster,
AlluxioNodeType type)
Returns a set of Hub nodes corresponding to the given
AlluxioNodeType from an
AlluxioCluster . |
Modifier and Type | Method and Description |
---|---|
void |
HubCluster.add(HubNodeAddress addr)
Add a new node to the cluster.
|
void |
HubCluster.heartbeat(HubNodeAddress addr)
heartbeats to update the state of the node with the given address.
|
boolean |
HubCluster.remove(HubNodeAddress addr)
Removes a node from the cluster.
|
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 | Field and Description |
---|---|
static com.google.protobuf.Parser<HubNodeAddress> |
HubNodeAddress.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
HubNodeAddress |
HubNodeAddress.Builder.build() |
HubNodeAddress |
HubNodeAddress.Builder.buildPartial() |
static HubNodeAddress |
HubNodeAddress.getDefaultInstance() |
HubNodeAddress |
HubNodeAddress.getDefaultInstanceForType() |
HubNodeAddress |
HubNodeAddress.Builder.getDefaultInstanceForType() |
HubNodeAddress |
AgentHeartbeatRequestOrBuilder.getHubNode()
optional .alluxio.hub.proto.HubNodeAddress hub_node = 1; |
HubNodeAddress |
AgentHeartbeatRequest.getHubNode()
optional .alluxio.hub.proto.HubNodeAddress hub_node = 1; |
HubNodeAddress |
AgentHeartbeatRequest.Builder.getHubNode()
optional .alluxio.hub.proto.HubNodeAddress hub_node = 1; |
HubNodeAddress |
RegisterAgentRequest.getNode()
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
HubNodeAddress |
RegisterAgentRequest.Builder.getNode()
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
HubNodeAddress |
HubNodeStatusOrBuilder.getNode()
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
HubNodeAddress |
HubNodeStatus.getNode()
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
HubNodeAddress |
HubNodeStatus.Builder.getNode()
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
HubNodeAddress |
RegisterAgentRequestOrBuilder.getNode()
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
static HubNodeAddress |
HubNodeAddress.parseDelimitedFrom(InputStream input) |
static HubNodeAddress |
HubNodeAddress.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static HubNodeAddress |
HubNodeAddress.parseFrom(byte[] data) |
static HubNodeAddress |
HubNodeAddress.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static HubNodeAddress |
HubNodeAddress.parseFrom(ByteBuffer data) |
static HubNodeAddress |
HubNodeAddress.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static HubNodeAddress |
HubNodeAddress.parseFrom(com.google.protobuf.ByteString data) |
static HubNodeAddress |
HubNodeAddress.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static HubNodeAddress |
HubNodeAddress.parseFrom(com.google.protobuf.CodedInputStream input) |
static HubNodeAddress |
HubNodeAddress.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static HubNodeAddress |
HubNodeAddress.parseFrom(InputStream input) |
static HubNodeAddress |
HubNodeAddress.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<HubNodeAddress> |
HubNodeAddress.getParserForType() |
static com.google.protobuf.Parser<HubNodeAddress> |
HubNodeAddress.parser() |
Modifier and Type | Method and Description |
---|---|
HubNodeAddress.Builder |
HubNodeAddress.Builder.mergeFrom(HubNodeAddress other) |
AgentHeartbeatRequest.Builder |
AgentHeartbeatRequest.Builder.mergeHubNode(HubNodeAddress value)
optional .alluxio.hub.proto.HubNodeAddress hub_node = 1; |
RegisterAgentRequest.Builder |
RegisterAgentRequest.Builder.mergeNode(HubNodeAddress value)
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
HubNodeStatus.Builder |
HubNodeStatus.Builder.mergeNode(HubNodeAddress value)
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
static HubNodeAddress.Builder |
HubNodeAddress.newBuilder(HubNodeAddress prototype) |
AgentHeartbeatRequest.Builder |
AgentHeartbeatRequest.Builder.setHubNode(HubNodeAddress value)
optional .alluxio.hub.proto.HubNodeAddress hub_node = 1; |
RegisterAgentRequest.Builder |
RegisterAgentRequest.Builder.setNode(HubNodeAddress value)
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
HubNodeStatus.Builder |
HubNodeStatus.Builder.setNode(HubNodeAddress value)
optional .alluxio.hub.proto.HubNodeAddress node = 1; |
Copyright © 2023. All Rights Reserved.