Package org.apache.hadoop.ozone.container.common.states.endpoint

Class HeartbeatEndpointTask

java.lang.Object

org.apache.hadoop.ozone.container.common.states.endpoint.HeartbeatEndpointTask

All Implemented Interfaces:

Callable<EndpointStateMachine.EndPointStates>

public class HeartbeatEndpointTask
extends Object
implements Callable<EndpointStateMachine.EndPointStates>

Heartbeat class for SCMs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HeartbeatEndpointTask.Builder	Builder class for HeartbeatEndpointTask.

Constructor Summary

Constructors

Constructor	Description
HeartbeatEndpointTask(EndpointStateMachine rpcEndpoint, org.apache.hadoop.hdds.conf.ConfigurationSource conf, StateContext context, org.apache.hadoop.hdds.upgrade.HDDSLayoutVersionManager versionManager)	Constructs a SCM heart beat.

Method Summary

Modifier and Type	Method	Description
EndpointStateMachine.EndPointStates	call()	Computes a result, or throws an exception if unable to do so.
org.apache.hadoop.hdds.protocol.proto.HddsProtos.DatanodeDetailsProto	getDatanodeDetailsProto()	Get the container Node ID proto.
static HeartbeatEndpointTask.Builder	newBuilder()	Returns a builder class for HeartbeatEndpointTask task.
void	setDatanodeDetailsProto(org.apache.hadoop.hdds.protocol.proto.HddsProtos.DatanodeDetailsProto datanodeDetailsProto)	Set container node ID proto.

Methods inherited from class java.lang.Object

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

Constructor Details

HeartbeatEndpointTask

public HeartbeatEndpointTask(EndpointStateMachine rpcEndpoint,
 org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 StateContext context,
 org.apache.hadoop.hdds.upgrade.HDDSLayoutVersionManager versionManager)

Constructs a SCM heart beat.

Parameters:

rpcEndpoint - rpc Endpoint

conf - Config.

context - State context

versionManager - Layout version Manager

Method Details

getDatanodeDetailsProto

public org.apache.hadoop.hdds.protocol.proto.HddsProtos.DatanodeDetailsProto getDatanodeDetailsProto()

Get the container Node ID proto.

Returns:

ContainerNodeIDProto

setDatanodeDetailsProto

public void setDatanodeDetailsProto(org.apache.hadoop.hdds.protocol.proto.HddsProtos.DatanodeDetailsProto datanodeDetailsProto)

Set container node ID proto.

Parameters:

datanodeDetailsProto - - the node id.

call

public EndpointStateMachine.EndPointStates call()
                                         throws Exception

Computes a result, or throws an exception if unable to do so.

Specified by:

call in interface Callable<EndpointStateMachine.EndPointStates>

Returns:

computed result

Throws:

Exception - if unable to compute a result

newBuilder

public static HeartbeatEndpointTask.Builder newBuilder()

Returns a builder class for HeartbeatEndpointTask task.

Returns:

Builder.