Skip navigation links
A B C D E F G H I L M N O P R S T U V W 

A

AbstractOutStream - Class in alluxio.client
An abstraction of the output stream API in Alluxio to write data to a file or a block.
AbstractOutStream() - Constructor for class alluxio.client.AbstractOutStream
 
acquireBlockMasterClientResource() - Method in class alluxio.client.file.FileSystemContext
Acquires a block master client resource from the block master client pool.
acquireBlockWorkerClient(WorkerNetAddress) - Method in class alluxio.client.file.FileSystemContext
Acquires a block worker client from the client pools.
acquireMasterClientResource() - Method in class alluxio.client.file.FileSystemContext
Acquires a file system master client from the file system master client pool.
addHeartbeat(ClientContext, MasterInquireClient) - Static method in class alluxio.client.metrics.MetricsHeartbeatContext
Sets up a new metrics heartbeat with the given client information.
afterConnect() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
 
afterConnect() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
afterConnect() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
afterConnect() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
afterConnect() - Method in class alluxio.client.metrics.MetricsMasterClient
 
allow() - Method in class alluxio.client.file.FileSystemContextReinitializer
Acquires the resource to allow reinitialization.
alluxio.client - package alluxio.client
 
alluxio.client.block - package alluxio.client.block
 
alluxio.client.block.options - package alluxio.client.block.options
 
alluxio.client.block.policy - package alluxio.client.block.policy
 
alluxio.client.block.policy.options - package alluxio.client.block.policy.options
 
alluxio.client.block.stream - package alluxio.client.block.stream
 
alluxio.client.block.util - package alluxio.client.block.util
 
alluxio.client.file - package alluxio.client.file
 
alluxio.client.file.options - package alluxio.client.file.options
 
alluxio.client.meta - package alluxio.client.meta
 
alluxio.client.metrics - package alluxio.client.metrics
 
alluxio.util - package alluxio.util
 
AlluxioBlockStore - Class in alluxio.client.block
Alluxio Block Store client.
AlluxioStorageType - Enum in alluxio.client
Specifies the type of data interaction with Alluxio.
asyncCache(AsyncCacheRequest) - Method in interface alluxio.client.block.stream.BlockWorkerClient
Caches a block asynchronously.
asyncCache(AsyncCacheRequest) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 

B

backup(BackupPOptions) - Method in interface alluxio.client.meta.MetaMasterClient
Writes a backup of the journal to the specified directory.
backup(BackupPOptions) - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
BaseFileSystem - Class in alluxio.client.file
Default implementation of the FileSystem interface.
BaseFileSystem(FileSystemContext, boolean) - Constructor for class alluxio.client.file.BaseFileSystem
Constructs a new base file system.
beforeStart(ClientCallStreamObserver<ReqT>) - Method in class alluxio.client.block.stream.DataMessageClientResponseObserver
 
block() - Method in class alluxio.client.file.FileSystemContextReinitializer
Acquires the resource to block reinitialization.
BlockInStream - Class in alluxio.client.block.stream
Provides an InputStream implementation that is based on DataReaders to stream data chunk by chunk.
BlockInStream(DataReader.Factory, WorkerNetAddress, BlockInStream.BlockInStreamSource, long, long) - Constructor for class alluxio.client.block.stream.BlockInStream
Creates an instance of BlockInStream.
BlockInStream.BlockInStreamSource - Enum in alluxio.client.block.stream
the source tracking where the block is from.
BlockLocationPolicy - Interface in alluxio.client.block.policy
Interface for determining the Alluxio worker location to serve a block write or UFS block read.
BlockLocationPolicy.Factory - Class in alluxio.client.block.policy
The factory for the BlockLocationPolicy.
BlockLocationUtils - Class in alluxio.client.block.util
Utility functions for working with block locations.
BlockMasterClient - Interface in alluxio.client.block
A client to use for interacting with a block master.
BlockMasterClient.Factory - Class in alluxio.client.block
Factory for BlockMasterClient.
BlockMasterClientPool - Class in alluxio.client.block
Class for managing block master clients.
BlockMasterClientPool(MasterClientContext) - Constructor for class alluxio.client.block.BlockMasterClientPool
Creates a new block master client pool.
BlockOutStream - Class in alluxio.client.block.stream
Provides an OutputStream implementation that is based on DataWriter which streams data chunk by chunk.
BlockOutStream(DataWriter, long, WorkerNetAddress) - Constructor for class alluxio.client.block.stream.BlockOutStream
Constructs a new BlockOutStream with only one DataWriter.
BlockOutStream(List<DataWriter>, long, List<WorkerNetAddress>) - Constructor for class alluxio.client.block.stream.BlockOutStream
Constructs a new BlockOutStream with only one DataWriter.
blockReinit() - Method in class alluxio.client.file.FileSystemContext
Acquires the resource to block reinitialization.
BlockWorkerClient - Interface in alluxio.client.block.stream
gRPC client for worker communication.
BlockWorkerClient.Factory - Class in alluxio.client.block.stream
Factory for block worker client.
BlockWorkerClientPool - Class in alluxio.client.block.stream
Class for managing block worker clients.
BlockWorkerClientPool(Subject, GrpcServerAddress, int, AlluxioConfiguration, EventLoopGroup) - Constructor for class alluxio.client.block.stream.BlockWorkerClientPool
Creates a new block master client pool.
BlockWorkerInfo - Class in alluxio.client.block
Information of an active block worker.
BlockWorkerInfo(WorkerNetAddress, long, long) - Constructor for class alluxio.client.block.BlockWorkerInfo
Constructs the block worker information.
BoundedStream - Interface in alluxio.client
This interface should be implemented by all Alluxio streams which are bounded at a certain byte size.

C

Cache() - Constructor for class alluxio.client.file.FileSystem.Cache
 
cancel() - Method in class alluxio.client.AbstractOutStream
Aborts the output stream.
cancel() - Method in class alluxio.client.block.stream.BlockOutStream
 
cancel() - Method in class alluxio.client.block.stream.GrpcBlockingStream
Cancels the stream.
cancel() - Method in class alluxio.client.block.stream.GrpcDataWriter
 
cancel() - Method in class alluxio.client.block.stream.LocalFileDataWriter
 
cancel() - Method in class alluxio.client.block.stream.UfsFallbackLocalFileDataWriter
 
cancel() - Method in interface alluxio.client.Cancelable
Cancels an operation.
cancel() - Method in class alluxio.client.file.FileOutStream
 
Cancelable - Interface in alluxio.client
This interface should be implemented by all Alluxio output streams which support aborting the temporary data that has been written.
checkConsistency(AlluxioURI, CheckConsistencyPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Checks the consistency of Alluxio metadata against the under storage for all files and directories in a given subtree.
checkConsistency(AlluxioURI, CheckConsistencyPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
checkConsistencyDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
checkpoint() - Method in interface alluxio.client.meta.MetaMasterClient
Creates a checkpoint in the primary master journal system.
checkpoint() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
chunkSize() - Method in interface alluxio.client.block.stream.DataWriter
 
chunkSize() - Method in class alluxio.client.block.stream.GrpcDataWriter
 
chunkSize() - Method in class alluxio.client.block.stream.LocalFileDataWriter
 
chunkSize() - Method in class alluxio.client.block.stream.UfsFallbackLocalFileDataWriter
 
ClientMasterSync - Class in alluxio.client.metrics
Task that carries the client metrics information to master through heartheat.
ClientMasterSync(String, MetricsMasterClient, AlluxioConfiguration) - Constructor for class alluxio.client.metrics.ClientMasterSync
Constructs a new ClientMasterSync.
close() - Method in class alluxio.client.block.BlockMasterClientPool
 
close() - Method in class alluxio.client.block.stream.BlockInStream
 
close() - Method in class alluxio.client.block.stream.BlockOutStream
 
close() - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
close() - Method in class alluxio.client.block.stream.GrpcBlockingStream
Closes the outbound stream.
close() - Method in class alluxio.client.block.stream.GrpcDataReader
 
close() - Method in class alluxio.client.block.stream.GrpcDataReader.Factory
 
close() - Method in class alluxio.client.block.stream.GrpcDataWriter
 
close() - Method in class alluxio.client.block.stream.LocalFileDataReader
 
close() - Method in class alluxio.client.block.stream.LocalFileDataReader.Factory
 
close() - Method in class alluxio.client.block.stream.LocalFileDataWriter
 
close() - Method in class alluxio.client.block.stream.UfsFallbackLocalFileDataWriter
 
close() - Method in class alluxio.client.file.BaseFileSystem
Shuts down the FileSystem.
close() - Method in class alluxio.client.file.ConfigHashSync
 
close() - Method in class alluxio.client.file.FileInStream
 
close() - Method in class alluxio.client.file.FileOutStream
 
close() - Method in class alluxio.client.file.FileSystemContext
Closes all the resources associated with the context.
close() - Method in class alluxio.client.file.FileSystemContextReinitializer
Shuts down the heartbeat thread immediately.
close() - Method in class alluxio.client.file.FileSystemContextReinitializer.ReinitAllowerResource
 
close() - Method in class alluxio.client.file.FileSystemContextReinitializer.ReinitBlockerResource
 
close() - Method in class alluxio.client.file.FileSystemMasterClientPool
 
closeResource(BlockWorkerClient) - Method in class alluxio.client.block.stream.BlockWorkerClientPool
 
commonDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
completeFile(AlluxioURI, CompleteFilePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Marks a file as completed.
completeFile(AlluxioURI, CompleteFilePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
ConfigHashSync - Class in alluxio.client.file
Heartbeat task for getting the latest configuration versions from meta master, if versions change, then re-initialize the filesystem context.
ConfigHashSync(FileSystemContext) - Constructor for class alluxio.client.file.ConfigHashSync
Constructs a new ConfigHashSync.
create(FileSystemContext) - Static method in class alluxio.client.block.AlluxioBlockStore
Creates an Alluxio block store with default local hostname.
create(MasterClientContext) - Static method in class alluxio.client.block.BlockMasterClient.Factory
Factory method for BlockMasterClient.
create(String, AlluxioConfiguration) - Static method in class alluxio.client.block.policy.BlockLocationPolicy.Factory
Factory for creating BlockLocationPolicy.
create(FileSystemContext, BlockInfo, WorkerNetAddress, BlockInStream.BlockInStreamSource, InStreamOptions) - Static method in class alluxio.client.block.stream.BlockInStream
Creates a BlockInStream.
create(FileSystemContext, long, long, WorkerNetAddress, OutStreamOptions) - Static method in class alluxio.client.block.stream.BlockOutStream
Creates an BlockOutStream.
create(Subject, GrpcServerAddress, AlluxioConfiguration, EventLoopGroup) - Static method in class alluxio.client.block.stream.BlockWorkerClient.Factory
Creates a new block worker client.
create(long, long) - Method in interface alluxio.client.block.stream.DataReader.Factory
Creates an instance of DataReader.
create(FileSystemContext, long, long, WorkerNetAddress, OutStreamOptions) - Static method in class alluxio.client.block.stream.DataWriter.Factory
 
create(long, long) - Method in class alluxio.client.block.stream.GrpcDataReader.Factory
 
create(FileSystemContext, WorkerNetAddress, long, long, RequestType, OutStreamOptions) - Static method in class alluxio.client.block.stream.GrpcDataWriter
 
create(long, long) - Method in class alluxio.client.block.stream.LocalFileDataReader.Factory
 
create(FileSystemContext, WorkerNetAddress, long, OutStreamOptions) - Static method in class alluxio.client.block.stream.LocalFileDataWriter
Creates an instance of LocalFileDataWriter.
create(FileSystemContext, WorkerNetAddress, long, long, OutStreamOptions) - Static method in class alluxio.client.block.stream.UfsFallbackLocalFileDataWriter
 
create(FileSystemContext, WorkerNetAddress, OutStreamOptions) - Static method in class alluxio.client.block.stream.UnderFileSystemFileOutStream
Creates an instance of UnderFileSystemFileOutStream that writes to a UFS file.
create(FileSystemContext) - Static method in class alluxio.client.file.BaseFileSystem
 
create(FileSystemContext, boolean) - Static method in class alluxio.client.file.BaseFileSystem
 
create(AlluxioConfiguration) - Static method in class alluxio.client.file.FileSystem.Factory
 
create(ClientContext) - Static method in class alluxio.client.file.FileSystem.Factory
 
create(FileSystemContext) - Static method in class alluxio.client.file.FileSystem.Factory
 
create(AlluxioConfiguration) - Static method in class alluxio.client.file.FileSystemContext
Creates a FileSystemContext with a null subject.
create(Subject, AlluxioConfiguration) - Static method in class alluxio.client.file.FileSystemContext
 
create(ClientContext) - Static method in class alluxio.client.file.FileSystemContext
 
create(Subject, MasterInquireClient, AlluxioConfiguration) - Static method in class alluxio.client.file.FileSystemContext
This method is provided for testing, use the FileSystemContext.create(alluxio.conf.AlluxioConfiguration) methods.
create(MasterClientContext) - Static method in class alluxio.client.file.FileSystemMasterClient.Factory
Factory method for FileSystemMasterClient.
createDirectory(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in class alluxio.client.file.BaseFileSystem
 
createDirectory(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.createDirectory(AlluxioURI, CreateDirectoryPOptions) with default options.
createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in interface alluxio.client.file.FileSystem
Creates a directory.
createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Creates a new directory.
createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
createDirectoryDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
createFile(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
createFile(AlluxioURI, CreateFilePOptions) - Method in class alluxio.client.file.BaseFileSystem
 
createFile(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.createFile(AlluxioURI, CreateFilePOptions) with default options.
createFile(AlluxioURI, CreateFilePOptions) - Method in interface alluxio.client.file.FileSystem
Creates a file.
createFile(AlluxioURI, CreateFilePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Creates a new file.
createFile(AlluxioURI, CreateFilePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
createFileDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
createLocalBlock(StreamObserver<CreateLocalBlockResponse>) - Method in interface alluxio.client.block.stream.BlockWorkerClient
Creates a local block on the worker.
createLocalBlock(StreamObserver<CreateLocalBlockResponse>) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
createNewResource() - Method in class alluxio.client.block.BlockMasterClientPool
 
createNewResource() - Method in class alluxio.client.block.stream.BlockWorkerClientPool
 
createNewResource() - Method in class alluxio.client.file.FileSystemMasterClientPool
 
createRemoteBlockInStream(FileSystemContext, long, WorkerNetAddress, BlockInStream.BlockInStreamSource, long, Protocol.OpenUfsBlockOptions) - Static method in class alluxio.client.block.stream.BlockInStream
Creates a BlockInStream to read from a specific remote server.
createReplicatedBlockOutStream(FileSystemContext, long, long, List<WorkerNetAddress>, OutStreamOptions) - Static method in class alluxio.client.block.stream.BlockOutStream
Creates a new remote block output stream.

D

DataMessageClientResponseObserver<ReqT,RespT> - Class in alluxio.client.block.stream
A StreamObserver that handles raw data buffers.
DataMessageClientResponseObserver(StreamObserver<RespT>, DataMessageMarshaller<ReqT>, DataMessageMarshaller<RespT>) - Constructor for class alluxio.client.block.stream.DataMessageClientResponseObserver
 
DataReader - Interface in alluxio.client.block.stream
The interface to read data chunks.
DataReader.Factory - Interface in alluxio.client.block.stream
The factory interface to create DataReaders.
DataWriter - Interface in alluxio.client.block.stream
The interface to write data.
DataWriter.Factory - Class in alluxio.client.block.stream
Factory for DataWriter.
DefaultBlockWorkerClient - Class in alluxio.client.block.stream
Default implementation of BlockWorkerClient.
DefaultBlockWorkerClient(Subject, GrpcServerAddress, AlluxioConfiguration, EventLoopGroup) - Constructor for class alluxio.client.block.stream.DefaultBlockWorkerClient
Creates a client instance for communicating with block worker.
defaults() - Static method in class alluxio.client.block.options.GetWorkerReportOptions
 
defaults() - Static method in class alluxio.client.block.policy.options.GetWorkerOptions
 
defaults(ClientContext, AlluxioConfiguration) - Static method in class alluxio.client.file.options.OutStreamOptions
 
defaults(ClientContext) - Static method in class alluxio.client.file.options.OutStreamOptions
 
delete(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
delete(AlluxioURI, DeletePOptions) - Method in class alluxio.client.file.BaseFileSystem
 
delete(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.delete(AlluxioURI, DeletePOptions) with default options.
delete(AlluxioURI, DeletePOptions) - Method in interface alluxio.client.file.FileSystem
Deletes a file or a directory.
delete(AlluxioURI, DeletePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Deletes a file or a directory.
delete(AlluxioURI, DeletePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
deleteDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
DeterministicHashPolicy - Class in alluxio.client.block.policy
This policy maps blockId to several deterministic Alluxio workers.
DeterministicHashPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.DeterministicHashPolicy
Constructs a new DeterministicHashPolicy.

E

equals(Object) - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
equals(Object) - Method in class alluxio.client.block.policy.DeterministicHashPolicy
 
equals(Object) - Method in class alluxio.client.block.policy.LocalFirstAvoidEvictionPolicy
 
equals(Object) - Method in class alluxio.client.block.policy.LocalFirstPolicy
 
equals(Object) - Method in class alluxio.client.block.policy.MostAvailableFirstPolicy
 
equals(Object) - Method in class alluxio.client.block.policy.options.GetWorkerOptions
 
equals(Object) - Method in class alluxio.client.block.policy.RoundRobinPolicy
 
equals(Object) - Method in class alluxio.client.block.policy.SpecificHostPolicy
 
equals(Object) - Method in class alluxio.client.file.FileSystem.FileSystemKey
 
equals(Object) - Method in class alluxio.client.file.options.InStreamOptions
 
equals(Object) - Method in class alluxio.client.file.options.OutStreamOptions
 
exists(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
exists(AlluxioURI, ExistsPOptions) - Method in class alluxio.client.file.BaseFileSystem
 
exists(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.exists(AlluxioURI, ExistsPOptions) with default options.
exists(AlluxioURI, ExistsPOptions) - Method in interface alluxio.client.file.FileSystem
Checks whether a path exists in Alluxio space.
existsDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 

F

Factory() - Constructor for class alluxio.client.block.stream.BlockWorkerClient.Factory
 
Factory(FileSystemContext, WorkerNetAddress, ReadRequest) - Constructor for class alluxio.client.block.stream.GrpcDataReader.Factory
Creates an instance of GrpcDataReader.Factory for block reads.
Factory(FileSystemContext, WorkerNetAddress, long, long, InStreamOptions) - Constructor for class alluxio.client.block.stream.LocalFileDataReader.Factory
Creates an instance of LocalFileDataReader.Factory.
FileInStream - Class in alluxio.client.file
A streaming API to read a file.
FileInStream(URIStatus, InStreamOptions, FileSystemContext) - Constructor for class alluxio.client.file.FileInStream
 
FileOutStream - Class in alluxio.client.file
Provides a streaming API to write a file.
FileOutStream(AlluxioURI, OutStreamOptions, FileSystemContext) - Constructor for class alluxio.client.file.FileOutStream
Creates a new file output stream.
FileSystem - Interface in alluxio.client.file
Basic file system interface supporting metadata operations and data operations.
FileSystem.Cache - Class in alluxio.client.file
A cache for storing FileSystem clients.
FileSystem.Factory - Class in alluxio.client.file
Factory for FileSystem.
FileSystem.FileSystemKey - Class in alluxio.client.file
A key which can be used to look up a FileSystem instance in the FileSystem.Cache.
FILESYSTEM_CACHE - Static variable in class alluxio.client.file.FileSystem.Factory
 
FileSystemContext - Class in alluxio.client.file
An object which houses resources and information for performing FileSystem operations.
FileSystemContextReinitializer - Class in alluxio.client.file
Reinitializes FileSystemContext inside BaseFileSystem.
FileSystemContextReinitializer(FileSystemContext) - Constructor for class alluxio.client.file.FileSystemContextReinitializer
Creates a new reinitializer for the context.
FileSystemContextReinitializer.ReinitAllowerResource - Class in alluxio.client.file
This resource allows reinitialization.
FileSystemContextReinitializer.ReinitBlockerResource - Class in alluxio.client.file
This resource blocks reinitialization until close.
FileSystemKey(Subject, AlluxioConfiguration) - Constructor for class alluxio.client.file.FileSystem.FileSystemKey
 
FileSystemKey(ClientContext) - Constructor for class alluxio.client.file.FileSystem.FileSystemKey
 
FileSystemMasterClient - Interface in alluxio.client.file
A client to use for interacting with a file system master.
FileSystemMasterClient.Factory - Class in alluxio.client.file
FileSystemMasterClientPool - Class in alluxio.client.file
A fixed pool of FileSystemMasterClient instances.
FileSystemMasterClientPool(MasterClientContext) - Constructor for class alluxio.client.file.FileSystemMasterClientPool
Creates a new file system master client pool.
FileSystemOptions - Class in alluxio.util
This class contains static methods which can be passed Alluxio configuration objects that will populate the gRPC options objects with the proper values based on the given configuration.
FileSystemOptions() - Constructor for class alluxio.util.FileSystemOptions
 
FileSystemUtils - Class in alluxio.client.file
Collection of utility methods to handle with FileSystem related objects.
flush() - Method in class alluxio.client.block.stream.BlockOutStream
 
flush() - Method in interface alluxio.client.block.stream.DataWriter
Flushes all the pending chunks.
flush() - Method in class alluxio.client.block.stream.GrpcDataWriter
 
flush() - Method in class alluxio.client.block.stream.LocalFileDataWriter
 
flush() - Method in class alluxio.client.block.stream.UfsFallbackLocalFileDataWriter
 
flush() - Method in class alluxio.client.file.FileOutStream
 
free(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
free(AlluxioURI, FreePOptions) - Method in class alluxio.client.file.BaseFileSystem
 
free(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.free(AlluxioURI, FreePOptions) with default options.
free(AlluxioURI, FreePOptions) - Method in interface alluxio.client.file.FileSystem
Evicts any data under the given path from Alluxio space, but does not delete the data from the UFS.
free(AlluxioURI, FreePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Frees a file.
free(AlluxioURI, FreePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
freeDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
fromProto(WorkerInfoField) - Static method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerInfoField
 
fromProto(WorkerRange) - Static method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerRange
 
fromProto(ReadPType) - Static method in enum alluxio.client.ReadType
 
fromProto(WritePType) - Static method in enum alluxio.client.WriteType
 

G

get(FileSystem.FileSystemKey) - Method in class alluxio.client.file.FileSystem.Cache
Gets a FileSystem from the cache.
get() - Static method in class alluxio.client.file.FileSystem.Factory
 
get(Subject) - Static method in class alluxio.client.file.FileSystem.Factory
Get a FileSystem from the cache with a given subject.
getAcl() - Method in class alluxio.client.file.options.OutStreamOptions
 
getAddress() - Method in class alluxio.client.block.stream.BlockInStream
 
getAddress() - Method in class alluxio.client.block.stream.BlockOutStream
 
getAddresses() - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
getAlluxioStorageType() - Method in class alluxio.client.file.options.OutStreamOptions
 
getAlluxioStorageType() - Method in enum alluxio.client.ReadType
 
getAlluxioStorageType() - Method in enum alluxio.client.WriteType
 
getAllWorkers() - Method in class alluxio.client.block.AlluxioBlockStore
 
getBlockInfo(long) - Method in interface alluxio.client.block.BlockMasterClient
Returns the BlockInfo for a block id.
getBlockInfo() - Method in class alluxio.client.block.policy.options.GetWorkerOptions
 
getBlockInfo(long) - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
Returns the BlockInfo for a block id.
getBlockInfo(long) - Method in class alluxio.client.file.options.InStreamOptions
 
getBlockLocations(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
getBlockLocations(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Builds a list of BlockLocationInfo for the given file.
getBlockMasterInfo(Set<BlockMasterInfo.BlockMasterInfoField>) - Method in interface alluxio.client.block.BlockMasterClient
 
getBlockMasterInfo(Set<BlockMasterInfo.BlockMasterInfoField>) - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
 
getBlockSizeBytes() - Method in class alluxio.client.file.options.OutStreamOptions
 
getBlockWorkerInfos() - Method in class alluxio.client.block.policy.options.GetWorkerOptions
 
getBytesWritten() - Method in class alluxio.client.AbstractOutStream
Deprecated.
this method will not work if more than MAX_INT bytes are written; to get a count of bytes written, wrap this stream in a counting output stream such as org.apache.commons.io.output.CountingOutputStream
getCapacityBytes() - Method in class alluxio.client.block.AlluxioBlockStore
Gets the total capacity of Alluxio's BlockStore.
getCapacityBytes() - Method in interface alluxio.client.block.BlockMasterClient
Gets the total Alluxio capacity in bytes, on all the tiers of all the workers.
getCapacityBytes() - Method in class alluxio.client.block.BlockWorkerInfo
 
getCapacityBytes() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
Gets the total Alluxio capacity in bytes, on all the tiers of all the workers.
getClientContext() - Method in class alluxio.client.file.FileSystemContext
 
getClusterConf() - Method in class alluxio.client.file.FileSystemContext
 
getCommonOptions() - Method in class alluxio.client.file.options.OutStreamOptions
 
getConf() - Method in class alluxio.client.file.BaseFileSystem
 
getConf() - Method in interface alluxio.client.file.FileSystem
 
getConfigHash() - Method in interface alluxio.client.meta.MetaMasterConfigClient
 
getConfigHash() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
getConfigReport() - Method in interface alluxio.client.meta.MetaMasterClient
Gets the server-side configuration check report.
getConfigReport() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
getConfiguration(GetConfigurationPOptions) - Method in interface alluxio.client.meta.MetaMasterConfigClient
 
getConfiguration(GetConfigurationPOptions) - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
getEligibleWorkers() - Method in class alluxio.client.block.AlluxioBlockStore
 
getException() - Method in class alluxio.client.file.ConfigHashSync
 
getFieldRange() - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
getFilePath(long) - Method in interface alluxio.client.file.FileSystemMasterClient
 
getFilePath(long) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
getGroup() - Method in class alluxio.client.file.options.OutStreamOptions
 
getId() - Method in class alluxio.client.block.stream.BlockInStream
 
getId() - Method in class alluxio.client.file.FileSystemContext
 
getInfo(long) - Method in class alluxio.client.block.AlluxioBlockStore
Gets the block info of a block, if it exists.
getInStream(long, InStreamOptions) - Method in class alluxio.client.block.AlluxioBlockStore
Gets a stream to read the data of a block.
getInStream(long, InStreamOptions, Map<WorkerNetAddress, Long>) - Method in class alluxio.client.block.AlluxioBlockStore
Gets a stream to read the data of a block.
getLocalWorker() - Method in class alluxio.client.file.FileSystemContext
 
getLocationPolicy() - Method in class alluxio.client.file.options.OutStreamOptions
 
getMasterAddress() - Method in class alluxio.client.file.FileSystemContext
 
getMasterClientContext() - Method in class alluxio.client.file.FileSystemContext
 
getMasterInfo(Set<MasterInfoField>) - Method in interface alluxio.client.meta.MetaMasterClient
 
getMasterInfo(Set<MasterInfoField>) - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
getMediumType() - Method in class alluxio.client.file.options.OutStreamOptions
 
getMetrics() - Method in interface alluxio.client.meta.MetaMasterClient
Gets a map of metrics property names and their values from metrics system.
getMetrics() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
getMode() - Method in class alluxio.client.file.options.OutStreamOptions
 
getMountId() - Method in class alluxio.client.file.options.OutStreamOptions
 
getMountTable() - Method in class alluxio.client.file.BaseFileSystem
 
getMountTable() - Method in interface alluxio.client.file.FileSystem
Lists all mount points and their corresponding under storage addresses.
getMountTable() - Method in interface alluxio.client.file.FileSystemMasterClient
Lists all mount points and their corresponding under storage addresses.
getMountTable() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
getNetAddress() - Method in class alluxio.client.block.BlockWorkerInfo
 
getNewBlockIdForFile(AlluxioURI) - Method in interface alluxio.client.file.FileSystemMasterClient
 
getNewBlockIdForFile(AlluxioURI) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
getOpenUfsBlockOptions(long) - Method in class alluxio.client.file.options.InStreamOptions
 
getOptions() - Method in class alluxio.client.file.options.InStreamOptions
 
getOutStream(long, long, WorkerNetAddress, OutStreamOptions) - Method in class alluxio.client.block.AlluxioBlockStore
Gets a stream to write data to a block.
getOutStream(long, long, OutStreamOptions) - Method in class alluxio.client.block.AlluxioBlockStore
Gets a stream to write data to a block based on the options.
getOwner() - Method in class alluxio.client.file.options.OutStreamOptions
 
getPathConf(AlluxioURI) - Method in class alluxio.client.file.FileSystemContext
The path level configuration is a SpecificPathConfiguration.
getPersistenceWaitTime() - Method in class alluxio.client.file.options.OutStreamOptions
 
getPos() - Method in class alluxio.client.block.stream.BlockInStream
 
getPos() - Method in class alluxio.client.file.FileInStream
 
getRemoteServiceType() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
 
getRemoteServiceType() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
getRemoteServiceType() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
getRemoteServiceType() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
getRemoteServiceType() - Method in class alluxio.client.metrics.MetricsMasterClient
 
getReplicationDurable() - Method in class alluxio.client.file.options.OutStreamOptions
 
getReplicationMax() - Method in class alluxio.client.file.options.OutStreamOptions
 
getReplicationMin() - Method in class alluxio.client.file.options.OutStreamOptions
 
getServiceName() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
 
getServiceName() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
getServiceName() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
getServiceName() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
getServiceName() - Method in class alluxio.client.metrics.MetricsMasterClient
 
getServiceVersion() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
 
getServiceVersion() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
getServiceVersion() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient
 
getServiceVersion() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
getServiceVersion() - Method in class alluxio.client.metrics.MetricsMasterClient
 
getSource() - Method in class alluxio.client.block.stream.BlockInStream
 
getStatus(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
getStatus(AlluxioURI, GetStatusPOptions) - Method in class alluxio.client.file.BaseFileSystem
 
getStatus(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.getStatus(AlluxioURI, GetStatusPOptions) with default options.
getStatus(AlluxioURI, GetStatusPOptions) - Method in interface alluxio.client.file.FileSystem
Gets the URIStatus object that represents the metadata of an Alluxio path.
getStatus(AlluxioURI, GetStatusPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
 
getStatus() - Method in class alluxio.client.file.options.InStreamOptions
 
getStatus(AlluxioURI, GetStatusPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
getStatusDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
getSyncPathList() - Method in class alluxio.client.file.BaseFileSystem
 
getSyncPathList() - Method in interface alluxio.client.file.FileSystem
Lists all the actively synced paths.
getSyncPathList() - Method in interface alluxio.client.file.FileSystemMasterClient
get the list of paths that are currently being actively synced.
getSyncPathList() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
getUfsPath() - Method in class alluxio.client.file.options.OutStreamOptions
 
getUfsReadLocationPolicy() - Method in class alluxio.client.file.options.InStreamOptions
 
getUnderStorageType() - Method in class alluxio.client.file.options.OutStreamOptions
 
getUnderStorageType() - Method in enum alluxio.client.WriteType
 
getUsedBytes() - Method in class alluxio.client.block.AlluxioBlockStore
Gets the used bytes of Alluxio's BlockStore.
getUsedBytes() - Method in interface alluxio.client.block.BlockMasterClient
Gets the total amount of used space in bytes, on all the tiers of all the workers.
getUsedBytes() - Method in class alluxio.client.block.BlockWorkerInfo
 
getUsedBytes() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
Gets the total amount of used space in bytes, on all the tiers of all the workers.
getValue() - Method in enum alluxio.client.ReadType
 
getValue() - Method in enum alluxio.client.WriteType
 
getWorker(GetWorkerOptions) - Method in interface alluxio.client.block.policy.BlockLocationPolicy
Gets the worker's network address for serving operations requested for the block.
getWorker(GetWorkerOptions) - Method in class alluxio.client.block.policy.DeterministicHashPolicy
 
getWorker(GetWorkerOptions) - Method in class alluxio.client.block.policy.LocalFirstAvoidEvictionPolicy
 
getWorker(GetWorkerOptions) - Method in class alluxio.client.block.policy.LocalFirstPolicy
 
getWorker(GetWorkerOptions) - Method in class alluxio.client.block.policy.MostAvailableFirstPolicy
 
getWorker(GetWorkerOptions) - Method in class alluxio.client.block.policy.RoundRobinPolicy
The policy uses the first fetch of worker info list as the base, and visits each of them in a round-robin manner in the subsequent calls.
getWorker(GetWorkerOptions) - Method in class alluxio.client.block.policy.SpecificHostPolicy
 
getWorkerInfoList() - Method in interface alluxio.client.block.BlockMasterClient
Gets the worker information of live workers(support older version Alluxio server).
getWorkerInfoList() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
 
getWorkerLostStorage() - Method in interface alluxio.client.block.BlockMasterClient
 
getWorkerLostStorage() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
 
GetWorkerOptions - Class in alluxio.client.block.policy.options
getWorkerRange() - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
getWorkerReport(GetWorkerReportOptions) - Method in interface alluxio.client.block.BlockMasterClient
Gets the worker information of selected workers and selected fields for report CLI.
getWorkerReport(GetWorkerReportOptions) - Method in class alluxio.client.block.RetryHandlingBlockMasterClient
 
GetWorkerReportOptions - Class in alluxio.client.block.options
Worker information options.
GetWorkerReportOptions(GetWorkerReportPOptions) - Constructor for class alluxio.client.block.options.GetWorkerReportOptions
Creates a new instance of GetWorkerReportOptions from a proto representation.
GetWorkerReportOptions.WorkerInfoField - Enum in alluxio.client.block.options
Enum representing the fields of the worker information.
GetWorkerReportOptions.WorkerRange - Enum in alluxio.client.block.options
Enum representing the range of workers that we want to show capacity information for.
getWriteTier() - Method in class alluxio.client.file.options.OutStreamOptions
 
getWriteType() - Method in class alluxio.client.file.options.OutStreamOptions
 
GrpcBlockingStream<ReqT,ResT> - Class in alluxio.client.block.stream
A helper class for accessing gRPC bi-directional stream synchronously.
GrpcBlockingStream(Function<StreamObserver<ResT>, StreamObserver<ReqT>>, int, String) - Constructor for class alluxio.client.block.stream.GrpcBlockingStream
 
GrpcDataMessageBlockingStream<ReqT,ResT> - Class in alluxio.client.block.stream
A helper class for accessing gRPC bi-directional stream synchronously.
GrpcDataMessageBlockingStream(Function<StreamObserver<ResT>, StreamObserver<ReqT>>, int, String, DataMessageMarshaller<ReqT>, DataMessageMarshaller<ResT>) - Constructor for class alluxio.client.block.stream.GrpcDataMessageBlockingStream
 
GrpcDataReader - Class in alluxio.client.block.stream
A gRPC data reader that streams a region from gRPC data server.
GrpcDataReader.Factory - Class in alluxio.client.block.stream
Factory class to create GrpcDataReaders.
GrpcDataWriter - Class in alluxio.client.block.stream
A gRPC data writer that streams a full block or a UFS file to a gRPC data server.

H

hashCode() - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
hashCode() - Method in class alluxio.client.block.policy.DeterministicHashPolicy
 
hashCode() - Method in class alluxio.client.block.policy.LocalFirstAvoidEvictionPolicy
 
hashCode() - Method in class alluxio.client.block.policy.LocalFirstPolicy
 
hashCode() - Method in class alluxio.client.block.policy.MostAvailableFirstPolicy
 
hashCode() - Method in class alluxio.client.block.policy.options.GetWorkerOptions
 
hashCode() - Method in class alluxio.client.block.policy.RoundRobinPolicy
 
hashCode() - Method in class alluxio.client.block.policy.SpecificHostPolicy
 
hashCode() - Method in class alluxio.client.file.FileSystem.FileSystemKey
 
hashCode() - Method in class alluxio.client.file.options.InStreamOptions
 
hashCode() - Method in class alluxio.client.file.options.OutStreamOptions
 
hasLocalWorker() - Method in class alluxio.client.file.FileSystemContext
 
heartbeat() - Method in class alluxio.client.file.ConfigHashSync
 
heartbeat() - Method in class alluxio.client.metrics.ClientMasterSync
Sends metrics to the master keyed with appId and client hostname.
heartbeat(List<ClientMetrics>) - Method in class alluxio.client.metrics.MetricsMasterClient
The method the worker should periodically execute to heartbeat back to the master.

I

InStreamOptions - Class in alluxio.client.file.options
Information for reading a file.
InStreamOptions(URIStatus, AlluxioConfiguration) - Constructor for class alluxio.client.file.options.InStreamOptions
Creates with the default OpenFilePOptions.
InStreamOptions(URIStatus, OpenFilePOptions, AlluxioConfiguration) - Constructor for class alluxio.client.file.options.InStreamOptions
Creates with given OpenFilePOptions instance.
interceptCall(MethodDescriptor<ReqT, RespT>, CallOptions, Channel) - Method in class alluxio.client.block.stream.StreamSerializationClientInterceptor
 
isAsync() - Method in enum alluxio.client.WriteType
 
isAsyncPersist() - Method in enum alluxio.client.UnderStorageType
 
isCache() - Method in enum alluxio.client.ReadType
 
isCache() - Method in enum alluxio.client.WriteType
 
isCanceled() - Method in class alluxio.client.block.stream.GrpcBlockingStream
 
isClosed() - Method in class alluxio.client.block.stream.GrpcBlockingStream
 
isClosed() - Method in class alluxio.client.file.BaseFileSystem
 
isClosed() - Method in interface alluxio.client.file.FileSystem
If there are operations currently running and close is called concurrently the behavior is undefined.
isClosedFromRemote() - Method in class alluxio.client.block.stream.GrpcBlockingStream
 
isHealthy() - Method in interface alluxio.client.block.stream.BlockWorkerClient
 
isHealthy(BlockWorkerClient) - Method in class alluxio.client.block.stream.BlockWorkerClientPool
Checks whether a client is healthy.
isHealthy() - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
isOpen() - Method in class alluxio.client.block.stream.GrpcBlockingStream
 
isPromote() - Method in enum alluxio.client.AlluxioStorageType
 
isPromote() - Method in enum alluxio.client.ReadType
 
isShortCircuit() - Method in class alluxio.client.block.stream.BlockInStream
 
isShortCircuit() - Method in interface alluxio.client.block.stream.DataReader.Factory
 
isShortCircuit() - Method in class alluxio.client.block.stream.GrpcDataReader.Factory
 
isShortCircuit() - Method in class alluxio.client.block.stream.LocalFileDataReader.Factory
 
isShutdown() - Method in interface alluxio.client.block.stream.BlockWorkerClient
 
isShutdown() - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
isStore() - Method in enum alluxio.client.AlluxioStorageType
 
isSyncPersist() - Method in enum alluxio.client.UnderStorageType
 
isThrough() - Method in enum alluxio.client.WriteType
 

L

listStatus(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
listStatus(AlluxioURI, ListStatusPOptions) - Method in class alluxio.client.file.BaseFileSystem
 
listStatus(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.listStatus(AlluxioURI, ListStatusPOptions) with default options.
listStatus(AlluxioURI, ListStatusPOptions) - Method in interface alluxio.client.file.FileSystem
If the path is a directory, returns the URIStatus of all the direct entries in it.
listStatus(AlluxioURI, ListStatusPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
 
listStatus(AlluxioURI, ListStatusPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
listStatusDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
loadMetadataDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
LocalFileDataReader - Class in alluxio.client.block.stream
A data reader that simply reads packets from a local file.
LocalFileDataReader.Factory - Class in alluxio.client.block.stream
Factory class to create LocalFileDataReaders.
LocalFileDataWriter - Class in alluxio.client.block.stream
A local data writer that simply writes packets to a local file.
LocalFirstAvoidEvictionPolicy - Class in alluxio.client.block.policy
A policy that returns local host first, and if the local worker doesn't have enough availability, it randomly picks a worker from the active workers list for each block write.
LocalFirstAvoidEvictionPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.LocalFirstAvoidEvictionPolicy
LocalFirstPolicy - Class in alluxio.client.block.policy
A policy that returns local host first, and if the local worker doesn't have enough availability, it randomly picks a worker from the active workers list for each block write.
LocalFirstPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.LocalFirstPolicy
Constructs a new LocalFirstPolicy.
LOG - Static variable in class alluxio.client.block.stream.DataWriter.Factory
 

M

mBlockStore - Variable in class alluxio.client.file.BaseFileSystem
 
mBytesWritten - Variable in class alluxio.client.AbstractOutStream
The number of bytes written.
mCachingEnabled - Variable in class alluxio.client.file.BaseFileSystem
 
MetaMasterClient - Interface in alluxio.client.meta
Interface for a meta master client.
MetaMasterConfigClient - Interface in alluxio.client.meta
Interface for a meta master config client.
MetricsHeartbeatContext - Class in alluxio.client.metrics
A class used to track metrics heartbeats to a master.
MetricsMasterClient - Class in alluxio.client.metrics
A client to use for interacting with a metrics master.
MetricsMasterClient(MasterClientContext) - Constructor for class alluxio.client.metrics.MetricsMasterClient
Creates a new metrics master client.
mFsContext - Variable in class alluxio.client.file.BaseFileSystem
 
MostAvailableFirstPolicy - Class in alluxio.client.block.policy
A policy that returns the worker with the most available bytes.
MostAvailableFirstPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.MostAvailableFirstPolicy
Constructs a new MostAvailableFirstPolicy.
mount(AlluxioURI, AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
mount(AlluxioURI, AlluxioURI, MountPOptions) - Method in class alluxio.client.file.BaseFileSystem
 
mount(AlluxioURI, AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.mount(AlluxioURI, AlluxioURI, MountPOptions) with default options.
mount(AlluxioURI, AlluxioURI, MountPOptions) - Method in interface alluxio.client.file.FileSystem
Mounts a UFS subtree to the given Alluxio path.
mount(AlluxioURI, AlluxioURI, MountPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Mounts the given UFS path under the given Alluxio path.
mount(AlluxioURI, AlluxioURI, MountPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
mountDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
moveBlock(MoveBlockRequest) - Method in interface alluxio.client.block.stream.BlockWorkerClient
Move a block from worker.
moveBlock(MoveBlockRequest) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
mUri - Variable in class alluxio.client.file.FileOutStream
 

N

nearest(TieredIdentity, List<WorkerNetAddress>, AlluxioConfiguration) - Static method in class alluxio.client.block.util.BlockLocationUtils
 

O

onCompleted() - Method in class alluxio.client.block.stream.DataMessageClientResponseObserver
 
onError(Throwable) - Method in class alluxio.client.block.stream.DataMessageClientResponseObserver
 
onNext(RespT) - Method in class alluxio.client.block.stream.DataMessageClientResponseObserver
 
onSuccess() - Method in class alluxio.client.file.FileSystemContextReinitializer
Notifies that the reinitialization has succeeded.
openFile(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
openFile(AlluxioURI, OpenFilePOptions) - Method in class alluxio.client.file.BaseFileSystem
 
openFile(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.openFile(AlluxioURI, OpenFilePOptions) with default options.
openFile(AlluxioURI, OpenFilePOptions) - Method in interface alluxio.client.file.FileSystem
Opens a file for reading.
openFileDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
openLocalBlock(StreamObserver<OpenLocalBlockResponse>) - Method in interface alluxio.client.block.stream.BlockWorkerClient
Opens a local block.
openLocalBlock(StreamObserver<OpenLocalBlockResponse>) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
OutStreamOptions - Class in alluxio.client.file.options
Method options for writing a file.
OutStreamOptions(CreateFilePOptions, ClientContext, AlluxioConfiguration) - Constructor for class alluxio.client.file.options.OutStreamOptions
Creates an OutStreamOptions instance from given options.

P

persist(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
persist(AlluxioURI, ScheduleAsyncPersistencePOptions) - Method in class alluxio.client.file.BaseFileSystem
 
persist(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.persist(AlluxioURI, ScheduleAsyncPersistencePOptions) which uses the default ScheduleAsyncPersistencePOptions.
persist(AlluxioURI, ScheduleAsyncPersistencePOptions) - Method in interface alluxio.client.file.FileSystem
Schedules the given path to be asynchronously persisted to the under file system.
persistAndWait(FileSystem, AlluxioURI, long) - Static method in class alluxio.client.file.FileSystemUtils
Convenience method for #persistAndWait(fs, uri, persistenceWaitTime, -1).
persistAndWait(FileSystem, AlluxioURI, long, int) - Static method in class alluxio.client.file.FileSystemUtils
Persists the given path to the under file system and returns once the persist is complete.
pos() - Method in interface alluxio.client.block.stream.DataReader
 
pos() - Method in interface alluxio.client.block.stream.DataWriter
 
pos() - Method in class alluxio.client.block.stream.GrpcDataReader
 
pos() - Method in class alluxio.client.block.stream.GrpcDataWriter
 
pos() - Method in class alluxio.client.block.stream.LocalFileDataReader
 
pos() - Method in class alluxio.client.block.stream.LocalFileDataWriter
 
pos() - Method in class alluxio.client.block.stream.UfsFallbackLocalFileDataWriter
 
positionedRead(long, byte[], int, int) - Method in class alluxio.client.block.stream.BlockInStream
 
positionedRead(long, byte[], int, int) - Method in class alluxio.client.file.FileInStream
 
positionedRead(long, byte[], int, int) - Method in interface alluxio.client.PositionedReadable
Reads up to the specified number of bytes, from a given position within a file, and return the number of bytes read.
PositionedReadable - Interface in alluxio.client
Stream that permits positional reading.

R

read() - Method in class alluxio.client.block.stream.BlockInStream
 
read(byte[]) - Method in class alluxio.client.block.stream.BlockInStream
 
read(byte[], int, int) - Method in class alluxio.client.block.stream.BlockInStream
 
read() - Method in class alluxio.client.file.FileInStream
 
read(byte[]) - Method in class alluxio.client.file.FileInStream
 
read(byte[], int, int) - Method in class alluxio.client.file.FileInStream
 
readBlock(StreamObserver<ReadResponse>) - Method in interface alluxio.client.block.stream.BlockWorkerClient
Reads a block from the worker.
readBlock(StreamObserver<ReadResponse>) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
readChunk() - Method in interface alluxio.client.block.stream.DataReader
Reads a chunk.
readChunk() - Method in class alluxio.client.block.stream.GrpcDataReader
 
readChunk() - Method in class alluxio.client.block.stream.LocalFileDataReader
 
ReadType - Enum in alluxio.client
Convenience modes for commonly used read types.
receive(long) - Method in class alluxio.client.block.stream.GrpcBlockingStream
Receives a response from the server.
receive(long) - Method in class alluxio.client.block.stream.GrpcDataMessageBlockingStream
 
receiveDataMessage(long) - Method in class alluxio.client.block.stream.GrpcDataMessageBlockingStream
Receives a response with data buffer from the server.
reinit(boolean, boolean) - Method in class alluxio.client.file.FileSystemContext
Closes the context, updates configuration from meta master, then re-initializes the context.
ReinitAllowerResource(CountingLatch) - Constructor for class alluxio.client.file.FileSystemContextReinitializer.ReinitAllowerResource
Waits the count to reach zero, then blocks further constructions of FileSystemContextReinitializer.ReinitBlockerResource until FileSystemContextReinitializer.ReinitAllowerResource.close().
ReinitBlockerResource(CountingLatch) - Constructor for class alluxio.client.file.FileSystemContextReinitializer.ReinitBlockerResource
Increases the count of the latch.
releaseBlockWorkerClient(WorkerNetAddress, BlockWorkerClient) - Method in class alluxio.client.file.FileSystemContext
Releases a block worker client to the client pools.
remaining() - Method in class alluxio.client.block.stream.BlockInStream
 
remaining() - Method in class alluxio.client.block.stream.BlockOutStream
 
remaining() - Method in interface alluxio.client.BoundedStream
 
remaining() - Method in class alluxio.client.file.FileInStream
 
remove(FileSystem.FileSystemKey) - Method in class alluxio.client.file.FileSystem.Cache
Removes the client with the given key from the cache.
removeBlock(RemoveBlockRequest) - Method in interface alluxio.client.block.stream.BlockWorkerClient
Removes a block from worker.
removeBlock(RemoveBlockRequest) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
removeHeartbeat(ClientContext) - Static method in class alluxio.client.metrics.MetricsHeartbeatContext
Removes an application from the metrics heartbeat.
removePathConfiguration(AlluxioURI, Set<PropertyKey>) - Method in interface alluxio.client.meta.MetaMasterConfigClient
Removes properties for a path.
removePathConfiguration(AlluxioURI) - Method in interface alluxio.client.meta.MetaMasterConfigClient
Removes all properties for a path.
removePathConfiguration(AlluxioURI, Set<PropertyKey>) - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
removePathConfiguration(AlluxioURI) - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
rename(AlluxioURI, AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
rename(AlluxioURI, AlluxioURI, RenamePOptions) - Method in class alluxio.client.file.BaseFileSystem
 
rename(AlluxioURI, AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.rename(AlluxioURI, AlluxioURI, RenamePOptions) with default options.
rename(AlluxioURI, AlluxioURI, RenamePOptions) - Method in interface alluxio.client.file.FileSystem
Renames an existing Alluxio path to another Alluxio path in Alluxio.
rename(AlluxioURI, AlluxioURI) - Method in interface alluxio.client.file.FileSystemMasterClient
Renames a file or a directory.
rename(AlluxioURI, AlluxioURI, RenamePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Renames a file or a directory.
rename(AlluxioURI, AlluxioURI) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
rename(AlluxioURI, AlluxioURI, RenamePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
renameDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
resetMetaMasterConfigClient(MasterClientContext) - Method in class alluxio.client.file.ConfigHashSync
Resets the internal meta master client based on the new configuration.
RetryHandlingBlockMasterClient - Class in alluxio.client.block
A wrapper for the gRPC client to interact with the block master, used by alluxio clients.
RetryHandlingBlockMasterClient(MasterClientContext) - Constructor for class alluxio.client.block.RetryHandlingBlockMasterClient
Creates a new block master client.
RetryHandlingFileSystemMasterClient - Class in alluxio.client.file
A wrapper for the gRPC client to interact with the file system master, used by alluxio clients.
RetryHandlingFileSystemMasterClient(MasterClientContext) - Constructor for class alluxio.client.file.RetryHandlingFileSystemMasterClient
Creates a new RetryHandlingFileSystemMasterClient instance.
RetryHandlingMetaMasterClient - Class in alluxio.client.meta
A wrapper for the gRPC client to interact with the meta master.
RetryHandlingMetaMasterClient(MasterClientContext) - Constructor for class alluxio.client.meta.RetryHandlingMetaMasterClient
Creates a new meta master client.
RetryHandlingMetaMasterConfigClient - Class in alluxio.client.meta
A wrapper for the gRPC client to interact with the meta master.
RetryHandlingMetaMasterConfigClient(MasterClientContext) - Constructor for class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
Creates a new meta master client.
RoundRobinPolicy - Class in alluxio.client.block.policy
A policy that chooses the worker for the next block in a round-robin manner and skips workers that do not have enough space.
RoundRobinPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.RoundRobinPolicy
Constructs a new RoundRobinPolicy.

S

scheduleAsyncPersist(AlluxioURI, ScheduleAsyncPersistencePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Schedules the async persistence of the given file.
scheduleAsyncPersist(AlluxioURI, ScheduleAsyncPersistencePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
scheduleAsyncPersistDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
scheduleAsyncPersistenceDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
seek(long) - Method in class alluxio.client.block.stream.BlockInStream
 
seek(long) - Method in class alluxio.client.file.FileInStream
 
send(ReqT, long) - Method in class alluxio.client.block.stream.GrpcBlockingStream
Sends a request.
send(ReqT) - Method in class alluxio.client.block.stream.GrpcBlockingStream
Sends a request.
sendDataMessage(DataMessage<ReqT, DataBuffer>, long) - Method in class alluxio.client.block.stream.GrpcDataMessageBlockingStream
Sends a request.
setAcl(AlluxioURI, SetAclAction, List<AclEntry>) - Method in class alluxio.client.file.BaseFileSystem
 
setAcl(AlluxioURI, SetAclAction, List<AclEntry>, SetAclPOptions) - Method in class alluxio.client.file.BaseFileSystem
 
setAcl(AlluxioURI, SetAclAction, List<AclEntry>) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.setAcl(AlluxioURI, SetAclAction, List, SetAclPOptions) with default options.
setAcl(AlluxioURI, SetAclAction, List<AclEntry>, SetAclPOptions) - Method in interface alluxio.client.file.FileSystem
Sets the ACL for a path.
setAcl(AlluxioURI, SetAclAction, List<AclEntry>, SetAclPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Sets the ACL for a path.
setAcl(AccessControlList) - Method in class alluxio.client.file.options.OutStreamOptions
Sets the acl of the file.
setAcl(AlluxioURI, SetAclAction, List<AclEntry>, SetAclPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
setAclDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
setAddresses(Set<String>) - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
setAttribute(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
setAttribute(AlluxioURI, SetAttributePOptions) - Method in class alluxio.client.file.BaseFileSystem
 
setAttribute(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.setAttribute(AlluxioURI, SetAttributePOptions) with default options.
setAttribute(AlluxioURI, SetAttributePOptions) - Method in interface alluxio.client.file.FileSystem
Sets any number of a path's attributes, such as TTL and pin status.
setAttribute(AlluxioURI, SetAttributePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Sets the file or directory attributes.
setAttribute(AlluxioURI, SetAttributePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
setAttributeClientDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
Defaults for the SetAttribute RPC which should only be used on the client side.
setAttributeDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
setBlockInfo(BlockInfo) - Method in class alluxio.client.block.policy.options.GetWorkerOptions
 
setBlockSizeBytes(long) - Method in class alluxio.client.file.options.OutStreamOptions
Sets the size of the block in bytes.
setBlockWorkerInfos(List<BlockWorkerInfo>) - Method in class alluxio.client.block.policy.options.GetWorkerOptions
 
setFieldRange(Set<GetWorkerReportOptions.WorkerInfoField>) - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
setGroup(String) - Method in class alluxio.client.file.options.OutStreamOptions
 
setLocationPolicy(BlockLocationPolicy) - Method in class alluxio.client.file.options.OutStreamOptions
 
setMediumType(String) - Method in class alluxio.client.file.options.OutStreamOptions
Set the write medium type of the file.
setMode(Mode) - Method in class alluxio.client.file.options.OutStreamOptions
 
setMountId(long) - Method in class alluxio.client.file.options.OutStreamOptions
 
setOwner(String) - Method in class alluxio.client.file.options.OutStreamOptions
 
setPathConfiguration(AlluxioURI, PropertyKey, String) - Method in interface alluxio.client.meta.MetaMasterConfigClient
Sets a property for a path.
setPathConfiguration(AlluxioURI, Map<PropertyKey, String>) - Method in interface alluxio.client.meta.MetaMasterConfigClient
Sets properties for a path.
setPathConfiguration(AlluxioURI, Map<PropertyKey, String>) - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient
 
setPersistenceWaitTime(long) - Method in class alluxio.client.file.options.OutStreamOptions
 
setReplicationDurable(int) - Method in class alluxio.client.file.options.OutStreamOptions
 
setReplicationMax(int) - Method in class alluxio.client.file.options.OutStreamOptions
 
setReplicationMin(int) - Method in class alluxio.client.file.options.OutStreamOptions
 
setUfsPath(String) - Method in class alluxio.client.file.options.OutStreamOptions
 
setUfsReadLocationPolicy(BlockLocationPolicy) - Method in class alluxio.client.file.options.InStreamOptions
Sets block read location policy.
setWorkerRange(GetWorkerReportOptions.WorkerRange) - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
setWriteTier(int) - Method in class alluxio.client.file.options.OutStreamOptions
Sets the write tier.
setWriteType(WriteType) - Method in class alluxio.client.file.options.OutStreamOptions
Sets the WriteType.
shouldGc(DynamicResourcePool<BlockWorkerClient>.ResourceInternal<BlockWorkerClient>) - Method in class alluxio.client.block.stream.BlockWorkerClientPool
 
skip(long) - Method in class alluxio.client.block.stream.BlockInStream
 
skip(long) - Method in class alluxio.client.file.FileInStream
 
SpecificHostPolicy - Class in alluxio.client.block.policy
Always returns a worker with the specified hostname.
SpecificHostPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.SpecificHostPolicy
Constructs a new SpecificHostPolicy.
SpecificHostPolicy(String) - Constructor for class alluxio.client.block.policy.SpecificHostPolicy
Constructs the policy with the hostname.
startSync(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
Starts the active syncing process on an Alluxio path.
startSync(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Starts the active syncing process on an Alluxio path.
startSync(AlluxioURI) - Method in interface alluxio.client.file.FileSystemMasterClient
Start the active syncing process for a specified path.
startSync(AlluxioURI) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
stopSync(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
Stops the active syncing process on an Alluxio path.
stopSync(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Stops the active syncing process on an Alluxio path.
stopSync(AlluxioURI) - Method in interface alluxio.client.file.FileSystemMasterClient
Stop the active syncing process for a specified path.
stopSync(AlluxioURI) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
StreamSerializationClientInterceptor - Class in alluxio.client.block.stream
Serialization interceptor for client.
StreamSerializationClientInterceptor() - Constructor for class alluxio.client.block.stream.StreamSerializationClientInterceptor
 

T

toProto() - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
toProto() - Method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerInfoField
 
toProto() - Method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerRange
 
toProto() - Method in enum alluxio.client.ReadType
 
toProto() - Method in enum alluxio.client.WriteType
 
toString() - Method in class alluxio.client.block.BlockWorkerInfo
 
toString() - Method in class alluxio.client.block.options.GetWorkerReportOptions
 
toString() - Method in class alluxio.client.block.policy.DeterministicHashPolicy
 
toString() - Method in class alluxio.client.block.policy.LocalFirstAvoidEvictionPolicy
 
toString() - Method in class alluxio.client.block.policy.LocalFirstPolicy
 
toString() - Method in class alluxio.client.block.policy.MostAvailableFirstPolicy
 
toString() - Method in class alluxio.client.block.policy.options.GetWorkerOptions
 
toString() - Method in class alluxio.client.block.policy.RoundRobinPolicy
 
toString() - Method in class alluxio.client.block.policy.SpecificHostPolicy
 
toString() - Method in class alluxio.client.file.options.InStreamOptions
 
toString() - Method in class alluxio.client.file.options.OutStreamOptions
 

U

UfsFallbackLocalFileDataWriter - Class in alluxio.client.block.stream
A data writer that writes to local first and fallback to UFS block writes when the block storage on this local worker is full.
UnderFileSystemFileOutStream - Class in alluxio.client.block.stream
Provides a streaming API to write to a file in the under file system through an Alluxio worker's data server.
UnderFileSystemFileOutStream(DataWriter, WorkerNetAddress) - Constructor for class alluxio.client.block.stream.UnderFileSystemFileOutStream
Constructs a new UnderFileSystemFileOutStream with only one DataWriter.
UnderStorageType - Enum in alluxio.client
Specifies the type of data interaction with Alluxio's Under Storage.
unmount(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem
 
unmount(AlluxioURI, UnmountPOptions) - Method in class alluxio.client.file.BaseFileSystem
 
unmount(AlluxioURI) - Method in interface alluxio.client.file.FileSystem
Convenience method for FileSystem.unmount(AlluxioURI, UnmountPOptions) with default options.
unmount(AlluxioURI, UnmountPOptions) - Method in interface alluxio.client.file.FileSystem
Unmounts a UFS subtree identified by the given Alluxio path.
unmount(AlluxioURI) - Method in interface alluxio.client.file.FileSystemMasterClient
Unmounts the given Alluxio path.
unmount(AlluxioURI) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
unmountDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptions
 
updateMount(AlluxioURI, MountPOptions) - Method in class alluxio.client.file.BaseFileSystem
 
updateMount(AlluxioURI, MountPOptions) - Method in interface alluxio.client.file.FileSystem
Updates the options for an existing mount point.
updateMount(AlluxioURI, MountPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Updates options of a mount point for the given Alluxio path.
updateMount(AlluxioURI, MountPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 
updateUfsMode(AlluxioURI, UpdateUfsModePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient
Updates the operation mode for the given ufs path.
updateUfsMode(AlluxioURI, UpdateUfsModePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient
 

V

valueOf(String) - Static method in enum alluxio.client.AlluxioStorageType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerInfoField
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerRange
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum alluxio.client.block.stream.BlockInStream.BlockInStreamSource
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum alluxio.client.ReadType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum alluxio.client.UnderStorageType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum alluxio.client.WriteType
Returns the enum constant of this type with the specified name.
values() - Static method in enum alluxio.client.AlluxioStorageType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerInfoField
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerRange
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum alluxio.client.block.stream.BlockInStream.BlockInStreamSource
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum alluxio.client.ReadType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum alluxio.client.UnderStorageType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum alluxio.client.WriteType
Returns an array containing the constants of this enum type, in the order they are declared.

W

waitCompleted(FileSystem, AlluxioURI) - Static method in class alluxio.client.file.FileSystemUtils
Shortcut for waitCompleted(fs, uri, -1, TimeUnit.MILLISECONDS), i.e., wait for an indefinite amount of time.
waitCompleted(FileSystem, AlluxioURI, long, TimeUnit) - Static method in class alluxio.client.file.FileSystemUtils
Waits for a file to be marked as completed.
waitForComplete(long) - Method in class alluxio.client.block.stream.GrpcBlockingStream
Wait for server to complete the inbound stream.
waitForComplete(long) - Method in class alluxio.client.block.stream.GrpcDataMessageBlockingStream
 
write(int) - Method in class alluxio.client.block.stream.BlockOutStream
 
write(byte[]) - Method in class alluxio.client.block.stream.BlockOutStream
 
write(byte[], int, int) - Method in class alluxio.client.block.stream.BlockOutStream
 
write(ByteBuf) - Method in class alluxio.client.block.stream.BlockOutStream
Writes the data in the specified byte buf to this output stream.
write(ByteBuf, int, int) - Method in class alluxio.client.block.stream.BlockOutStream
Writes len bytes from the specified byte buf starting at offset off to this output stream.
write(int) - Method in class alluxio.client.file.FileOutStream
 
write(byte[]) - Method in class alluxio.client.file.FileOutStream
 
write(byte[], int, int) - Method in class alluxio.client.file.FileOutStream
 
writeBlock(StreamObserver<WriteResponse>) - Method in interface alluxio.client.block.stream.BlockWorkerClient
Writes a block to the worker asynchronously.
writeBlock(StreamObserver<WriteResponse>) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient
 
writeChunk(ByteBuf) - Method in interface alluxio.client.block.stream.DataWriter
Writes a chunk.
writeChunk(ByteBuf) - Method in class alluxio.client.block.stream.GrpcDataWriter
 
writeChunk(ByteBuf) - Method in class alluxio.client.block.stream.LocalFileDataWriter
 
writeChunk(ByteBuf) - Method in class alluxio.client.block.stream.UfsFallbackLocalFileDataWriter
 
writeFallbackInitRequest(long) - Method in class alluxio.client.block.stream.GrpcDataWriter
Notifies the server UFS fallback endpoint to start writing a new block by resuming the given number of bytes from block store.
WriteType - Enum in alluxio.client
Write types for creating a file in Alluxio.
A B C D E F G H I L M N O P R S T U V W 
Skip navigation links

Copyright © 2024. All Rights Reserved.