Modifier and Type | Method and Description |
---|---|
JournalContext |
NoopMaster.createJournalContext() |
JournalContext |
AbstractMaster.createJournalContext() |
JournalContext |
Master.createJournalContext() |
Modifier and Type | Method and Description |
---|---|
JournalContext |
RpcContext.get() |
JournalContext |
RpcContext.getJournalContext() |
Constructor and Description |
---|
RpcContext(BlockDeletionContext blockDeleter,
JournalContext journalContext)
Creates an
RpcContext . |
Modifier and Type | Method and Description |
---|---|
void |
ActiveSyncManager.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.AddSyncPointEntry entry)
Apply AddSyncPoint entry and journal the entry.
|
void |
ActiveSyncManager.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.RemoveSyncPointEntry entry)
Apply removeSyncPoint entry and journal the entry.
|
Modifier and Type | Method and Description |
---|---|
void |
InodeTree.initializeRoot(String owner,
String group,
Mode mode,
JournalContext context)
Initializes the root of the inode tree.
|
Modifier and Type | Method and Description |
---|---|
void |
MountTable.add(java.util.function.Supplier<JournalContext> journalContext,
AlluxioURI alluxioUri,
AlluxioURI ufsUri,
long mountId,
MountPOptions options)
Mounts the given UFS path at the given Alluxio path.
|
void |
MountTable.State.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.AddMountPointEntry entry) |
void |
InodeTreePersistentState.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.DeleteFileEntry entry)
Deletes an inode (may be either a file or directory).
|
void |
MountTable.State.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.DeleteMountPointEntry entry) |
long |
InodeTreePersistentState.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.NewBlockEntry entry)
Allocates and returns the next block ID for the indicated inode.
|
void |
InodeTreePersistentState.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.RenameEntry entry)
Renames an inode.
|
void |
InodeTreePersistentState.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.SetAclEntry entry)
Sets an ACL for an inode.
|
void |
InodeTreePersistentState.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.UpdateInodeDirectoryEntry entry)
Updates an inode directory's state.
|
void |
InodeTreePersistentState.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.UpdateInodeEntry entry)
Updates an inode's state.
|
void |
InodeTreePersistentState.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.UpdateInodeFileEntry entry)
Updates an inode file's state.
|
void |
InodeTreePersistentState.applyAndJournal(java.util.function.Supplier<JournalContext> context,
MutableInode<?> inode,
String path)
Adds an inode to the inode tree.
|
boolean |
MountTable.delete(java.util.function.Supplier<JournalContext> journalContext,
AlluxioURI uri,
boolean checkNestedMount)
Unmounts the given Alluxio path.
|
long |
InodeTree.newBlock(java.util.function.Supplier<JournalContext> context,
File.NewBlockEntry entry) |
void |
InodeTree.rename(java.util.function.Supplier<JournalContext> context,
File.RenameEntry entry) |
void |
InodeTree.setAcl(java.util.function.Supplier<JournalContext> context,
File.SetAclEntry entry) |
void |
InodeTree.setDirectChildrenLoaded(java.util.function.Supplier<JournalContext> context,
InodeDirectory dir)
Marks an inode directory as having its direct children loaded.
|
void |
InodeTree.syncPersistExistingDirectory(java.util.function.Supplier<JournalContext> context,
InodeDirectoryView dir)
Synchronously persists an inode directory to the UFS.
|
void |
MountTable.update(java.util.function.Supplier<JournalContext> journalContext,
AlluxioURI alluxioUri,
long newMountId,
MountPOptions newOptions)
Update the mount point with new options and mount ID.
|
void |
InodeTree.updateInode(java.util.function.Supplier<JournalContext> context,
File.UpdateInodeEntry entry) |
void |
InodeTree.updateInodeFile(java.util.function.Supplier<JournalContext> context,
File.UpdateInodeFileEntry entry) |
Modifier and Type | Class and Description |
---|---|
class |
MasterJournalContext
Context for storing master journal information.
|
class |
NoopJournalContext
Noop version of JournalContext.
|
Modifier and Type | Method and Description |
---|---|
JournalContext |
Journal.createJournalContext() |
default JournalContext |
JournalContext.get() |
Modifier and Type | Method and Description |
---|---|
default void |
DelegatingJournaled.applyAndJournal(java.util.function.Supplier<JournalContext> context,
Journal.JournalEntry entry) |
default void |
Journaled.applyAndJournal(java.util.function.Supplier<JournalContext> context,
Journal.JournalEntry entry)
Applies and journals a journal entry.
|
Modifier and Type | Method and Description |
---|---|
JournalContext |
NoopJournal.createJournalContext() |
Modifier and Type | Class and Description |
---|---|
class |
RaftJournalContext
Wrapper context around
MasterJournalContext for holding the raft journal lock over the
lifetime of the journal context. |
Modifier and Type | Method and Description |
---|---|
JournalContext |
RaftJournal.createJournalContext() |
Modifier and Type | Method and Description |
---|---|
JournalContext |
UfsJournal.createJournalContext() |
Modifier and Type | Method and Description |
---|---|
void |
PathProperties.add(java.util.function.Supplier<JournalContext> ctx,
String path,
Map<PropertyKey,String> properties)
Adds properties for path.
|
void |
PathProperties.State.applyAndJournal(java.util.function.Supplier<JournalContext> ctx,
Meta.PathPropertiesEntry entry) |
void |
PathProperties.State.applyAndJournal(java.util.function.Supplier<JournalContext> ctx,
Meta.RemovePathPropertiesEntry entry) |
void |
PathProperties.remove(java.util.function.Supplier<JournalContext> ctx,
String path,
Set<String> keys)
Removes the specified set of keys from the properties for path.
|
void |
PathProperties.removeAll(java.util.function.Supplier<JournalContext> ctx,
String path)
Removes all properties for path.
|
Modifier and Type | Method and Description |
---|---|
void |
MasterUfsManager.setUfsMode(java.util.function.Supplier<JournalContext> journalContext,
AlluxioURI ufsPath,
UfsMode ufsMode)
Set the operation mode the given physical ufs.
|
Copyright © 2023. All Rights Reserved.