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

Class SlowDiskTracker

java.lang.Object

org.apache.hadoop.hdfs.server.blockmanagement.SlowDiskTracker

@Private
@Unstable
public class SlowDiskTracker
extends Object

This class aggregates information from SlowDiskReports received via heartbeats.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SlowDiskTracker.DiskLatency	This structure is a thin wrapper over disk latencies.

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addSlowDiskReport(String dataNodeID, org.apache.hadoop.hdfs.server.protocol.SlowDiskReports dnSlowDiskReport)
void	checkAndUpdateReportIfNecessary()
static String	getSlowDiskIDForReport(String datanodeID, String slowDisk)
String	getSlowDiskReportAsJsonString()	Retrieve all valid reports as a JSON string.
void	updateSlowDiskReportAsync(long now)

Methods inherited from class java.lang.Object

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

Field Details

LOG

public static final org.slf4j.Logger LOG

Constructor Details

SlowDiskTracker

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

Method Details

getSlowDiskIDForReport

@VisibleForTesting
public static String getSlowDiskIDForReport(String datanodeID,
 String slowDisk)

addSlowDiskReport

public void addSlowDiskReport(String dataNodeID,
 org.apache.hadoop.hdfs.server.protocol.SlowDiskReports dnSlowDiskReport)

checkAndUpdateReportIfNecessary

public void checkAndUpdateReportIfNecessary()

updateSlowDiskReportAsync

@VisibleForTesting
public void updateSlowDiskReportAsync(long now)

getSlowDiskReportAsJsonString

public String getSlowDiskReportAsJsonString()

Retrieve all valid reports as a JSON string.

Returns:

serialized representation of valid reports. null if serialization failed.