Package | Description |
---|---|
alluxio.hub.agent.process | |
alluxio.hub.agent.util.process | |
alluxio.hub.manager.process | |
alluxio.hub.manager.util | |
alluxio.hub.proto |
Modifier and Type | Method and Description |
---|---|
Set<AlluxioNodeType> |
AgentProcessContext.alluxioProcesses() |
Modifier and Type | Method and Description |
---|---|
void |
AgentProcessContext.changeState(AlluxioNodeType type,
ProcessStateChange action)
Attempts to change the state of a process.
|
Modifier and Type | Method and Description |
---|---|
AlluxioProcessStatus |
NodeStatus.getProcessStatus(AlluxioNodeType type)
Get the current process status.
|
void |
ProcessLauncher.start(AlluxioNodeType type)
Starts an Alluxio process of the given type.
|
void |
ProcessLauncher.stop(AlluxioNodeType type)
Stop an Alluxio process of the given type.
|
Modifier and Type | Method and Description |
---|---|
AlluxioConfigurationSet |
ManagerProcessContext.configurationSetFor(AlluxioNodeType type)
Gets the configuration for a given alluxio node type.
|
<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.
|
Set<HubNodeAddress> |
ManagerProcessContext.updateConfigurationFor(AlluxioNodeType type,
AlluxioConfigurationSet conf)
Updates the configuration for a set of Alluxio nodes.
|
Modifier and Type | Method and Description |
---|---|
Map<AlluxioNodeType,ProcessState> |
AlluxioCluster.heartbeat(AlluxioNodeStatusOrBuilder addr)
Add a new node to the cluster.
|
Map<AlluxioNodeType,ProcessState> |
AlluxioCluster.remove(AlluxioNodeStatusOrBuilder addr)
Remove a node from the cluster with the address's hostname.
|
Map<AlluxioNodeType,ProcessState> |
AlluxioCluster.remove(String hostname)
Remove a node from the cluster.
|
Modifier and Type | Method and Description |
---|---|
Set<String> |
AlluxioCluster.getNodeType(AlluxioNodeType type)
Gets a set of node hostnames which correspond to a given
AlluxioNodeType . |
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 |
---|---|
static AlluxioNodeType |
AlluxioNodeType.forNumber(int value) |
AlluxioNodeType |
UploadFileOrBuilder.getDestination()
optional .alluxio.hub.proto.AlluxioNodeType destination = 4; |
AlluxioNodeType |
UploadFile.getDestination()
optional .alluxio.hub.proto.AlluxioNodeType destination = 4; |
AlluxioNodeType |
UploadFile.Builder.getDestination()
optional .alluxio.hub.proto.AlluxioNodeType destination = 4; |
AlluxioNodeType |
RemoveFile.getLocation()
optional .alluxio.hub.proto.AlluxioNodeType location = 2; |
AlluxioNodeType |
RemoveFile.Builder.getLocation()
optional .alluxio.hub.proto.AlluxioNodeType location = 2; |
AlluxioNodeType |
RemoveFileOrBuilder.getLocation()
optional .alluxio.hub.proto.AlluxioNodeType location = 2; |
AlluxioNodeType |
ListFileOrBuilder.getLocation()
optional .alluxio.hub.proto.AlluxioNodeType location = 2; |
AlluxioNodeType |
ListFile.getLocation()
optional .alluxio.hub.proto.AlluxioNodeType location = 2; |
AlluxioNodeType |
ListFile.Builder.getLocation()
optional .alluxio.hub.proto.AlluxioNodeType location = 2; |
AlluxioNodeType |
GetConfigurationSetRequest.PayloadOrBuilder.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
GetConfigurationSetRequest.Payload.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
GetConfigurationSetRequest.Payload.Builder.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
AgentGetConfigurationSetRequestOrBuilder.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
AgentGetConfigurationSetRequest.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
AgentGetConfigurationSetRequest.Builder.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
AgentProcessStatusChangeRequestOrBuilder.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioNodeType |
AgentProcessStatusChangeRequest.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioNodeType |
AgentProcessStatusChangeRequest.Builder.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioNodeType |
AlluxioProcessStatusOrBuilder.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
AlluxioProcessStatus.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
AlluxioProcessStatus.Builder.getNodeType()
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AlluxioNodeType |
WriteConfigurationSetRequest.PayloadOrBuilder.getNodeType(int index)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioNodeType |
WriteConfigurationSetRequest.Payload.getNodeType(int index)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioNodeType |
WriteConfigurationSetRequest.Payload.Builder.getNodeType(int index)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioNodeType |
AgentWriteConfigurationSetRequestOrBuilder.getNodeType(int index)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioNodeType |
AgentWriteConfigurationSetRequest.getNodeType(int index)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioNodeType |
AgentWriteConfigurationSetRequest.Builder.getNodeType(int index)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
static AlluxioNodeType |
AlluxioNodeType.valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static AlluxioNodeType |
AlluxioNodeType.valueOf(int value)
Deprecated.
Use
forNumber(int) instead. |
static AlluxioNodeType |
AlluxioNodeType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AlluxioNodeType[] |
AlluxioNodeType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
List<AlluxioNodeType> |
WriteConfigurationSetRequest.PayloadOrBuilder.getNodeTypeList()
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
List<AlluxioNodeType> |
WriteConfigurationSetRequest.Payload.getNodeTypeList()
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
List<AlluxioNodeType> |
WriteConfigurationSetRequest.Payload.Builder.getNodeTypeList()
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
List<AlluxioNodeType> |
AgentWriteConfigurationSetRequestOrBuilder.getNodeTypeList()
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
List<AlluxioNodeType> |
AgentWriteConfigurationSetRequest.getNodeTypeList()
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
List<AlluxioNodeType> |
AgentWriteConfigurationSetRequest.Builder.getNodeTypeList()
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
static com.google.protobuf.Internal.EnumLiteMap<AlluxioNodeType> |
AlluxioNodeType.internalGetValueMap() |
Modifier and Type | Method and Description |
---|---|
WriteConfigurationSetRequest.Payload.Builder |
WriteConfigurationSetRequest.Payload.Builder.addNodeType(AlluxioNodeType value)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AgentWriteConfigurationSetRequest.Builder |
AgentWriteConfigurationSetRequest.Builder.addNodeType(AlluxioNodeType value)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
UploadFile.Builder |
UploadFile.Builder.setDestination(AlluxioNodeType value)
optional .alluxio.hub.proto.AlluxioNodeType destination = 4; |
RemoveFile.Builder |
RemoveFile.Builder.setLocation(AlluxioNodeType value)
optional .alluxio.hub.proto.AlluxioNodeType location = 2; |
ListFile.Builder |
ListFile.Builder.setLocation(AlluxioNodeType value)
optional .alluxio.hub.proto.AlluxioNodeType location = 2; |
GetConfigurationSetRequest.Payload.Builder |
GetConfigurationSetRequest.Payload.Builder.setNodeType(AlluxioNodeType value)
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AgentGetConfigurationSetRequest.Builder |
AgentGetConfigurationSetRequest.Builder.setNodeType(AlluxioNodeType value)
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
AgentProcessStatusChangeRequest.Builder |
AgentProcessStatusChangeRequest.Builder.setNodeType(AlluxioNodeType value)
optional .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AlluxioProcessStatus.Builder |
AlluxioProcessStatus.Builder.setNodeType(AlluxioNodeType value)
optional .alluxio.hub.proto.AlluxioNodeType node_type = 1; |
WriteConfigurationSetRequest.Payload.Builder |
WriteConfigurationSetRequest.Payload.Builder.setNodeType(int index,
AlluxioNodeType value)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AgentWriteConfigurationSetRequest.Builder |
AgentWriteConfigurationSetRequest.Builder.setNodeType(int index,
AlluxioNodeType value)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
Modifier and Type | Method and Description |
---|---|
WriteConfigurationSetRequest.Payload.Builder |
WriteConfigurationSetRequest.Payload.Builder.addAllNodeType(Iterable<? extends AlluxioNodeType> values)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
AgentWriteConfigurationSetRequest.Builder |
AgentWriteConfigurationSetRequest.Builder.addAllNodeType(Iterable<? extends AlluxioNodeType> values)
repeated .alluxio.hub.proto.AlluxioNodeType node_type = 2; |
Copyright © 2023. All Rights Reserved.