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

Class NodeReportPublisher

java.lang.Object

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

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

All Implemented Interfaces:

Runnable

public class NodeReportPublisher
extends ReportPublisher<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto>

Publishes NodeReport which will be sent to SCM as part of heartbeat. NodeReport consist of: - NodeIOStats - VolumeReports

Constructor Summary

Constructors

Constructor	Description
NodeReportPublisher()

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto	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

NodeReportPublisher

public NodeReportPublisher()

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.NodeReportProto>

Returns:

report interval in milliseconds

getReport

protected org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto getReport()
                                                                                                          throws IOException

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.NodeReportProto>

Returns:

datanode report

Throws:

IOException