ServicePlugin
FileJournalManager
NNStorage
- blockpoolID- removedStorageDirs- attribute3:type
Configuration
HAState
FSEditLogLoader
+ loadFSEdits
LogsPurgeable
+ purgeLogsOlderThan+ selectInputStreams
LeaseManager
- leases- sortedLeases- sortedLeasesByPath
+ countPath+ addLease+ removeLease+ reassignLease+ renewLease- checkLeases
TransferFsImage
Monitor
FSImageStorageInspector
+ inspectDirectory+ isUpgradeFinalized+ getLatestImages+ getMaxSeenTxId+ needToSave
FSImageTransactionalStorageInspector
NameNodeHttpServer
NameNode
- namenodeRegistration- namenodeRole- haState- haEnabled- emptier
+ main- initialize- loadNamesystem- startCommonServices- stopCommonServices- startTrashEmptier- stopTrashEmptier- startHttpServer- stopHttpServer
HAServiceProtocol
+ getServiceStatus+ transitionToStandby+ transitionToActive+ monitorHealth
BookKeeperJournalManager
CheckpointerThread
NamenodeProtocol
+ rollEditLog+ getBlocks+ startCheckpoint+ endCheckpoint
Storage
- storageType- storageDirs
BlockManager
- blocksMap- corruptReplicasMap- InvalidateBlocks- postponedMisreplicatedBlocks- underReplicatedBlocks- pendingReplicationBlocks
+ activate+ close
Closeable
NamenodeProtocols
FSImageFormat.Saver
Namesystem
StandbyState
QuorumJournalManager
DatanodeStatistics
+ getCapacityTotal+ getCapacityUsed
SnapshotManager
- fsDirectory- snapshottables
NameNodeRpcServer
-serviceRpcServer-clientRpcServer
+ start+ join
FSImage
- lastAppliedTxId
+ format+ recoverTransitionRead+ saveNamespace+ loadFSImage+ loadEdits+ doImportCheckpoint+ openEditLogForWrite+ startCheckpoint+ endCheckpoint- doUpgrade- doRollback- doFinalize
BackupJournalManager
SequentialBlockIdGenerator
+ nextValue
GetUserMappingsProtocol
JournalManager
+ format+ startLogSegment+ finalizeLogSegment+ setOutputBufferCapacity+ recoverUnfinalizedSegments+ close
FSImageFormat.Loader
EditLogTailerThread
SafeModeMonitor
RefreshUserMappingsProtocol
NameNodeResourceMonitor
Runnable
QuorumCall
- successes- exceptions
FSNamesystem
- fsDirectory- fsLock
+ loadFromDisk+ startCommonServices+ stopCommonServices+ startActiveServices+ stopActiveServices+ startStandbyServices+ prepareToStopStandbyServices+ stopStandbyServices- startSecretManager- stopSecretManager
ClientProtocol
+ getBlockLocations+ create+ append+ setReplication+ abandonBlock+ addBlock+ complete+ reportBadBlocks+ renewLease+ recoverLease+ getDatanodeReport+ setSafeMode+ refreshNodes
StorageErrorReporter
HostFileManager
- includes- excludes
+ refresh+ isIncluded+ isExcluded
NameNodeResourceChecker
- volumes
+ hasAvailableDiskSpace
DecommissionManager
FSEditLog
- journalSet- editLogStream- storage- editsDirs- sharedEditsDirs- myTransactionId
+ initJournalsForWrite+ initSharedJournalsForRead+ selectInputStreams+ logEdit- startLogSegment- endCurrentLogSegment- createJournal- rollEditLog
FSImagePreTransactionalStorageInspector
NameNodeMetrics
SequentialNumber
StartupProgress
BackupState
EditLogTailer
- activeAddr
+ doTailEdits- triggerActiveLogRoll
StandbyCheckpointer
- activeNNAddress
+ start+ stop- doCheckpoint
JournalSet
HeartbeatManager
- datanodes
+ register+ addDatanode+ removeDatanode+ updateHeartbeat+ startDecommission+ stopDecommission+ heartbeatCheck
ReplicationMonitor
FSClusterStats
FSImageSaver
RefreshAuthorizationPolicyProtocol
HAContext
+ startActiveServices+ stopActiveServices+ startStandbyServices+ stopStandbyServices+ prepareToStopStandbyServices+ writeLock+ writeUnlock
ActiveState
AsyncLoggerSet
- loggers
+ setEpoch+ isEpochEstablished+ getEpoch+ newEpoch+ startLogSegment+ finalizeLogSegment+ sendEdits
NNStorageRetentionManager
DatanodeManager
- datanodeMap- host2DatanodeMap
+ checkDecommissionState+ registerDatanode+ refreshNodes+ handleHeartbeat+ removeDatanode+ addDatanode
DatanodeProtocol
+ registerDatanode+ sendHeartbeat+ blockReport+ blockReceivedAndDeleted+ reportBadBlocks+ commitBlockSynchronization
NameNodeHAContext
