public class TopologyDetails extends Object
Constructor and Description |
---|
TopologyDetails(String topologyId,
Map<String,Object> topologyConf,
StormTopology topology,
int numWorkers,
Map<ExecutorDetails,String> executorToComponents,
int launchTime,
String owner) |
TopologyDetails(String topologyId,
Map<String,Object> topologyConf,
StormTopology topology,
int numWorkers,
Map<ExecutorDetails,String> executorToComponents,
String owner) |
TopologyDetails(String topologyId,
Map<String,Object> topologyConf,
StormTopology topology,
int numWorkers,
String owner) |
Modifier and Type | Method and Description |
---|---|
void |
addResourcesForExec(ExecutorDetails exec,
NormalizedResourceRequest resourceList)
add resource requirements for a executor.
|
boolean |
equals(Object o) |
NormalizedResourceRequest |
getApproximateTotalResources()
Get an approximate total resources needed for this topology.
|
Map<String,Component> |
getComponents()
Returns a representation of the non-system components of the topology graph Each Component object in the returning map is populated with the list of its parents, children and execs assigned to that component.
|
Map<String,Object> |
getConf() |
Set<ExecutorDetails> |
getExecutors() |
Map<ExecutorDetails,String> |
getExecutorToComponent() |
String |
getId() |
int |
getLaunchTime()
Get the timestamp of when this topology was launched.
|
String |
getName() |
int |
getNumWorkers() |
Double |
getOffHeapMemoryRequirement(ExecutorDetails exec)
Gets the off heap memory requirement for a certain task within a topology.
|
Double |
getOnHeapMemoryRequirement(ExecutorDetails exec)
Gets the on heap memory requirement for a certain task within a topology.
|
double |
getRequestedNonSharedOffHeap() |
double |
getRequestedNonSharedOnHeap() |
double |
getRequestedSharedOffHeap() |
double |
getRequestedSharedOnHeap() |
Set<SharedMemory> |
getSharedMemoryRequests(Collection<ExecutorDetails> executors)
Gets the total memory resource list for a set of tasks that is part of a topology.
|
NormalizedResourceRequest |
getTaskResourceReqList(ExecutorDetails exec)
get the resources requirements for a executor.
|
StormTopology |
getTopology() |
int |
getTopologyPriority()
get the priority of this topology.
|
String |
getTopologySubmitter()
Get the user that submitted this topology.
|
Double |
getTopologyWorkerMaxHeapSize()
Get the max heap size for a worker used by this topology.
|
Double |
getTotalCpuReqTask(ExecutorDetails exec)
Get the total CPU requirement for executor.
|
Double |
getTotalMemReqTask(ExecutorDetails exec)
Gets the total memory requirement for a task.
|
double |
getTotalRequestedCpu()
Note: The public API relevant to resource aware scheduling is unstable as of May 2015.
|
double |
getTotalRequestedMemOffHeap()
Note: The public API relevant to resource aware scheduling is unstable as of May 2015.
|
double |
getTotalRequestedMemOnHeap()
Note: The public API relevant to resource aware scheduling is unstable as of May 2015.
|
NormalizedResourceRequest |
getTotalResources(ExecutorDetails exec)
Get the total resource requirement for an executor.
|
int |
getUpTime()
Get how long this topology has been executing.
|
boolean |
hasExecInTopo(ExecutorDetails exec)
Checks if a executor is part of this topology.
|
int |
hashCode() |
Map<ExecutorDetails,String> |
selectExecutorToComponent(Collection<ExecutorDetails> executors) |
String |
toString() |
public TopologyDetails(String topologyId, Map<String,Object> topologyConf, StormTopology topology, int numWorkers, String owner)
public TopologyDetails(String topologyId, Map<String,Object> topologyConf, StormTopology topology, int numWorkers, Map<ExecutorDetails,String> executorToComponents, String owner)
public TopologyDetails(String topologyId, Map<String,Object> topologyConf, StormTopology topology, int numWorkers, Map<ExecutorDetails,String> executorToComponents, int launchTime, String owner)
public String getId()
public String getName()
public int getNumWorkers()
public StormTopology getTopology()
public Map<ExecutorDetails,String> getExecutorToComponent()
public Map<ExecutorDetails,String> selectExecutorToComponent(Collection<ExecutorDetails> executors)
public Set<ExecutorDetails> getExecutors()
public Map<String,Component> getComponents()
Returns a representation of the non-system components of the topology graph Each Component object in the returning map is populated with the list of its parents, children and execs assigned to that component.
public Double getOnHeapMemoryRequirement(ExecutorDetails exec)
Gets the on heap memory requirement for a certain task within a topology.
exec
- the executor the inquiry is concerning.public Double getOffHeapMemoryRequirement(ExecutorDetails exec)
Gets the off heap memory requirement for a certain task within a topology.
exec
- the executor the inquiry is concerning.public Double getTotalMemReqTask(ExecutorDetails exec)
Gets the total memory requirement for a task.
exec
- the executor the inquiry is concerning.public Set<SharedMemory> getSharedMemoryRequests(Collection<ExecutorDetails> executors)
Gets the total memory resource list for a set of tasks that is part of a topology.
executors
- all executors for a topologypublic NormalizedResourceRequest getTotalResources(ExecutorDetails exec)
Get the total resource requirement for an executor.
exec
- the executor to get the resources for.public NormalizedResourceRequest getApproximateTotalResources()
Get an approximate total resources needed for this topology.
public Double getTotalCpuReqTask(ExecutorDetails exec)
Get the total CPU requirement for executor.
exec
- public double getTotalRequestedMemOnHeap()
Note: The public API relevant to resource aware scheduling is unstable as of May 2015. We reserve the right to change them.
public double getRequestedSharedOnHeap()
public double getRequestedNonSharedOnHeap()
public double getTotalRequestedMemOffHeap()
Note: The public API relevant to resource aware scheduling is unstable as of May 2015. We reserve the right to change them.
public double getRequestedNonSharedOffHeap()
public double getRequestedSharedOffHeap()
public double getTotalRequestedCpu()
Note: The public API relevant to resource aware scheduling is unstable as of May 2015. We reserve the right to change them.
public NormalizedResourceRequest getTaskResourceReqList(ExecutorDetails exec)
get the resources requirements for a executor.
exec
- executor detailspublic boolean hasExecInTopo(ExecutorDetails exec)
Checks if a executor is part of this topology.
public void addResourcesForExec(ExecutorDetails exec, NormalizedResourceRequest resourceList)
add resource requirements for a executor.
public Double getTopologyWorkerMaxHeapSize()
Get the max heap size for a worker used by this topology.
public String getTopologySubmitter()
Get the user that submitted this topology.
public int getTopologyPriority()
get the priority of this topology.
public int getLaunchTime()
Get the timestamp of when this topology was launched.
public int getUpTime()
Get how long this topology has been executing.
Copyright © 2022 The Apache Software Foundation. All rights reserved.