Modifier and Type | Method and Description |
---|---|
JournalContext |
AbstractMaster.createJournalContext() |
JournalContext |
NoopMaster.createJournalContext() |
JournalContext |
Master.createJournalContext() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultBlockMaster.commitBlockInUFS(long blockId,
long length,
JournalContext journalContext) |
void |
BlockMaster.commitBlockInUFS(long blockId,
long length,
JournalContext context)
Marks a block as committed, but without a worker location.
|
Modifier and Type | Method and Description |
---|---|
JournalContext |
DefaultFileSystemMaster.createJournalContext() |
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.
|
LockedInodePath |
InodeTree.lockFullInodePath(AlluxioURI uri,
InodeTree.LockPattern lockPattern,
JournalContext journalContext)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockFullInodePath(AlluxioURI uri,
LockingScheme lockScheme,
JournalContext journalContext)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockFullInodePath(long id,
InodeTree.LockPattern lockPattern,
JournalContext journalContext)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockInodePath(AlluxioURI uri,
InodeTree.LockPattern lockPattern,
boolean tryLock,
JournalContext journalContext)
Locks existing inodes on the specified path, in the specified
InodeTree.LockPattern . |
LockedInodePath |
InodeTree.lockInodePath(AlluxioURI uri,
InodeTree.LockPattern lockPattern,
JournalContext journalContext)
Locks existing inodes on the specified path, in the specified
InodeTree.LockPattern . |
LockedInodePath |
InodeTree.lockInodePath(LockingScheme scheme,
JournalContext journalContext)
Locks existing inodes on the path and with the pattern defined by
LockingScheme.getPath() and LockingScheme.getPattern() . |
InodePathPair |
InodeTree.lockInodePathPair(AlluxioURI path1,
InodeTree.LockPattern lockPattern1,
AlluxioURI path2,
InodeTree.LockPattern lockPattern2,
JournalContext journalContext)
Locks existing inodes on the two specified paths.
|
LockedInodePath |
InodeTree.tryLockInodePath(LockingScheme scheme,
JournalContext journalContext)
Locks existing inodes on the path and with the pattern defined by
LockingScheme.getPath() and LockingScheme.getPattern() . |
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.addValidated(java.util.function.Supplier<JournalContext> journalContext,
AlluxioURI alluxioUri,
AlluxioURI ufsUri,
long mountId,
MountPOptions options)
Inserts an entry into the mount table.
|
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.setDirectChildrenLoaded(java.util.function.Supplier<JournalContext> context,
InodeDirectory dir,
boolean directChildrenLoaded)
Marks an inode directory as having its direct children loaded or not.
|
void |
InodeTree.syncPersistExistingDirectory(java.util.function.Supplier<JournalContext> context,
InodeDirectoryView dir,
boolean isMetadataLoad)
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) |
Constructor and Description |
---|
LockedInodePath(AlluxioURI uri,
ReadOnlyInodeStore inodeStore,
InodeLockManager inodeLockManager,
InodeDirectory root,
InodeTree.LockPattern lockPattern,
boolean tryLock,
JournalContext journalContext)
Creates a new locked inode path.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSystemMergeJournalContext
Context for merging journal entries together for a wrapped journal context.
|
class |
MasterJournalContext
Context for storing master journal information.
|
class |
MergeJournalContext
Context for merging journal entries together for a wrapped journal context.
|
class |
MetadataSyncMergeJournalContext
A
FileSystemMergeJournalContext used in MetadataSync (InodeSyncStream). |
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() |
JournalContext |
FileSystemMergeJournalContext.getUnderlyingJournalContext() |
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 |
---|
FileSystemMergeJournalContext(JournalContext journalContext,
JournalEntryMerger journalEntryMerger)
Constructs a
FileSystemMergeJournalContext . |
MergeJournalContext(JournalContext journalContext,
AlluxioURI uri,
java.util.function.UnaryOperator<List<Journal.JournalEntry>> merger)
Constructs a
MergeJournalContext . |
MetadataSyncMergeJournalContext(JournalContext journalContext,
JournalEntryMerger journalEntryMerger)
Constructs a
MetadataSyncMergeJournalContext . |
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.