Package org.apache.hadoop.hdfs.server.federation.store.records.impl.pb

Class MembershipStatePBImpl

java.lang.Object

org.apache.hadoop.hdfs.server.federation.store.records.BaseRecord

org.apache.hadoop.hdfs.server.federation.store.records.MembershipState

org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.MembershipStatePBImpl

All Implemented Interfaces:

Comparable<BaseRecord>, FederationNamenodeContext, PBRecord

public class MembershipStatePBImpl
extends MembershipState
implements PBRecord

Protobuf implementation of the MembershipState record.

Field Summary

Fields inherited from class org.apache.hadoop.hdfs.server.federation.store.records.MembershipState

ERROR_MSG_NO_BP_SPECIFIED, ERROR_MSG_NO_NS_SPECIFIED, ERROR_MSG_NO_RPC_ADDR_SPECIFIED, ERROR_MSG_NO_WEB_ADDR_SPECIFIED, NAME_COMPARATOR

Fields inherited from class org.apache.hadoop.hdfs.server.federation.store.records.BaseRecord

ERROR_MSG_CREATION_TIME_NEGATIVE, ERROR_MSG_MODIFICATION_TIME_NEGATIVE

Constructor Summary

Constructors

Constructor	Description
MembershipStatePBImpl()
MembershipStatePBImpl(org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeMembershipRecordProto proto)

Method Summary

Modifier and Type	Method	Description
String	getBlockPoolId()
String	getClusterId()
long	getDateCreated()	Get the creation time for the record.
long	getDateModified()	Get the modification time for the record.
boolean	getIsSafeMode()
long	getLastContact()
String	getLifelineAddress()	Get the Lifeline RPC server address of the namenode.
String	getNamenodeId()	Identifier for the namenode.
String	getNameserviceId()	Identifier for the nameservice/namespace.
org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeMembershipRecordProto	getProto()	Get the protocol for the record.
String	getRouterId()
String	getRpcAddress()	Get the RPC server address of the namenode.
String	getServiceAddress()	Get the Service RPC server address of the namenode.
FederationNamenodeServiceState	getState()	The current state of the namenode (active, standby, etc).
MembershipStats	getStats()
String	getWebAddress()	Get the HTTP(s) server address of the namenode.
String	getWebScheme()	Get the Scheme of web address of the namenode.
void	readInstance(String base64String)	Populate this record with serialized data.
void	setBlockPoolId(String blockPoolId)
void	setClusterId(String clusterId)
void	setDateCreated(long time)	Set the creation time for the record.
void	setDateModified(long time)	Set the modification time for the record.
void	setIsSafeMode(boolean isSafeMode)
void	setLastContact(long contact)
void	setLifelineAddress(String lifelineAddress)
void	setNamenodeId(String namenodeId)
void	setNameserviceId(String nameserviceId)
void	setProto(org.apache.hadoop.thirdparty.protobuf.Message proto)	Set the protocol for the record.
void	setRouterId(String routerId)
void	setRpcAddress(String rpcAddress)
void	setServiceAddress(String serviceAddress)
void	setState(FederationNamenodeServiceState state)
void	setStats(MembershipStats stats)
void	setWebAddress(String webAddress)
void	setWebScheme(String webScheme)

Methods inherited from class org.apache.hadoop.hdfs.server.federation.store.records.MembershipState

checkExpired, compareNameTo, compareTo, getDeletionMs, getExpirationMs, getNamenodeKey, getNamenodeKey, getPrimaryKeys, isAvailable, isExpired, like, newInstance, newInstance, overrideState, setDeletionMs, setExpirationMs, toString, validate

Methods inherited from class org.apache.hadoop.hdfs.server.federation.store.records.BaseRecord

equals, generateMashupKey, getPrimaryKey, hashCode, hasOtherFields, init, shouldBeDeleted

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

MembershipStatePBImpl

public MembershipStatePBImpl()

MembershipStatePBImpl

public MembershipStatePBImpl(org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeMembershipRecordProto proto)

Method Details

getProto

public org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeMembershipRecordProto getProto()

Description copied from interface: PBRecord

Get the protocol for the record.

Specified by:

getProto in interface PBRecord

Returns:

The protocol for this record.

setProto

public void setProto(org.apache.hadoop.thirdparty.protobuf.Message proto)

Description copied from interface: PBRecord

Set the protocol for the record.

Specified by:

setProto in interface PBRecord

Parameters:

proto - Protocol for this record.

readInstance

public void readInstance(String base64String)
                  throws IOException

Description copied from interface: PBRecord

Populate this record with serialized data.

Specified by:

readInstance in interface PBRecord

Parameters:

base64String - Serialized data in base64.

Throws:

IOException - If it cannot read the data.

setRouterId

public void setRouterId(String routerId)

Specified by:

setRouterId in class MembershipState

setNameserviceId

public void setNameserviceId(String nameserviceId)

Specified by:

setNameserviceId in class MembershipState

setNamenodeId

public void setNamenodeId(String namenodeId)

Specified by:

setNamenodeId in class MembershipState

setWebAddress

public void setWebAddress(String webAddress)

Specified by:

setWebAddress in class MembershipState

setRpcAddress

public void setRpcAddress(String rpcAddress)

Specified by:

setRpcAddress in class MembershipState

setServiceAddress

public void setServiceAddress(String serviceAddress)

Specified by:

setServiceAddress in class MembershipState

setLifelineAddress

public void setLifelineAddress(String lifelineAddress)

Specified by:

setLifelineAddress in class MembershipState

setIsSafeMode

public void setIsSafeMode(boolean isSafeMode)

Specified by:

setIsSafeMode in class MembershipState

setClusterId

public void setClusterId(String clusterId)

Specified by:

setClusterId in class MembershipState

setBlockPoolId

public void setBlockPoolId(String blockPoolId)

Specified by:

setBlockPoolId in class MembershipState

setState

public void setState(FederationNamenodeServiceState state)

Specified by:

setState in class MembershipState

setWebScheme

public void setWebScheme(String webScheme)

Specified by:

setWebScheme in class MembershipState

getRouterId

public String getRouterId()

Specified by:

getRouterId in class MembershipState

getNameserviceId

public String getNameserviceId()

Description copied from interface: FederationNamenodeContext

Identifier for the nameservice/namespace.

Specified by:

getNameserviceId in interface FederationNamenodeContext

Specified by:

getNameserviceId in class MembershipState

Returns:

Namenode nameservice identifier.

getNamenodeId

public String getNamenodeId()

Description copied from interface: FederationNamenodeContext

Identifier for the namenode.

Specified by:

getNamenodeId in interface FederationNamenodeContext

Specified by:

getNamenodeId in class MembershipState

Returns:

String

getClusterId

public String getClusterId()

Specified by:

getClusterId in class MembershipState

getBlockPoolId

public String getBlockPoolId()

Specified by:

getBlockPoolId in class MembershipState

getRpcAddress

public String getRpcAddress()

Description copied from interface: FederationNamenodeContext

Get the RPC server address of the namenode.

Specified by:

getRpcAddress in interface FederationNamenodeContext

Specified by:

getRpcAddress in class MembershipState

Returns:

RPC server address in the form of host:port.

getServiceAddress

public String getServiceAddress()

Description copied from interface: FederationNamenodeContext

Get the Service RPC server address of the namenode.

Specified by:

getServiceAddress in interface FederationNamenodeContext

Specified by:

getServiceAddress in class MembershipState

Returns:

Service RPC server address in the form of host:port.

getWebAddress

public String getWebAddress()

Description copied from interface: FederationNamenodeContext

Get the HTTP(s) server address of the namenode.

Specified by:

getWebAddress in interface FederationNamenodeContext

Specified by:

getWebAddress in class MembershipState

Returns:

HTTP(s) address in the form of host:port.

getLifelineAddress

public String getLifelineAddress()

Description copied from interface: FederationNamenodeContext

Get the Lifeline RPC server address of the namenode.

Specified by:

getLifelineAddress in interface FederationNamenodeContext

Specified by:

getLifelineAddress in class MembershipState

Returns:

Lifeline RPC server address in the form of host:port.

getIsSafeMode

public boolean getIsSafeMode()

Specified by:

getIsSafeMode in class MembershipState

getState

public FederationNamenodeServiceState getState()

Description copied from interface: FederationNamenodeContext

The current state of the namenode (active, standby, etc).

Specified by:

getState in interface FederationNamenodeContext

Specified by:

getState in class MembershipState

Returns:

FederationNamenodeServiceState State of the namenode.

getWebScheme

public String getWebScheme()

Description copied from interface: FederationNamenodeContext

Get the Scheme of web address of the namenode.

Specified by:

getWebScheme in interface FederationNamenodeContext

Specified by:

getWebScheme in class MembershipState

Returns:

Scheme of web address (HTTP/HTTPS).

setStats

public void setStats(MembershipStats stats)

Specified by:

setStats in class MembershipState

getStats

public MembershipStats getStats()

Specified by:

getStats in class MembershipState

setLastContact

public void setLastContact(long contact)

Specified by:

setLastContact in class MembershipState

getLastContact

public long getLastContact()

Specified by:

getLastContact in class MembershipState

setDateModified

public void setDateModified(long time)

Description copied from class: BaseRecord

Set the modification time for the record.

Specified by:

setDateModified in class BaseRecord

Parameters:

time - Modification time of the record.

getDateModified

public long getDateModified()

Description copied from class: BaseRecord

Get the modification time for the record.

Specified by:

getDateModified in interface FederationNamenodeContext

Specified by:

getDateModified in class BaseRecord

Returns:

Modification time of the record.

setDateCreated

public void setDateCreated(long time)

Description copied from class: BaseRecord

Set the creation time for the record.

Specified by:

setDateCreated in class BaseRecord

Parameters:

time - Creation time of the record.

getDateCreated

public long getDateCreated()

Description copied from class: BaseRecord

Get the creation time for the record.

Specified by:

getDateCreated in class BaseRecord

Returns:

Creation time of the record