Package org.apache.hadoop.hdfs.server.blockmanagement

Class SlowPeerDisabledTracker

java.lang.Object

org.apache.hadoop.hdfs.server.blockmanagement.SlowPeerTracker

org.apache.hadoop.hdfs.server.blockmanagement.SlowPeerDisabledTracker

@Private
public class SlowPeerDisabledTracker
extends SlowPeerTracker

Disabled tracker for slow peers. To be used when dfs.datanode.peer.stats.enabled is disabled.

Constructor Summary

Constructors

Constructor	Description
SlowPeerDisabledTracker(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.util.Timer timer)

Method Summary

Modifier and Type	Method	Description
void	addReport(String slowNode, String reportingNode, org.apache.hadoop.hdfs.server.protocol.OutlierMetrics slowNodeMetrics)	Add a new report.
String	getJson()	Retrieve all valid reports as a JSON string.
Map<String,SortedSet<org.apache.hadoop.hdfs.server.blockmanagement.SlowPeerLatencyWithReportingNode>>	getReportsForAllDataNodes()	Retrieve all reports for all nodes.
Set<org.apache.hadoop.hdfs.server.blockmanagement.SlowPeerLatencyWithReportingNode>	getReportsForNode(String slowNode)	Retrieve the non-expired reports that mark a given DataNode as slow.
List<String>	getSlowNodes(int numNodes)	Returns all tracking slow peers.
boolean	isSlowPeerTrackerEnabled()	If SlowPeerTracker is enabled, return true, else returns false.

Methods inherited from class org.apache.hadoop.hdfs.server.blockmanagement.SlowPeerTracker

setMaxSlowPeersToReport

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SlowPeerDisabledTracker

public SlowPeerDisabledTracker(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.util.Timer timer)

Method Details

isSlowPeerTrackerEnabled

public boolean isSlowPeerTrackerEnabled()

Description copied from class: SlowPeerTracker

If SlowPeerTracker is enabled, return true, else returns false.

Overrides:

isSlowPeerTrackerEnabled in class SlowPeerTracker

Returns:

true if slow peer tracking is enabled, else false.

addReport

public void addReport(String slowNode,
 String reportingNode,
 org.apache.hadoop.hdfs.server.protocol.OutlierMetrics slowNodeMetrics)

Description copied from class: SlowPeerTracker

Add a new report. DatanodeIds can be the DataNodeIds or addresses We don't care as long as the caller is consistent.

Overrides:

addReport in class SlowPeerTracker

Parameters:

slowNode - DataNodeId of the peer suspected to be slow.

reportingNode - DataNodeId of the node reporting on its peer.

slowNodeMetrics - Aggregate latency metrics of slownode as reported by the reporting node.

getReportsForNode

public Set<org.apache.hadoop.hdfs.server.blockmanagement.SlowPeerLatencyWithReportingNode> getReportsForNode(String slowNode)

Description copied from class: SlowPeerTracker

Retrieve the non-expired reports that mark a given DataNode as slow. Stale reports are excluded.

Overrides:

getReportsForNode in class SlowPeerTracker

Parameters:

slowNode - target node Id.

Returns:

set of reports which implicate the target node as being slow.

getReportsForAllDataNodes

public Map<String,SortedSet<org.apache.hadoop.hdfs.server.blockmanagement.SlowPeerLatencyWithReportingNode>> getReportsForAllDataNodes()

Description copied from class: SlowPeerTracker

Retrieve all reports for all nodes. Stale reports are excluded.

Overrides:

getReportsForAllDataNodes in class SlowPeerTracker

Returns:

map from SlowNodeId -> (set of nodes reporting peers).

getJson

public String getJson()

Description copied from class: SlowPeerTracker

Retrieve all valid reports as a JSON string.

Overrides:

getJson in class SlowPeerTracker

Returns:

serialized representation of valid reports. null if serialization failed.

getSlowNodes

public List<String> getSlowNodes(int numNodes)

Description copied from class: SlowPeerTracker

Returns all tracking slow peers.

Overrides:

getSlowNodes in class SlowPeerTracker

Returns: