Modifier and Type | Method and Description |
---|---|
T |
RpcUtils.RpcCallable.call()
The RPC implementation.
|
T |
RpcUtils.RpcCallableThrowsIOException.call()
The RPC implementation.
|
Modifier and Type | Method and Description |
---|---|
int |
Command.run(org.apache.commons.cli.CommandLine cl)
Runs the command.
|
Modifier and Type | Method and Description |
---|---|
int |
CheckConsistencyCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChownCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MkdirCommand.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 |
RmCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LoadCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
PinCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
TestCommand.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 |
FreeCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CopyFromLocalCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DuCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
TouchCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LsCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
LocationCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
DeleteLineageCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CreateLineageCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
SetTtlCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
UnsetTtlCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
StatCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChmodCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
PersistCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChgrpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CopyToLocalCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MountCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ReportCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
HelpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
MvCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
ChecksumCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CpCommand.run(org.apache.commons.cli.CommandLine cl) |
int |
CountCommand.run(org.apache.commons.cli.CommandLine cl) |
protected void |
CheckConsistencyCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChownCommand.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 |
LoadCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
CatCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
PinCommand.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 |
FreeCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
DuCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
TouchCommand.runPlainPath(AlluxioURI inputPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
LsCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
LocationCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
SetTtlCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
UnsetTtlCommand.runPlainPath(AlluxioURI inputPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
StatCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChmodCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
PersistCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChgrpCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
ReportCommand.runPlainPath(AlluxioURI path,
org.apache.commons.cli.CommandLine cl) |
protected void |
ChecksumCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl) |
protected void |
AbstractFileSystemCommand.runPlainPath(AlluxioURI plainPath,
org.apache.commons.cli.CommandLine cl)
Run the command for a particular URI that does not contain wildcard in its path.
|
static void |
FileSystemCommandUtils.setPinned(FileSystem fs,
AlluxioURI path,
boolean pinned)
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 |
---|---|
void |
BaseFileSystem.createDirectory(AlluxioURI path) |
void |
FileSystem.createDirectory(AlluxioURI path)
Convenience method for
FileSystem.createDirectory(AlluxioURI, CreateDirectoryOptions) with
default options. |
void |
BaseFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryOptions options) |
void |
FileSystem.createDirectory(AlluxioURI path,
CreateDirectoryOptions options)
Creates a directory.
|
FileOutStream |
BaseFileSystem.createFile(AlluxioURI path) |
FileOutStream |
FileSystem.createFile(AlluxioURI path)
Convenience method for
FileSystem.createFile(AlluxioURI, CreateFileOptions) with default options. |
FileOutStream |
BaseFileSystem.createFile(AlluxioURI path,
CreateFileOptions options) |
FileOutStream |
FileSystem.createFile(AlluxioURI path,
CreateFileOptions options)
Creates a file.
|
void |
BaseFileSystem.delete(AlluxioURI path) |
void |
FileSystem.delete(AlluxioURI path)
Convenience method for
FileSystem.delete(AlluxioURI, DeleteOptions) with default options. |
void |
BaseFileSystem.delete(AlluxioURI path,
DeleteOptions options) |
void |
FileSystem.delete(AlluxioURI path,
DeleteOptions options)
Deletes a file or a directory.
|
boolean |
BaseFileSystem.exists(AlluxioURI path) |
boolean |
FileSystem.exists(AlluxioURI path)
Convenience method for
FileSystem.exists(AlluxioURI, ExistsOptions) with default options. |
boolean |
BaseFileSystem.exists(AlluxioURI path,
ExistsOptions options) |
boolean |
FileSystem.exists(AlluxioURI path,
ExistsOptions options)
Checks whether a path exists in Alluxio space.
|
void |
BaseFileSystem.free(AlluxioURI path) |
void |
FileSystem.free(AlluxioURI path)
Convenience method for
FileSystem.free(AlluxioURI, FreeOptions) with default options. |
void |
BaseFileSystem.free(AlluxioURI path,
FreeOptions options) |
void |
FileSystem.free(AlluxioURI path,
FreeOptions options)
Evicts any data under the given path from Alluxio space, but does not delete the data from the
UFS.
|
Map<String,MountPointInfo> |
BaseFileSystem.getMountTable() |
Map<String,MountPointInfo> |
FileSystem.getMountTable()
Lists all mount points and their corresponding under storage addresses.
|
URIStatus |
BaseFileSystem.getStatus(AlluxioURI path) |
URIStatus |
FileSystem.getStatus(AlluxioURI path)
Convenience method for
FileSystem.getStatus(AlluxioURI, GetStatusOptions) with default options. |
URIStatus |
BaseFileSystem.getStatus(AlluxioURI path,
GetStatusOptions options) |
URIStatus |
FileSystem.getStatus(AlluxioURI path,
GetStatusOptions options)
Gets the
URIStatus object that represents the metadata of an Alluxio path. |
List<URIStatus> |
BaseFileSystem.listStatus(AlluxioURI path) |
List<URIStatus> |
FileSystem.listStatus(AlluxioURI path)
Convenience method for
FileSystem.listStatus(AlluxioURI, ListStatusOptions) with default options. |
List<URIStatus> |
BaseFileSystem.listStatus(AlluxioURI path,
ListStatusOptions options) |
List<URIStatus> |
FileSystem.listStatus(AlluxioURI path,
ListStatusOptions options)
If the path is a directory, returns the
URIStatus of all the direct entries in it. |
void |
BaseFileSystem.loadMetadata(AlluxioURI path)
Deprecated.
since version 1.1 and will be removed in version 2.0
|
void |
FileSystem.loadMetadata(AlluxioURI path)
Deprecated.
since version 1.1 and will be removed in version 2.0
|
void |
BaseFileSystem.loadMetadata(AlluxioURI path,
LoadMetadataOptions options)
Deprecated.
since version 1.1 and will be removed in version 2.0
|
void |
FileSystem.loadMetadata(AlluxioURI path,
LoadMetadataOptions options)
Deprecated.
since version 1.1 and will be removed in version 2.0
|
void |
BaseFileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath) |
void |
FileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath)
Convenience method for
FileSystem.mount(AlluxioURI, AlluxioURI, MountOptions) with default
options. |
void |
BaseFileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountOptions options) |
void |
FileSystem.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountOptions options)
Mounts a UFS subtree to the given Alluxio path.
|
FileInStream |
BaseFileSystem.openFile(AlluxioURI path) |
FileInStream |
FileSystem.openFile(AlluxioURI path)
Convenience method for
FileSystem.openFile(AlluxioURI, OpenFileOptions) with default options. |
FileInStream |
BaseFileSystem.openFile(AlluxioURI path,
OpenFileOptions options) |
FileInStream |
FileSystem.openFile(AlluxioURI path,
OpenFileOptions options)
Opens a file for reading.
|
void |
BaseFileSystem.rename(AlluxioURI src,
AlluxioURI dst) |
void |
FileSystem.rename(AlluxioURI src,
AlluxioURI dst)
Convenience method for
FileSystem.rename(AlluxioURI, AlluxioURI, RenameOptions) with default
options. |
void |
BaseFileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenameOptions options) |
void |
FileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenameOptions options)
Renames an existing Alluxio path to another Alluxio path in Alluxio.
|
void |
BaseFileSystem.setAttribute(AlluxioURI path) |
void |
FileSystem.setAttribute(AlluxioURI path)
Convenience method for
FileSystem.setAttribute(AlluxioURI, SetAttributeOptions) with default
options. |
void |
BaseFileSystem.setAttribute(AlluxioURI path,
SetAttributeOptions options) |
void |
FileSystem.setAttribute(AlluxioURI path,
SetAttributeOptions options)
Sets any number of a path's attributes, such as TTL and pin status.
|
void |
BaseFileSystem.unmount(AlluxioURI path) |
void |
FileSystem.unmount(AlluxioURI path)
Convenience method for
FileSystem.unmount(AlluxioURI, UnmountOptions) with default options. |
void |
BaseFileSystem.unmount(AlluxioURI path,
UnmountOptions options) |
void |
FileSystem.unmount(AlluxioURI path,
UnmountOptions options)
Unmounts a UFS subtree identified by the given Alluxio path.
|
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 |
---|---|
static KeyValuePartitionWriter |
KeyValuePartitionWriter.Factory.create(AlluxioURI uri)
Factory method to create a
KeyValuePartitionWriter instance that writes key-value
data to a new partition file in Alluxio. |
static KeyValuePartitionReader |
KeyValuePartitionReader.Factory.create(AlluxioURI uri)
Factory method to create a
KeyValuePartitionReader given the AlluxioURI of a
key-value partition. |
static KeyValuePartitionReader |
KeyValuePartitionReader.Factory.create(long blockId)
Factory method to create a
KeyValuePartitionReader given the block id of a key-value
partition. |
KeyValueStoreWriter |
KeyValueSystem.createStore(AlluxioURI uri)
Gets a writer to create a new key-value store.
|
KeyValueStoreWriter |
BaseKeyValueSystem.createStore(AlluxioURI uri) |
void |
KeyValueSystem.deleteStore(AlluxioURI uri)
Deletes a completed key-value store.
|
void |
BaseKeyValueSystem.deleteStore(AlluxioURI uri) |
byte[] |
KeyValueStoreReader.get(byte[] key)
Gets the value associated with
key , returns null if not found. |
byte[] |
KeyValuePartitionReader.get(byte[] key)
Gets the value associated with the given key in the key-value partition, returning null if the
key is not found.
|
ByteBuffer |
KeyValueStoreReader.get(ByteBuffer key)
Gets the value associated with
key , returns null if not found. |
ByteBuffer |
KeyValuePartitionReader.get(ByteBuffer key)
Gets the value associated with the given key in the key-value partition, returning null if the
key is not found.
|
ByteBuffer |
KeyValueWorkerClient.get(long blockId,
ByteBuffer key)
Gets the value of a given
key from a specific key-value block. |
List<ByteBuffer> |
KeyValueWorkerClient.getNextKeys(long blockId,
ByteBuffer key,
int numKeys)
Gets a batch of keys next to the current key in the partition.
|
int |
KeyValueWorkerClient.getSize(long blockId) |
KeyValueIterator |
KeyValueIterable.iterator() |
void |
KeyValueSystem.mergeStore(AlluxioURI fromUri,
AlluxioURI toUri)
Merges one completed key-value store to another completed key-value store.
|
void |
BaseKeyValueSystem.mergeStore(AlluxioURI fromUri,
AlluxioURI toUri) |
KeyValuePair |
KeyValueStoreIterator.next() |
KeyValuePair |
KeyValueIterator.next()
Throws a
NoSuchElementException if there are no more pairs. |
KeyValueStoreReader |
KeyValueSystem.openStore(AlluxioURI uri)
Gets a reader to access a key-value store.
|
KeyValueStoreReader |
BaseKeyValueSystem.openStore(AlluxioURI uri) |
void |
KeyValueStoreWriter.put(byte[] key,
byte[] value)
Adds a key and its associated value to this store.
|
void |
KeyValueStoreWriter.put(ByteBuffer key,
ByteBuffer value)
Adds a key and its associated value to this store.
|
void |
KeyValueSystem.renameStore(AlluxioURI oldUri,
AlluxioURI newUri)
Rename a completed key-value store.
|
void |
BaseKeyValueSystem.renameStore(AlluxioURI oldUri,
AlluxioURI newUri) |
int |
KeyValueStoreReader.size() |
int |
KeyValuePartitionReader.size() |
int |
ByteBufferKeyValuePartitionReader.size() |
Constructor and Description |
---|
KeyValueStoreIterator(List<PartitionInfo> partitions) |
Modifier and Type | Method and Description |
---|---|
FileOutStream |
LineageFileSystem.createFile(AlluxioURI path,
CreateFileOptions options)
Gets the output stream for lineage job.
|
long |
AlluxioLineage.createLineage(List<AlluxioURI> inputFiles,
List<AlluxioURI> outputFiles,
Job job)
Convenience method for
AbstractLineageClient.createLineage(List, List, Job, CreateLineageOptions) with
default options. |
long |
AbstractLineageClient.createLineage(List<AlluxioURI> inputFiles,
List<AlluxioURI> outputFiles,
Job job,
CreateLineageOptions options) |
boolean |
AlluxioLineage.deleteLineage(long lineageId)
Convenience method for
AbstractLineageClient.deleteLineage(long, DeleteLineageOptions) with default options. |
boolean |
AbstractLineageClient.deleteLineage(long lineageId,
DeleteLineageOptions options) |
void |
LineageFileSystem.reportLostFile(AlluxioURI path)
Reports a file as lost.
|
Modifier and Type | Method and Description |
---|---|
static void |
Performance.createFiles()
Creates the files for this example.
|
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 |
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 |
LineageDeletionException
The exception thrown when a lineage deletion fails in Alluxio.
|
class |
LineageDoesNotExistException
The exception thrown when a lineage does not exist in Alluxio.
|
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 |
---|---|
void |
DefaultFileSystemMaster.scheduleAsyncPersistence(AlluxioURI path) |
void |
FileSystemMaster.scheduleAsyncPersistence(AlluxioURI path)
Schedules a file for async persistence.
|
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 |
DefaultKeyValueMaster.deleteStore(AlluxioURI uri) |
void |
KeyValueMaster.deleteStore(AlluxioURI uri)
Deletes a completed key-value store.
|
void |
DefaultKeyValueMaster.mergeStore(AlluxioURI fromUri,
AlluxioURI toUri) |
void |
KeyValueMaster.mergeStore(AlluxioURI fromUri,
AlluxioURI toUri)
Merges one completed key-value store to another completed key-value store.
|
void |
DefaultKeyValueMaster.renameStore(AlluxioURI oldUri,
AlluxioURI newUri) |
void |
KeyValueMaster.renameStore(AlluxioURI oldUri,
AlluxioURI newUri)
Renames one completed key-value store.
|
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.
|
Copyright © 2023. All Rights Reserved.