Package org.apache.hadoop.hdfs.server.datanode

Class DiskBalancerWorkStatus

java.lang.Object

org.apache.hadoop.hdfs.server.datanode.DiskBalancerWorkStatus

@Private
@Unstable
public class DiskBalancerWorkStatus
extends Object

Helper class that reports how much work has has been done by the node.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DiskBalancerWorkStatus.DiskBalancerWorkEntry	A class that is used to report each work item that we are working on.
static enum	DiskBalancerWorkStatus.Result	Various result values.

Constructor Summary

Constructors

Constructor	Description
DiskBalancerWorkStatus()	Constructs a default workStatus Object.
DiskBalancerWorkStatus(DiskBalancerWorkStatus.Result result, String planID, String planFile)	Constructs a workStatus Object.
DiskBalancerWorkStatus(DiskBalancerWorkStatus.Result result, String planID, String planFile, String currentState)	Constructs a workStatus Object.
DiskBalancerWorkStatus(DiskBalancerWorkStatus.Result result, String planID, List<DiskBalancerWorkStatus.DiskBalancerWorkEntry> currentState)	Constructs a workStatus Object.

Method Summary

Modifier and Type	Method	Description
void	addWorkEntry(DiskBalancerWorkStatus.DiskBalancerWorkEntry entry)	Adds a new work entry to the list.
String	currentStateString()	Return current state as a string.
List<DiskBalancerWorkStatus.DiskBalancerWorkEntry>	getCurrentState()	Gets current Status.
String	getPlanFile()	Returns planFile.
String	getPlanID()	Returns planID.
DiskBalancerWorkStatus.Result	getResult()	Returns result.
static DiskBalancerWorkStatus	parseJson(String json)	Returns a DiskBalancerWorkStatus object from the Json .
String	toJsonString()

Methods inherited from class java.lang.Object

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

Constructor Details

DiskBalancerWorkStatus

public DiskBalancerWorkStatus()

Constructs a default workStatus Object.

DiskBalancerWorkStatus

public DiskBalancerWorkStatus(DiskBalancerWorkStatus.Result result,
 String planID,
 String planFile)

Constructs a workStatus Object.

Parameters:

result - - int

planID - - Plan ID

planFile - - Plan file name

DiskBalancerWorkStatus

public DiskBalancerWorkStatus(DiskBalancerWorkStatus.Result result,
 String planID,
 List<DiskBalancerWorkStatus.DiskBalancerWorkEntry> currentState)

Constructs a workStatus Object.

Parameters:

result - - int

planID - - Plan ID

currentState - - Current State

DiskBalancerWorkStatus

public DiskBalancerWorkStatus(DiskBalancerWorkStatus.Result result,
 String planID,
 String planFile,
 String currentState)
                       throws IOException

Constructs a workStatus Object.

Parameters:

result - - int

planID - - Plan ID

currentState - - List of WorkEntries.

Throws:

IOException

Method Details

getResult

public DiskBalancerWorkStatus.Result getResult()

Returns result.

Returns:

long

getPlanID

public String getPlanID()

Returns planID.

Returns:

String

getPlanFile

public String getPlanFile()

Returns planFile.

Returns:

String

getCurrentState

public List<DiskBalancerWorkStatus.DiskBalancerWorkEntry> getCurrentState()

Gets current Status.

Returns:

- Json String

currentStateString

public String currentStateString()
                          throws IOException

Return current state as a string.

Throws:

IOException

toJsonString

public String toJsonString()
                    throws IOException

Throws:

IOException

parseJson

public static DiskBalancerWorkStatus parseJson(String json)
                                        throws IOException

Returns a DiskBalancerWorkStatus object from the Json .

Parameters:

json - - json String

Returns:

DiskBalancerWorkStatus

Throws:

IOException

addWorkEntry

public void addWorkEntry(DiskBalancerWorkStatus.DiskBalancerWorkEntry entry)

Adds a new work entry to the list.

Parameters:

entry - - DiskBalancerWorkEntry