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,
OperationContext operationContext)
Creates an
RpcContext . |
Modifier and Type | Method and Description |
---|---|
void |
ActiveSyncManager.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.AddSyncPointEntry entry)
Apply
File.AddSyncPointEntry and journal the entry. |
void |
ActiveSyncManager.applyAndJournal(java.util.function.Supplier<JournalContext> context,
File.RemoveSyncPointEntry entry)
Apply
File.RemoveSyncPointEntry 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 |
MergeJournalContext
Context for merging journal entries together for a wrapped journal context.
|
class |
NoopJournalContext
Noop version of JournalContext.
|
class |
StateChangeJournalContext
Context for correctly managing the state change lock for a wrapped journal context.
|
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.
|
Constructor and Description |
---|
MergeJournalContext(JournalContext journalContext,
java.util.function.UnaryOperator<List<Journal.JournalEntry>> merger)
Constructs a
MergeJournalContext . |
StateChangeJournalContext(JournalContext journalContext,
LockResource stateLockResource)
Constructs a
StateChangeJournalContext . |
Modifier and Type | Method and Description |
---|---|
JournalContext |
NoopJournal.createJournalContext() |
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 |
DefaultMetaMaster.State.applyAndJournal(java.util.function.Supplier<JournalContext> ctx,
String clusterId) |
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 |
---|---|
SyncStatus |
AlluxioCatalog.attachDatabase(JournalContext journalContext,
String udbType,
String udbConnectionUri,
String udbDbName,
String dbName,
Map<String,String> map,
boolean ignoreSyncErrors)
Attaches an udb database to Alluxio catalog.
|
void |
AlluxioCatalog.completeTransformTable(JournalContext journalContext,
String dbName,
String tableName,
String definition,
Map<String,Layout> transformedLayouts)
Completes table transformation by updating the layouts of the table's partitions.
|
boolean |
AlluxioCatalog.detachDatabase(JournalContext journalContext,
String dbName)
Removes an existing database.
|
SyncStatus |
Database.sync(JournalContext context)
Syncs the metadata from the under db.
|
SyncStatus |
AlluxioCatalog.syncDatabase(JournalContext journalContext,
String dbName)
Syncs a database.
|
Modifier and Type | Method and Description |
---|---|
void |
Database.applyAndJournal(java.util.function.Supplier<JournalContext> context,
Journal.JournalEntry entry) |
Constructor and Description |
---|
TransformManager(TransformManager.ThrowingSupplier<JournalContext,UnavailableException> createJournalContext,
AlluxioCatalog catalog,
JobMasterClient jobMasterClient)
An internal job master client will be created.
|
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.