Modifier and Type | Class and Description |
---|---|
class |
ConfigHashSync
Heartbeat task for getting the latest configuration versions from meta master, if versions
change, then re-initialize the filesystem context.
|
Constructor and Description |
---|
HeartbeatThread(String executorName,
HeartbeatExecutor executor,
long intervalMs,
AlluxioConfiguration conf,
UserState userState)
Convenience method for
HeartbeatThread(String, String, HeartbeatExecutor, long, AlluxioConfiguration, UserState)
where threadId is null. |
HeartbeatThread(String executorName,
String threadId,
HeartbeatExecutor executor,
long intervalMs,
AlluxioConfiguration conf,
UserState userState)
Creates a
Runnable to execute heartbeats for the given HeartbeatExecutor . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultBlockMaster.LostWorkerDetectionHeartbeatExecutor
Lost worker periodic check.
|
class |
DefaultBlockMaster.WorkerRegisterStreamGCExecutor
Periodically checks the open worker register streams.
|
Modifier and Type | Class and Description |
---|---|
class |
BlockIntegrityChecker
Heartbeat executor for validating inode and block integrity.
|
Modifier and Type | Class and Description |
---|---|
class |
ActiveSyncer
Periodically sync the files for a particular mount point.
|
Modifier and Type | Class and Description |
---|---|
class |
ReplicationChecker
The executor to check block replication level periodically and handle over-replicated and
under-replicated blocks correspondingly.
|
Modifier and Type | Class and Description |
---|---|
class |
JournalSpaceMonitor
A heartbeat executor which periodically tracks the amount of disk space available for a
particular path, generally the disk holding the journal.
|
class |
MetaMasterSync
If a master is detected as a standby master.
|
class |
UpdateChecker
Periodically Alluxio version update check.
|
Modifier and Type | Class and Description |
---|---|
class |
BlockMasterSync
Task that carries out the necessary block worker to master communications, including register and
heartbeat.
|
class |
DefaultBlockWorker.StorageChecker
StorageChecker periodically checks the health of each storage path and report missing blocks to
BlockWorker . |
class |
PinListSync
PinListSync periodically syncs the set of pinned inodes from master, and saves the new pinned
inodes to the
BlockWorker . |
Modifier and Type | Class and Description |
---|---|
class |
CommandHandlingExecutor
Manages the communication with the master.
|
Copyright © 2023. All Rights Reserved.