Package org.apache.hadoop.ozone.container.common.report

Class CommandStatusReportPublisher

java.lang.Object

org.apache.hadoop.ozone.container.common.report.ReportPublisher<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.CommandStatusReportsProto>

org.apache.hadoop.ozone.container.common.report.CommandStatusReportPublisher

All Implemented Interfaces:

Runnable

public class CommandStatusReportPublisher
extends ReportPublisher<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.CommandStatusReportsProto>

Publishes CommandStatusReport which will be sent to SCM as part of heartbeat. CommandStatusReport consist of the following information: - type : type of command. - status : status of command execution (PENDING, EXECUTED, FAILURE). - cmdId : Command id. - msg : optional message.

Constructor Summary

Constructors

Constructor	Description
CommandStatusReportPublisher()

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.CommandStatusReportsProto	getReport()	Generate and returns the report which has to be sent as part of heartbeat.
protected long	getReportFrequency()	Returns the frequency in which this particular report has to be scheduled.

Methods inherited from class org.apache.hadoop.ozone.container.common.report.ReportPublisher

getConf, getContext, init, run, setConf

Methods inherited from class java.lang.Object

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

Constructor Details

CommandStatusReportPublisher

public CommandStatusReportPublisher()

Method Details

getReportFrequency

protected long getReportFrequency()

Description copied from class: ReportPublisher

Returns the frequency in which this particular report has to be scheduled.

Specified by:

getReportFrequency in class ReportPublisher<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.CommandStatusReportsProto>

Returns:

report interval in milliseconds

getReport

protected org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.CommandStatusReportsProto getReport()

Description copied from class: ReportPublisher

Generate and returns the report which has to be sent as part of heartbeat.

Specified by:

getReport in class ReportPublisher<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.CommandStatusReportsProto>

Returns:

datanode report