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

Class MembershipStats

java.lang.Object
org.apache.hadoop.hdfs.server.federation.store.records.BaseRecord
org.apache.hadoop.hdfs.server.federation.store.records.MembershipStats
All Implemented Interfaces:
Comparable<BaseRecord>
Direct Known Subclasses:
MembershipStatsPBImpl
public abstract class MembershipStats extends BaseRecord
Data schema for storing NN stats in the StateStoreService.

  • Constructor Details

    • MembershipStats

      public MembershipStats()

  • Method Details

    • newInstance

      public static MembershipStats newInstance() throws IOException
      Throws:
      IOException

    • setTotalSpace

      public abstract void setTotalSpace(long space)

    • getTotalSpace

      public abstract long getTotalSpace()

    • setAvailableSpace

      public abstract void setAvailableSpace(long space)

    • getAvailableSpace

      public abstract long getAvailableSpace()

    • setProvidedSpace

      public abstract void setProvidedSpace(long capacity)

    • getProvidedSpace

      public abstract long getProvidedSpace()

    • setNumOfFiles

      public abstract void setNumOfFiles(long files)

    • getNumOfFiles

      public abstract long getNumOfFiles()

    • setNumOfBlocks

      public abstract void setNumOfBlocks(long blocks)

    • getNumOfBlocks

      public abstract long getNumOfBlocks()

    • setNumOfBlocksMissing

      public abstract void setNumOfBlocksMissing(long blocks)

    • getNumOfBlocksMissing

      public abstract long getNumOfBlocksMissing()

    • setNumOfBlocksPendingReplication

      public abstract void setNumOfBlocksPendingReplication(long blocks)

    • getNumOfBlocksPendingReplication

      public abstract long getNumOfBlocksPendingReplication()

    • setNumOfBlocksUnderReplicated

      public abstract void setNumOfBlocksUnderReplicated(long blocks)

    • getNumOfBlocksUnderReplicated

      public abstract long getNumOfBlocksUnderReplicated()

    • setNumOfBlocksPendingDeletion

      public abstract void setNumOfBlocksPendingDeletion(long blocks)

    • getNumOfBlocksPendingDeletion

      public abstract long getNumOfBlocksPendingDeletion()

    • setNumOfActiveDatanodes

      public abstract void setNumOfActiveDatanodes(int nodes)

    • getNumOfActiveDatanodes

      public abstract int getNumOfActiveDatanodes()

    • setNumOfDeadDatanodes

      public abstract void setNumOfDeadDatanodes(int nodes)

    • getNumOfDeadDatanodes

      public abstract int getNumOfDeadDatanodes()

    • setNumOfStaleDatanodes

      public abstract void setNumOfStaleDatanodes(int nodes)

    • getNumOfStaleDatanodes

      public abstract int getNumOfStaleDatanodes()

    • setNumOfDecommissioningDatanodes

      public abstract void setNumOfDecommissioningDatanodes(int nodes)

    • getNumOfDecommissioningDatanodes

      public abstract int getNumOfDecommissioningDatanodes()

    • setNumOfDecomActiveDatanodes

      public abstract void setNumOfDecomActiveDatanodes(int nodes)

    • getNumOfDecomActiveDatanodes

      public abstract int getNumOfDecomActiveDatanodes()

    • setNumOfDecomDeadDatanodes

      public abstract void setNumOfDecomDeadDatanodes(int nodes)

    • getNumOfDecomDeadDatanodes

      public abstract int getNumOfDecomDeadDatanodes()

    • setNumOfInMaintenanceLiveDataNodes

      public abstract void setNumOfInMaintenanceLiveDataNodes(int nodes)

    • getNumOfInMaintenanceLiveDataNodes

      public abstract int getNumOfInMaintenanceLiveDataNodes()

    • setNumOfInMaintenanceDeadDataNodes

      public abstract void setNumOfInMaintenanceDeadDataNodes(int nodes)

    • getNumOfInMaintenanceDeadDataNodes

      public abstract int getNumOfInMaintenanceDeadDataNodes()

    • setNumOfEnteringMaintenanceDataNodes

      public abstract void setNumOfEnteringMaintenanceDataNodes(int nodes)

    • getNumOfEnteringMaintenanceDataNodes

      public abstract int getNumOfEnteringMaintenanceDataNodes()

    • setCorruptFilesCount

      public abstract void setCorruptFilesCount(int num)

    • getCorruptFilesCount

      public abstract int getCorruptFilesCount()

    • setScheduledReplicationBlocks

      public abstract void setScheduledReplicationBlocks(long blocks)

    • getScheduledReplicationBlocks

      public abstract long getScheduledReplicationBlocks()

    • setNumberOfMissingBlocksWithReplicationFactorOne

      public abstract void setNumberOfMissingBlocksWithReplicationFactorOne(long blocks)

    • getNumberOfMissingBlocksWithReplicationFactorOne

      public abstract long getNumberOfMissingBlocksWithReplicationFactorOne()

    • setNumberOfBadlyDistributedBlocks

      public abstract void setNumberOfBadlyDistributedBlocks(long blocks)

    • getNumberOfBadlyDistributedBlocks

      public abstract long getNumberOfBadlyDistributedBlocks()

    • setHighestPriorityLowRedundancyReplicatedBlocks

      public abstract void setHighestPriorityLowRedundancyReplicatedBlocks(long blocks)

    • getHighestPriorityLowRedundancyReplicatedBlocks

      public abstract long getHighestPriorityLowRedundancyReplicatedBlocks()

    • setHighestPriorityLowRedundancyECBlocks

      public abstract void setHighestPriorityLowRedundancyECBlocks(long blocks)

    • getHighestPriorityLowRedundancyECBlocks

      public abstract long getHighestPriorityLowRedundancyECBlocks()

    • setPendingSPSPaths

      public abstract void setPendingSPSPaths(int pendingSPSPaths)

    • getPendingSPSPaths

      public abstract int getPendingSPSPaths()

    • getPrimaryKeys

      public SortedMap<String,String> getPrimaryKeys()
      Description copied from class: BaseRecord
      Map of primary key names to values for the record. The primary key can be a combination of 1-n different State Store serialized values.
      Specified by:
      getPrimaryKeys in class BaseRecord
      Returns:
      Map of key/value pairs that constitute this object's primary key.

    • getExpirationMs

      public long getExpirationMs()
      Description copied from class: BaseRecord
      Get the expiration time for the record.
      Specified by:
      getExpirationMs in class BaseRecord
      Returns:
      Expiration time for the record.

    • 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 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