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 |
TouchCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
TestCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
RmCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
GetFaclCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LoadCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
SetReplicationCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StatCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DistributedLoadCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
PinCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DuCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChecksumCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
SetTtlCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LsCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CopyToLocalCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChgrpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
SetFaclCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MvCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
HelpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
GetSyncPathListCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChownCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StopSyncCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UnsetTtlCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StartSyncCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MkdirCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DistributedCpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UpdateMountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DistributedMvCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CheckConsistencyCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UnpinCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
HeadCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
TailCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
PersistCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UnmountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChmodCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
FreeCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CopyFromLocalCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LocationCommand.run(org.apache.commons.cli.CommandLine cl) |
protected void |
TouchCommand.runPlainPath(AlluxioURI inputPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
RmCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
GetFaclCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
LoadCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
StatCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
PinCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
DuCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChecksumCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
SetTtlCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
LsCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChgrpCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
SetFaclCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChownCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
StopSyncCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
UnsetTtlCommand.runPlainPath(AlluxioURI inputPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
CheckConsistencyCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
UnpinCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
HeadCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
TailCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
UnmountCommand.runPlainPath(AlluxioURI inputPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChmodCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
FreeCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
LocationCommand.runPlainPath(AlluxioURI plainPath,
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 |
CatCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
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) |
Modifier and Type | Method and Description |
---|---|
int |
ListCommand.run(org.apache.commons.cli.CommandLine cl) |
Modifier and Type | Method and Description |
---|---|
int |
ListCommand.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) |
abstract int |
AbstractTableCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ListDatabasesCommand.run(org.apache.commons.cli.CommandLine cl) |
Modifier and Type | Method and Description |
---|---|
void |
FileSystem.createDirectory(AlluxioURI path)
Convenience method for
FileSystem.createDirectory(AlluxioURI, CreateDirectoryPOptions) with
default options. |
void |
BaseFileSystem.createDirectory(AlluxioURI path) |
void |
FileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options)
Creates a directory.
|
void |
BaseFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
FileOutStream |
FileSystem.createFile(AlluxioURI path)
Convenience method for
FileSystem.createFile(AlluxioURI, CreateFilePOptions) with default
options. |
FileOutStream |
BaseFileSystem.createFile(AlluxioURI path) |
FileOutStream |
FileSystem.createFile(AlluxioURI path,
CreateFilePOptions options)
Creates a file.
|
FileOutStream |
BaseFileSystem.createFile(AlluxioURI path,
CreateFilePOptions options) |
void |
FileSystem.delete(AlluxioURI path)
Convenience method for
FileSystem.delete(AlluxioURI, DeletePOptions) with default options. |
void |
BaseFileSystem.delete(AlluxioURI path) |
void |
FileSystem.delete(AlluxioURI path,
DeletePOptions options)
Deletes a file or a directory.
|
void |
BaseFileSystem.delete(AlluxioURI path,
DeletePOptions options) |
boolean |
FileSystem.exists(AlluxioURI path)
Convenience method for
FileSystem.exists(AlluxioURI, ExistsPOptions) with default options. |
boolean |
BaseFileSystem.exists(AlluxioURI path) |
boolean |
FileSystem.exists(AlluxioURI path,
ExistsPOptions options)
Checks whether a path exists in Alluxio space.
|
boolean |
BaseFileSystem.exists(AlluxioURI path,
ExistsPOptions options) |
void |
FileSystem.free(AlluxioURI path)
Convenience method for
FileSystem.free(AlluxioURI, FreePOptions) with default options. |
void |
BaseFileSystem.free(AlluxioURI path) |
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> |
FileSystem.getBlockLocations(AlluxioURI path)
Builds a list of
BlockLocationInfo for the given file. |
List<BlockLocationInfo> |
BaseFileSystem.getBlockLocations(AlluxioURI path) |
Map<String,MountPointInfo> |
FileSystem.getMountTable()
Lists all mount points and their corresponding under storage addresses.
|
Map<String,MountPointInfo> |
BaseFileSystem.getMountTable() |
URIStatus |
FileSystem.getStatus(AlluxioURI path)
Convenience method for
FileSystem.getStatus(AlluxioURI, GetStatusPOptions) with default options. |
URIStatus |
BaseFileSystem.getStatus(AlluxioURI path) |
URIStatus |
CachingFileSystem.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> |
FileSystem.getSyncPathList()
Lists all the actively synced paths.
|
List<SyncPointInfo> |
BaseFileSystem.getSyncPathList() |
List<URIStatus> |
FileSystem.listStatus(AlluxioURI path)
Convenience method for
FileSystem.listStatus(AlluxioURI, ListStatusPOptions) with default
options. |
List<URIStatus> |
BaseFileSystem.listStatus(AlluxioURI path) |
List<URIStatus> |
CachingFileSystem.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) |
void |
FileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath)
Convenience method for
FileSystem.mount(AlluxioURI, AlluxioURI, MountPOptions) with default
options. |
void |
BaseFileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath) |
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) |
FileInStream |
FileSystem.openFile(AlluxioURI path)
Convenience method for
FileSystem.openFile(AlluxioURI, OpenFilePOptions) with default options. |
FileInStream |
BaseFileSystem.openFile(AlluxioURI path) |
FileInStream |
FileSystem.openFile(AlluxioURI path,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
BaseFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
void |
FileSystem.persist(AlluxioURI path)
Convenience method for
FileSystem.persist(AlluxioURI, ScheduleAsyncPersistencePOptions) which
uses the default ScheduleAsyncPersistencePOptions . |
void |
BaseFileSystem.persist(AlluxioURI path) |
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.
|
void |
FileSystem.rename(AlluxioURI src,
AlluxioURI dst)
Convenience method for
FileSystem.rename(AlluxioURI, AlluxioURI, RenamePOptions) with default
options. |
void |
BaseFileSystem.rename(AlluxioURI src,
AlluxioURI dst) |
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 |
FileSystem.reverseResolve(AlluxioURI ufsUri)
Reverse resolve a ufs uri.
|
AlluxioURI |
BaseFileSystem.reverseResolve(AlluxioURI ufsUri) |
void |
FileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries)
Convenience method for
FileSystem.setAcl(AlluxioURI, SetAclAction, List, SetAclPOptions) with
default options. |
void |
BaseFileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries) |
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) |
void |
FileSystem.setAttribute(AlluxioURI path)
Convenience method for
FileSystem.setAttribute(AlluxioURI, SetAttributePOptions) with default
options. |
void |
BaseFileSystem.setAttribute(AlluxioURI path) |
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 |
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 |
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.
|
void |
FileSystem.unmount(AlluxioURI path)
Convenience method for
FileSystem.unmount(AlluxioURI, UnmountPOptions) with default options. |
void |
BaseFileSystem.unmount(AlluxioURI path) |
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 |
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.
|
Modifier and Type | Method and Description |
---|---|
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 |
BlockAlreadyExistsException
The exception thrown when a block already exists in Alluxio.
|
class |
BlockDoesNotExistException
The exception thrown when a block does not exist in Alluxio.
|
class |
BlockInfoException
The exception thrown when something with the block goes wrong, i.e.
|
class |
ConnectionFailedException
Exception used when a network connection failure occurs.
|
class |
DependencyDoesNotExistException
The exception thrown when a dependency does not exist in Alluxio.
|
class |
DirectoryNotEmptyException
Exception for situations where an operation fails because a directory is not empty.
|
class |
FailedToCheckpointException
The exception thrown when Alluxio failed to create a checkpoint.
|
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 |
InvalidJournalEntryException
The exception thrown when we have seen an invalid journal entry.
|
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 |
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.
|
class |
WorkerOutOfSpaceException
The exception thrown when a worker is out of space.
|
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 |
ReplicationHandler.evict(AlluxioURI uri,
long blockId,
int numReplicas)
Decreases the block replication level by a target number of replicas.
|
long |
DefaultReplicationHandler.evict(AlluxioURI uri,
long blockId,
int numReplicas) |
long |
ReplicationHandler.migrate(AlluxioURI uri,
long blockId,
String workerHost,
String mediumType)
Migrate blocks to the correctly pinned locations.
|
long |
DefaultReplicationHandler.migrate(AlluxioURI uri,
long blockId,
String workerHost,
String mediumType) |
long |
ReplicationHandler.replicate(AlluxioURI uri,
long blockId,
int numReplicas)
Increases the block replication level by a target number of replicas.
|
long |
DefaultReplicationHandler.replicate(AlluxioURI uri,
long blockId,
int numReplicas) |
Modifier and Type | Method and Description |
---|---|
static void |
JobUtils.loadBlock(FileSystem fs,
FileSystemContext context,
String path,
long blockId)
Loads a block into the local worker.
|
Modifier and Type | Method and Description |
---|---|
void |
FileSystemMaster.scheduleAsyncPersistence(AlluxioURI path,
ScheduleAsyncPersistenceContext context)
Schedules a file for async persistence.
|
void |
DefaultFileSystemMaster.scheduleAsyncPersistence(AlluxioURI path,
ScheduleAsyncPersistenceContext context) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultAsyncPersistHandler.scheduleAsyncPersistence(AlluxioURI path) |
void |
AsyncPersistHandler.scheduleAsyncPersistence(AlluxioURI path)
Schedules a file for async persistence.
|
Modifier and Type | Method and Description |
---|---|
void |
FileDataManager.persistFile(long fileId,
List<Long> blockIds)
Persists the blocks of a file into the under file system.
|
static void |
UnderFileSystemUtils.prepareFilePath(AlluxioURI alluxioPath,
String ufsPath,
FileSystem fs,
UnderFileSystem ufs)
Creates parent directories for path with correct permissions if required.
|
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
JobMasterClient.heartbeat(long workerId,
List<TaskInfo> taskInfoList)
Periodic heartbeats to update the tasks' status from a worker, and returns the commands.
|
Copyright © 2023. All Rights Reserved.