Modifier and Type | Class and Description |
---|---|
class |
AbstractMaster
This is the base class for all masters, and contains common functionality.
|
class |
CoreMaster
Abstract class for masters that run in the core master process.
|
class |
NoopMaster
Master implementation that does nothing.
|
Modifier and Type | Method and Description |
---|---|
<T extends Master> |
MasterProcess.getMaster(Class<T> clazz) |
Modifier and Type | Method and Description |
---|---|
Master |
MasterFactory.create(MasterRegistry registry,
T context)
Factory method to create a new master instance.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BlockMaster
Interface of the block master that manages the metadata for all the blocks and block workers in
Alluxio.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultBlockMaster
This block master manages the metadata for all the blocks and block workers in Alluxio.
|
Modifier and Type | Interface and Description |
---|---|
interface |
FileSystemMaster
The interface of file system master service.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultFileSystemMaster
The master that handles all file system metadata management.
|
Modifier and Type | Class and Description |
---|---|
class |
JobMaster
The master that handles all job managing operations.
|
Modifier and Type | Interface and Description |
---|---|
interface |
JournalMaster
Interface for journal master implementations.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultJournalMaster
Default implementation for
JournalMaster . |
Modifier and Type | Method and Description |
---|---|
Master |
JournalMasterFactory.create(MasterRegistry registry,
MasterContext context) |
Modifier and Type | Method and Description |
---|---|
void |
JournalSystem.addJournalSink(Master master,
JournalSink journalSink) |
void |
AbstractJournalSystem.addJournalSink(Master master,
JournalSink journalSink) |
Journal |
JournalSystem.createJournal(Master master)
Creates a journal for the given state machine.
|
Set<JournalSink> |
JournalSystem.getJournalSinks(Master master) |
Set<JournalSink> |
AbstractJournalSystem.getJournalSinks(Master master) |
void |
JournalSystem.removeJournalSink(Master master,
JournalSink journalSink) |
void |
AbstractJournalSystem.removeJournalSink(Master master,
JournalSink journalSink) |
Modifier and Type | Method and Description |
---|---|
void |
NoopJournalSystem.addJournalSink(Master master,
JournalSink journalSink) |
Journal |
NoopJournalSystem.createJournal(Master master) |
Set<JournalSink> |
NoopJournalSystem.getJournalSinks(Master master) |
void |
NoopJournalSystem.removeJournalSink(Master master,
JournalSink journalSink) |
Modifier and Type | Method and Description |
---|---|
Journal |
RaftJournalSystem.createJournal(Master master) |
Modifier and Type | Method and Description |
---|---|
UfsJournal |
UfsJournalSystem.createJournal(Master master) |
Constructor and Description |
---|
UfsJournal(URI location,
Master master,
long quietPeriodMs,
java.util.function.Supplier<Set<JournalSink>> journalSinks)
Creates a new instance of
UfsJournal . |
UfsJournalCheckpointThread(Master master,
UfsJournal journal,
long startSequence,
java.util.function.Supplier<Set<JournalSink>> journalSinks)
Creates a new instance of
UfsJournalCheckpointThread . |
UfsJournalCheckpointThread(Master master,
UfsJournal journal,
java.util.function.Supplier<Set<JournalSink>> journalSinks)
Creates a new instance of
UfsJournalCheckpointThread . |
Modifier and Type | Interface and Description |
---|---|
interface |
MetaMaster
The interface of meta master.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultMetaMaster
The default meta master.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MetricsMaster
Interface of the metrics master that aggregates the cluster-level metrics from workers and
clients.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultMetricsMaster
Default implementation of the metrics master.
|
Modifier and Type | Method and Description |
---|---|
protected void |
RpcServerService.startGrpcServer(java.util.function.Function<Master,Map<ServiceType,GrpcService>> serviceProvider) |
Copyright © 2023. All Rights Reserved.