Modifier and Type | Method and Description |
---|---|
T |
RpcUtils.RpcCallableThrowsIOException.call()
The RPC implementation.
|
Modifier and Type | Method and Description |
---|---|
default int |
Command.run(org.apache.commons.cli.CommandLine cl)
Runs the command.
|
Modifier and Type | Method and Description |
---|---|
int |
CollectMetricsCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CollectConfigCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CollectLogCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ExecuteShellCollectInfoCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CollectJvmInfoCommand.run(org.apache.commons.cli.CommandLine cl) |
Modifier and Type | Method and Description |
---|---|
static int |
DistributedLoadUtils.distributedLoad(AbstractDistributedJobCommand command,
org.apache.commons.cli.CommandLine cl,
String pathStr)
Run the actual distributedLoad command.
|
int |
SyncDirNextTimeCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LsCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StopSyncCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LocationCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
FreeCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
TouchCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MkdirCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChecksumCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
PinCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UnpinCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UnmountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
PersistCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
RmCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LoadMetadataCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
GetFaclCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DistributedLoadCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
SetFaclCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
GetSyncPathListCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MvCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StartSyncCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UnsetTtlCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
SetTtlCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
HeadCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CopyFromLocalCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CheckConsistencyCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
NeedsSyncCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChmodCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
TestCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StatCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
TailCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DistributedCpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DistributedMvCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
SetReplicationCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
FreeWorkerCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CopyToLocalCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UpdateMountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChgrpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LoadCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
HelpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DuCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChownCommand.run(org.apache.commons.cli.CommandLine cl) |
protected void |
SyncDirNextTimeCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
LsCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
StopSyncCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
LocationCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
FreeCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
TouchCommand.runPlainPath(AlluxioURI inputPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChecksumCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
PinCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
UnpinCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
UnmountCommand.runPlainPath(AlluxioURI inputPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
RmCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
LoadMetadataCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
GetFaclCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
CatCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
SetFaclCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
UnsetTtlCommand.runPlainPath(AlluxioURI inputPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
SetTtlCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
HeadCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
CheckConsistencyCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
NeedsSyncCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChmodCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
StatCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
TailCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChgrpCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
LoadCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
DuCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
AbstractFileSystemCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl)
Runs the command for a particular URI that does not contain wildcard in its path.
|
protected void |
ChownCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
static void |
FileSystemCommandUtils.setDirectChildrenLoaded(FileSystem fs,
AlluxioURI path,
boolean directChildrenLoaded)
Sets direct children loaded.
|
static void |
FileSystemCommandUtils.setPinned(FileSystem fs,
AlluxioURI path,
boolean pinned,
List<String> mediumTypes)
Sets pin state for the input path.
|
static void |
FileSystemCommandUtils.setTtl(FileSystem fs,
AlluxioURI path,
long ttlMs,
TtlAction ttlAction)
Sets a new TTL value or unsets an existing TTL value for file at path.
|
Modifier and Type | Method and Description |
---|---|
int |
UfsCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StateLockHoldersCommand.run(org.apache.commons.cli.CommandLine cl) |
Modifier and Type | Method and Description |
---|---|
int |
ListCommand.run(org.apache.commons.cli.CommandLine cl) |
Modifier and Type | Method and Description |
---|---|
int |
GetCmdStatusCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StatCommand.run(org.apache.commons.cli.CommandLine cl) |
Modifier and Type | Method and Description |
---|---|
int |
TransformTableCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
TransformStatusCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ListDatabasesCommand.run(org.apache.commons.cli.CommandLine cl) |
abstract int |
AbstractTableCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LoadTableCommand.run(org.apache.commons.cli.CommandLine cl) |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingFileSystem.checkAccess(AlluxioURI path,
CheckAccessPOptions options) |
void |
FileSystem.checkAccess(AlluxioURI path,
CheckAccessPOptions options)
Checks access to a path.
|
void |
BaseFileSystem.checkAccess(AlluxioURI path,
CheckAccessPOptions options) |
default void |
FileSystem.createDirectory(AlluxioURI path)
Convenience method for
FileSystem.createDirectory(AlluxioURI, CreateDirectoryPOptions) with
default options. |
void |
MetadataCachingFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
void |
DelegatingFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
void |
FileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options)
Creates a directory.
|
void |
BaseFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
default FileOutStream |
FileSystem.createFile(AlluxioURI path)
Convenience method for
FileSystem.createFile(AlluxioURI, CreateFilePOptions) with default
options. |
FileOutStream |
MetadataCachingFileSystem.createFile(AlluxioURI path,
CreateFilePOptions options) |
FileOutStream |
DelegatingFileSystem.createFile(AlluxioURI path,
CreateFilePOptions options) |
FileOutStream |
FileSystemCache.InstanceCachingFileSystem.createFile(AlluxioURI path,
CreateFilePOptions options) |
FileOutStream |
FileSystem.createFile(AlluxioURI path,
CreateFilePOptions options)
Creates a file.
|
FileOutStream |
BaseFileSystem.createFile(AlluxioURI path,
CreateFilePOptions options) |
default void |
FileSystem.delete(AlluxioURI path)
Convenience method for
FileSystem.delete(AlluxioURI, DeletePOptions) with default options. |
void |
MetadataCachingFileSystem.delete(AlluxioURI path,
DeletePOptions options) |
void |
DelegatingFileSystem.delete(AlluxioURI path,
DeletePOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.delete(AlluxioURI path,
DeletePOptions options) |
void |
FileSystem.delete(AlluxioURI path,
DeletePOptions options)
Deletes a file or a directory.
|
void |
BaseFileSystem.delete(AlluxioURI path,
DeletePOptions options) |
default boolean |
FileSystem.exists(AlluxioURI path)
Convenience method for
FileSystem.exists(AlluxioURI, ExistsPOptions) with default options. |
boolean |
DelegatingFileSystem.exists(AlluxioURI path,
ExistsPOptions options) |
boolean |
FileSystemCache.InstanceCachingFileSystem.exists(AlluxioURI path,
ExistsPOptions options) |
boolean |
FileSystem.exists(AlluxioURI path,
ExistsPOptions options)
Checks whether a path exists in Alluxio space.
|
boolean |
BaseFileSystem.exists(AlluxioURI path,
ExistsPOptions options) |
default void |
FileSystem.free(AlluxioURI path)
Convenience method for
FileSystem.free(AlluxioURI, FreePOptions) with default options. |
void |
DelegatingFileSystem.free(AlluxioURI path,
FreePOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.free(AlluxioURI path,
FreePOptions options) |
void |
FileSystem.free(AlluxioURI path,
FreePOptions options)
Evicts any data under the given path from Alluxio space, but does not delete the data from the
UFS.
|
void |
BaseFileSystem.free(AlluxioURI path,
FreePOptions options) |
List<BlockLocationInfo> |
MetadataCachingFileSystem.getBlockLocations(AlluxioURI path) |
List<BlockLocationInfo> |
DelegatingFileSystem.getBlockLocations(AlluxioURI path) |
List<BlockLocationInfo> |
FileSystemCache.InstanceCachingFileSystem.getBlockLocations(AlluxioURI path) |
default List<BlockLocationInfo> |
FileSystem.getBlockLocations(AlluxioURI path)
Builds a list of
BlockLocationInfo for the given file. |
List<BlockLocationInfo> |
DelegatingFileSystem.getBlockLocations(URIStatus status) |
List<BlockLocationInfo> |
FileSystemCache.InstanceCachingFileSystem.getBlockLocations(URIStatus status) |
List<BlockLocationInfo> |
FileSystem.getBlockLocations(URIStatus status)
Builds a list of
BlockLocationInfo for the given file. |
List<BlockLocationInfo> |
BaseFileSystem.getBlockLocations(URIStatus status) |
default Map<String,MountPointInfo> |
FileSystem.getMountTable()
Lists all mount points and their corresponding under storage addresses.
|
Map<String,MountPointInfo> |
DelegatingFileSystem.getMountTable(boolean checkUfs) |
Map<String,MountPointInfo> |
FileSystemCache.InstanceCachingFileSystem.getMountTable(boolean checkUfs) |
Map<String,MountPointInfo> |
FileSystem.getMountTable(boolean checkUfs)
Lists all mount points and their corresponding under storage addresses.
|
Map<String,MountPointInfo> |
BaseFileSystem.getMountTable(boolean checkUfs) |
default URIStatus |
FileSystem.getStatus(AlluxioURI path)
Convenience method for
FileSystem.getStatus(AlluxioURI, GetStatusPOptions) with default options. |
URIStatus |
MetadataCachingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
DelegatingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
FileSystemCache.InstanceCachingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
FileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options)
Gets the
URIStatus object that represents the metadata of an Alluxio path. |
URIStatus |
BaseFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
List<SyncPointInfo> |
DelegatingFileSystem.getSyncPathList() |
List<SyncPointInfo> |
FileSystemCache.InstanceCachingFileSystem.getSyncPathList() |
List<SyncPointInfo> |
FileSystem.getSyncPathList()
Lists all the actively synced paths.
|
List<SyncPointInfo> |
BaseFileSystem.getSyncPathList() |
default void |
FileSystem.iterateStatus(AlluxioURI path,
java.util.function.Consumer<? super URIStatus> action)
Performs a specific action on each
URIStatus in the result of FileSystem.listStatus(alluxio.AlluxioURI) . |
void |
MetadataCachingFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
DelegatingFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
FileSystemCache.InstanceCachingFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
FileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action)
Performs a specific action on each
URIStatus in the result of FileSystem.listStatus(alluxio.AlluxioURI) . |
void |
BaseFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
default List<URIStatus> |
FileSystem.listStatus(AlluxioURI path)
Convenience method for
FileSystem.listStatus(AlluxioURI, ListStatusPOptions) with default
options. |
List<URIStatus> |
MetadataCachingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
DelegatingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
FileSystemCache.InstanceCachingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
FileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options)
If the path is a directory, returns the
URIStatus of all the direct entries in it. |
List<URIStatus> |
BaseFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
ListStatusPartialResult |
DelegatingFileSystem.listStatusPartial(AlluxioURI path,
ListStatusPartialPOptions options) |
ListStatusPartialResult |
FileSystem.listStatusPartial(AlluxioURI path,
ListStatusPartialPOptions options)
Same as
FileSystem.listStatus(AlluxioURI, ListStatusPOptions) except may
only return a subset of the results as determined by the options parameter. |
ListStatusPartialResult |
BaseFileSystem.listStatusPartial(AlluxioURI path,
ListStatusPartialPOptions options) |
default void |
FileSystem.loadMetadata(AlluxioURI path)
Convenience method for
FileSystem.loadMetadata(AlluxioURI, ListStatusPOptions) with default
options. |
void |
DelegatingFileSystem.loadMetadata(AlluxioURI path,
ListStatusPOptions options) |
void |
FileSystem.loadMetadata(AlluxioURI path,
ListStatusPOptions options)
Loads metadata about a path in the UFS to Alluxio.
|
void |
BaseFileSystem.loadMetadata(AlluxioURI path,
ListStatusPOptions options) |
default void |
FileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath)
Convenience method for
FileSystem.mount(AlluxioURI, AlluxioURI, MountPOptions) with default
options. |
void |
DelegatingFileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountPOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountPOptions options) |
void |
FileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountPOptions options)
Mounts a UFS subtree to the given Alluxio path.
|
void |
BaseFileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountPOptions options) |
void |
DelegatingFileSystem.needsSync(AlluxioURI path) |
void |
FileSystem.needsSync(AlluxioURI path)
Marks the path in Alluxio as needing sync with the UFS.
|
void |
BaseFileSystem.needsSync(AlluxioURI path) |
default FileInStream |
FileSystem.openFile(AlluxioURI path)
Convenience method for
FileSystem.openFile(AlluxioURI, OpenFilePOptions) with default options. |
FileInStream |
MetadataCachingFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
DelegatingFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
FileSystemCache.InstanceCachingFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
FileSystem.openFile(AlluxioURI path,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
BaseFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
DelegatingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
FileSystemCache.InstanceCachingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
FileSystem.openFile(URIStatus status,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
BaseFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
default void |
FileSystem.persist(AlluxioURI path)
Convenience method for
FileSystem.persist(AlluxioURI, ScheduleAsyncPersistencePOptions) which
uses the default ScheduleAsyncPersistencePOptions . |
void |
DelegatingFileSystem.persist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.persist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options) |
void |
FileSystem.persist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options)
Schedules the given path to be asynchronously persisted to the under file system.
|
void |
BaseFileSystem.persist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options) |
static void |
FileSystemUtils.persistAndWait(FileSystem fs,
AlluxioURI uri,
long persistenceWaitTime)
Convenience method for
#persistAndWait(fs, uri, persistenceWaitTime, -1) . |
static void |
FileSystemUtils.persistAndWait(FileSystem fs,
AlluxioURI uri,
long persistenceWaitTime,
int timeoutMs)
Persists the given path to the under file system and returns once the persist is complete.
|
default void |
FileSystem.rename(AlluxioURI src,
AlluxioURI dst)
Convenience method for
FileSystem.rename(AlluxioURI, AlluxioURI, RenamePOptions) with default
options. |
void |
MetadataCachingFileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options) |
void |
DelegatingFileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options) |
void |
FileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options)
Renames an existing Alluxio path to another Alluxio path in Alluxio.
|
void |
BaseFileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options) |
AlluxioURI |
DelegatingFileSystem.reverseResolve(AlluxioURI ufsUri) |
AlluxioURI |
FileSystemCache.InstanceCachingFileSystem.reverseResolve(AlluxioURI ufsUri) |
AlluxioURI |
FileSystem.reverseResolve(AlluxioURI ufsUri)
Reverse resolve a ufs uri.
|
AlluxioURI |
BaseFileSystem.reverseResolve(AlluxioURI ufsUri) |
default void |
FileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries)
Convenience method for
FileSystem.setAcl(AlluxioURI, SetAclAction, List, SetAclPOptions) with
default options. |
void |
DelegatingFileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options) |
void |
FileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options)
Sets the ACL for a path.
|
void |
BaseFileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options) |
default void |
FileSystem.setAttribute(AlluxioURI path)
Convenience method for
FileSystem.setAttribute(AlluxioURI, SetAttributePOptions) with default
options. |
void |
DelegatingFileSystem.setAttribute(AlluxioURI path,
SetAttributePOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.setAttribute(AlluxioURI path,
SetAttributePOptions options) |
void |
FileSystem.setAttribute(AlluxioURI path,
SetAttributePOptions options)
Sets any number of a path's attributes, such as TTL and pin status.
|
void |
BaseFileSystem.setAttribute(AlluxioURI path,
SetAttributePOptions options) |
void |
DelegatingFileSystem.startSync(AlluxioURI path) |
void |
FileSystemCache.InstanceCachingFileSystem.startSync(AlluxioURI path) |
void |
FileSystem.startSync(AlluxioURI path)
Starts the active syncing process on an Alluxio path.
|
void |
BaseFileSystem.startSync(AlluxioURI path)
Starts the active syncing process on an Alluxio path.
|
void |
DelegatingFileSystem.stopSync(AlluxioURI path) |
void |
FileSystemCache.InstanceCachingFileSystem.stopSync(AlluxioURI path) |
void |
FileSystem.stopSync(AlluxioURI path)
Stops the active syncing process on an Alluxio path.
|
void |
BaseFileSystem.stopSync(AlluxioURI path)
Stops the active syncing process on an Alluxio path.
|
default void |
FileSystem.unmount(AlluxioURI path)
Convenience method for
FileSystem.unmount(AlluxioURI, UnmountPOptions) with default options. |
void |
DelegatingFileSystem.unmount(AlluxioURI path,
UnmountPOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.unmount(AlluxioURI path,
UnmountPOptions options) |
void |
FileSystem.unmount(AlluxioURI path,
UnmountPOptions options)
Unmounts a UFS subtree identified by the given Alluxio path.
|
void |
BaseFileSystem.unmount(AlluxioURI path,
UnmountPOptions options) |
void |
DelegatingFileSystem.updateMount(AlluxioURI alluxioPath,
MountPOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.updateMount(AlluxioURI alluxioPath,
MountPOptions options) |
void |
FileSystem.updateMount(AlluxioURI alluxioPath,
MountPOptions options)
Updates the options for an existing mount point.
|
void |
BaseFileSystem.updateMount(AlluxioURI alluxioPath,
MountPOptions options) |
static boolean |
FileSystemUtils.waitCompleted(FileSystem fs,
AlluxioURI uri)
Shortcut for
waitCompleted(fs, uri, -1, TimeUnit.MILLISECONDS) , i.e., wait for an
indefinite amount of time. |
static boolean |
FileSystemUtils.waitCompleted(FileSystem fs,
AlluxioURI uri,
long timeout,
TimeUnit tunit)
Waits for a file to be marked as completed.
|
protected void |
BaseFileSystem.wrapAndThrowAlluxioStatusException(AlluxioStatusException e) |
Modifier and Type | Method and Description |
---|---|
FileInStream |
LocalCacheFileInStream.FileInStreamOpener.open(URIStatus uriStatus)
Opens an FSDataInputStream at the indicated Path.
|
FileInStream |
LocalCacheFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
LocalCacheFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
UfsBaseFileSystem.needsSync(AlluxioURI path) |
Modifier and Type | Method and Description |
---|---|
static void |
AlluxioFS.main(String[] args)
Entry point for the
AlluxioFS program. |
void |
Performance.AlluxioReadWorker.readPartition()
Reads a partition.
|
void |
Performance.AlluxioWriterWorker.writePartition()
Writes a partition.
|
Modifier and Type | Class and Description |
---|---|
class |
AccessControlException
Thrown when permission checking fails.
|
class |
BackupAbortedException
Thrown when backup is aborted.
|
class |
BackupDelegationException
Thrown when backup delegation fails.
|
class |
BackupException
Thrown when backup is fails.
|
class |
BlockAlreadyExistsException
The exception thrown when a block already exists in Alluxio.
|
class |
BlockInfoException
The exception thrown when something with the block goes wrong, i.e.
|
class |
BusyException
Thrown when the system is busy.
|
class |
ConnectionFailedException
Exception used when a network connection failure occurs.
|
class |
DirectoryNotEmptyException
Exception for situations where an operation fails because a directory is not empty.
|
class |
FailedToAcquireRegisterLeaseException
The exception thrown when the worker cannot acquire a registration lease after all
the retry attempts have been exhausted.
|
class |
FileAlreadyCompletedException
The exception thrown when a file is already completed in Alluxio.
|
class |
FileAlreadyExistsException
The exception thrown when a file already exists in Alluxio.
|
class |
FileDoesNotExistException
The exception thrown when a path does not exist in Alluxio.
|
class |
FileIncompleteException
The exception thrown when opening a file that hasn't completed.
|
class |
InvalidFileSizeException
The exception thrown when the file of a size is invalid.
|
class |
InvalidPathException
The exception thrown when the path in Alluxio is invalid.
|
class |
InvalidWorkerStateException
The exception thrown when a worker is in an invalid state, i.e.
|
class |
JobDoesNotExistException
The exception thrown when a job definition does not exist in Alluxio.
|
class |
OpenDirectoryException
The exception thrown when trying to call openFile on a directory.
|
class |
PageNotFoundException
An exception that should be thrown when a page is not found in store.
|
class |
RegisterLeaseNotFoundException
The exception thrown when the worker attempts to register but there is no lease found.
|
class |
ServiceNotFoundException
Exception used when the service is not provided by the server.
|
class |
UfsBlockAccessTokenUnavailableException
The exception thrown when it fails to grab a UFS access token for a UFS block.
|
class |
UnexpectedAlluxioException
The exception thrown when an unexpected error occurs within the Alluxio system.
|
Modifier and Type | Method and Description |
---|---|
AlluxioException |
AlluxioStatusException.toAlluxioException() |
Modifier and Type | Method and Description |
---|---|
static AlluxioStatusException |
AlluxioStatusException.fromAlluxioException(AlluxioException ae)
Converts checked Alluxio exceptions to Alluxio status exceptions.
|
Modifier and Type | Method and Description |
---|---|
long |
DefaultReplicationHandler.migrate(AlluxioURI uri,
long blockId,
String workerHost,
String mediumType) |
long |
ReplicationHandler.migrate(AlluxioURI uri,
long blockId,
String workerHost,
String mediumType)
Migrate blocks to the correctly pinned locations.
|
long |
DefaultReplicationHandler.setReplica(AlluxioURI uri,
long blockId,
int numReplicas) |
long |
ReplicationHandler.setReplica(AlluxioURI uri,
long blockId,
int numReplicas)
Set the block replication level by a target number of replicas.
|
Modifier and Type | Method and Description |
---|---|
static void |
JobUtils.loadBlock(URIStatus status,
FileSystemContext context,
long blockId,
WorkerNetAddress address,
boolean directCache)
Loads a block into the local worker.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AlluxioMasterProcess.takeEmergencyBackup() |
Modifier and Type | Method and Description |
---|---|
void |
BackupTracker.updateError(AlluxioException error)
Updates the error of backup status.
|
Modifier and Type | Method and Description |
---|---|
BackupStatus |
BackupWorkerRole.backup(BackupPRequest request,
StateLockOptions stateLockOptions) |
BackupStatus |
BackupLeaderRole.backup(BackupPRequest request,
StateLockOptions stateLockOptions) |
BackupStatus |
BackupOps.backup(BackupPRequest request,
StateLockOptions stateLockOptions)
Takes a backup.
|
BackupStatus |
BackupLeaderRole.getBackupStatus(BackupStatusPRequest statusPRequest) |
BackupStatus |
BackupOps.getBackupStatus(BackupStatusPRequest statusPRequest)
Used to query the status of a backup.
|
void |
BackupTracker.waitUntilFinished()
Used to wait until this backup is finished.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultFileSystemMaster.scheduleAsyncPersistence(AlluxioURI path,
ScheduleAsyncPersistenceContext context) |
void |
FileSystemMaster.scheduleAsyncPersistence(AlluxioURI path,
ScheduleAsyncPersistenceContext context)
Schedules a file for async persistence.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncPersistHandler.scheduleAsyncPersistence(AlluxioURI path)
Schedules a file for async persistence.
|
void |
DefaultAsyncPersistHandler.scheduleAsyncPersistence(AlluxioURI path) |
Modifier and Type | Method and Description |
---|---|
BackupStatus |
DefaultMetaMaster.backup(BackupPRequest request,
StateLockOptions stateLockOptions) |
BackupStatus |
DefaultMetaMaster.getBackupStatus(BackupStatusPRequest statusPRequest) |
BackupStatus |
DefaultMetaMaster.takeEmergencyBackup()
Overrides current backup role and forces the master to take a local backup.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
MultipartUploadCleaner.apply(FileSystem metaFs,
FileSystem userFs,
String bucket,
String object,
String uploadId)
Schedule a task to clean multipart upload.
|
static List<URIStatus> |
S3RestUtils.checkStatusesForUploadId(FileSystem metaFs,
FileSystem userFs,
AlluxioURI multipartTempDirUri,
String uploadId)
Fetches and returns the corresponding
URIStatus for both
the multipart upload temp directory and the Alluxio S3 metadata file. |
static void |
S3RestUtils.deleteExistObject(FileSystem fs,
AlluxioURI objectURI)
Delete an existing key.
|
static void |
S3RestUtils.deleteExistObject(FileSystem fs,
AlluxioURI objectURI,
Boolean recursive)
Delete an existing key.
|
void |
CompleteMultipartUploadHandler.CompleteMultipartUploadTask.removePartsDirAndMPMetaFile(AlluxioURI multipartTemporaryDir)
Cleanup the multipart upload temporary folder holding the parts files.
|
void |
S3ObjectTask.CompleteMultipartUploadTask.removePartsDirAndMPMetaFile(AlluxioURI multipartTemporaryDir)
Cleanup the multipart upload temporary folder holding the parts files.
|
static void |
S3RestUtils.setEntityTag(FileSystem fs,
AlluxioURI objectUri,
String entityTag)
This helper method is used to set the ETag xAttr on an object.
|
long |
MultipartUploadCleaner.tryAbortMultipartUpload(FileSystem metaFs,
FileSystem userFs,
String bucket,
String object,
String uploadId)
Try to abort a multipart upload if it was timeout.
|
List<URIStatus> |
CompleteMultipartUploadHandler.CompleteMultipartUploadTask.validateParts(CompleteMultipartUploadRequest request,
String objectPath,
AlluxioURI multipartTemporaryDir)
Validate the parts as part of this multipart uplaod request.
|
List<URIStatus> |
S3ObjectTask.CompleteMultipartUploadTask.validateParts(CompleteMultipartUploadRequest request,
String objectPath,
AlluxioURI multipartTemporaryDir)
Validate the parts as part of this multipart uplaod request.
|
Constructor and Description |
---|
S3RestServiceHandler(javax.servlet.ServletContext context)
Constructs a new
S3RestServiceHandler . |
Modifier and Type | Method and Description |
---|---|
protected void |
StressMasterBenchBase.applyNativeOperation(FileSystem fs,
Operation operation,
long counter,
org.apache.hadoop.fs.Path basePath,
org.apache.hadoop.fs.Path fixedBasePath,
int fixedCount) |
protected abstract void |
MultiOperationStressMasterBench.BenchThread.applyOperation(int operationIndex,
long operationCounter) |
protected abstract void |
StressMasterBench.BenchThread.applyOperation(long counter) |
protected StressMasterBenchBase.BenchContext |
MultiOperationStressMasterBench.getContext() |
protected abstract StressMasterBenchBase.BenchContext |
StressMasterBenchBase.getContext() |
Modifier and Type | Method and Description |
---|---|
static String |
UdbUtils.mountAlluxioPath(String tableName,
AlluxioURI ufsUri,
AlluxioURI tableUri,
UdbContext udbContext,
UdbConfiguration udbConfiguration)
Mount ufs path to alluxio path.
|
Modifier and Type | Method and Description |
---|---|
AlluxioException |
BackupStatus.getError() |
Modifier and Type | Method and Description |
---|---|
BackupStatus |
BackupStatus.setError(AlluxioException error)
Fails the backup with given error.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultBlockWorker.cache(CacheRequest request) |
void |
BlockWorker.cache(CacheRequest request)
Submits the cache request to cache manager to execute.
|
void |
CacheRequestManager.submitRequest(CacheRequest request)
Handles a request to cache a block.
|
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
JobMasterClient.heartbeat(JobWorkerHealth jobWorkerHealth,
List<JobInfo> taskInfoList)
Periodic heartbeats to update the tasks' status from a worker, and returns the commands.
|
Copyright © 2023. All Rights Reserved.