Package org.apache.hadoop.ozone.protocol

Interface StorageContainerDatanodeProtocol

All Known Subinterfaces:

ReconDatanodeProtocol

All Known Implementing Classes:

StorageContainerDatanodeProtocolClientSideTranslatorPB

@Private
public interface StorageContainerDatanodeProtocol

The protocol spoken between datanodes and SCM. For specifics please the Protoc file that defines this protocol.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	versionID

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMVersionResponseProto	getVersion(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMVersionRequestProto versionRequest)	Returns SCM version.
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMRegisteredResponseProto	register(org.apache.hadoop.hdds.protocol.proto.HddsProtos.ExtendedDatanodeDetailsProto extendedDatanodeDetailsProto, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto nodeReport, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReportsProto containerReportsRequestProto, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto pipelineReports, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.LayoutVersionProto layoutInfo)	Register Datanode.
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMHeartbeatResponseProto	sendHeartbeat(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMHeartbeatRequestProto heartbeat)	Used by data node to send a Heartbeat.

Field Details

versionID

static final long versionID

See Also:

• Constant Field Values

Method Details

getVersion

org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMVersionResponseProto getVersion(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMVersionRequestProto versionRequest)
                                                                                                         throws IOException

Returns SCM version.

Returns:

Version info.

Throws:

IOException

sendHeartbeat

org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMHeartbeatResponseProto sendHeartbeat(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMHeartbeatRequestProto heartbeat)
                                                                                                              throws IOException,
TimeoutException

Used by data node to send a Heartbeat.

Parameters:

heartbeat - Heartbeat

Returns:

- SCMHeartbeatResponseProto

Throws:

IOException

TimeoutException

register

org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMRegisteredResponseProto register(org.apache.hadoop.hdds.protocol.proto.HddsProtos.ExtendedDatanodeDetailsProto extendedDatanodeDetailsProto,
 org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto nodeReport,
 org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReportsProto containerReportsRequestProto,
 org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto pipelineReports,
 org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.LayoutVersionProto layoutInfo)
                                                                                                          throws IOException

Register Datanode.

Parameters:

extendedDatanodeDetailsProto - - extended Datanode Details.

nodeReport - - Node Report.

containerReportsRequestProto - - Container Reports.

layoutInfo - - Layout Version Information.

Returns:

SCM Command.

Throws:

IOException