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

Class PipelineReportPublisher

java.lang.Object

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

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

All Implemented Interfaces:

Runnable

public class PipelineReportPublisher
extends ReportPublisher<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto>

Publishes Pipeline which will be sent to SCM as part of heartbeat. PipelineReport consist of the following information about each pipeline: - pipelineID - leaderID

Constructor Summary

Constructors

Constructor	Description
PipelineReportPublisher()

Method Summary

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

PipelineReportPublisher

public PipelineReportPublisher()

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

Returns:

report interval in milliseconds

getReport

protected org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto 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.PipelineReportsProto>

Returns:

datanode report