A B C D E F G H I J K L M N O P Q R S T U V W

A

abort(String) - Method in interface alluxio.client.file.cache.PageStore

Abort a temporary file.

abort(String) - Method in class alluxio.client.file.cache.store.LocalPageStore

abort(String) - Method in interface alluxio.client.file.cache.store.PageStoreDir

Abort a temporary file.

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.

add(int) - Method in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

Adds a new size to the encoder.

addHeartbeat(ClientContext, MasterInquireClient) - Static method in class alluxio.client.metrics.MetricsHeartbeatContext

Sets up a new metrics heartbeat with the given client information.

addPage(PageId, PageInfo) - Method in class alluxio.client.file.cache.DefaultPageMetaStore

addPage(PageId, PageInfo) - Method in interface alluxio.client.file.cache.PageMetaStore

Adds a new page to the cache.

addPage(PageId, PageInfo) - Method in class alluxio.client.file.cache.QuotaPageMetaStore

addTempPage(PageId, PageInfo) - Method in class alluxio.client.file.cache.DefaultPageMetaStore

addTempPage(PageId, PageInfo) - Method in interface alluxio.client.file.cache.PageMetaStore

Adds a new temp page to the cache.

addWorkerToCache(Long, WorkerNetAddress) - Method in class alluxio.client.block.policy.CapacityBaseRandomPolicy

AffinityHashAllocator - Class in alluxio.client.file.cache.allocator

Offers stickiness allocation based on the file id.

AffinityHashAllocator(List<PageStoreDir>) - Constructor for class alluxio.client.file.cache.allocator.AffinityHashAllocator

AffinityHashAllocator(List<PageStoreDir>, Function<String, Integer>) - Constructor for class alluxio.client.file.cache.allocator.AffinityHashAllocator

afterConnect() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient

afterConnect() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

afterConnect() - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

afterConnect() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient

afterConnect() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient

afterConnect() - Method in class alluxio.client.metrics.RetryHandlingMetricsMasterClient

aging() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

Decrease each item's clock and clean stale items.

aging() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

aging() - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

A thread-safe method to check aging progress of each segment.

aging() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

aging() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

aging() - Method in interface alluxio.client.file.cache.ShadowCacheManager

Aging all the pages stored in this shadow cache.

ALL - Static variable in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerInfoField

allocate(String, long) - Method in class alluxio.client.file.cache.allocator.AffinityHashAllocator

allocate(String, long) - Method in interface alluxio.client.file.cache.allocator.Allocator

allocate(String, long) - Method in class alluxio.client.file.cache.allocator.HashAllocator

allocate(String, long) - Method in class alluxio.client.file.cache.DefaultPageMetaStore

allocate(String, long) - Method in interface alluxio.client.file.cache.PageMetaStore

Allocator - Interface in alluxio.client.file.cache.allocator

Local cache allocator.

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.cache - package alluxio.client.file.cache

alluxio.client.file.cache.allocator - package alluxio.client.file.cache.allocator

alluxio.client.file.cache.cuckoofilter - package alluxio.client.file.cache.cuckoofilter

alluxio.client.file.cache.evictor - package alluxio.client.file.cache.evictor

alluxio.client.file.cache.filter - package alluxio.client.file.cache.filter

alluxio.client.file.cache.store - package alluxio.client.file.cache.store

alluxio.client.file.options - package alluxio.client.file.options

alluxio.client.journal - package alluxio.client.journal

alluxio.client.meta - package alluxio.client.meta

alluxio.client.metrics - package alluxio.client.metrics

alluxio.util - package alluxio.util

AlluxioFileInStream - Class in alluxio.client.file

An implementation of FileInStream for data stored in Alluxio.

AlluxioFileInStream(URIStatus, InStreamOptions, FileSystemContext) - Constructor for class alluxio.client.file.AlluxioFileInStream

AlluxioFileOutStream - Class in alluxio.client.file

Provides a streaming API to write a file.

AlluxioFileOutStream(AlluxioURI, OutStreamOptions, FileSystemContext) - Constructor for class alluxio.client.file.AlluxioFileOutStream

Creates a new file output stream.

altIndex(int, int, int) - Static method in class alluxio.client.file.cache.cuckoofilter.CuckooUtils

Compute the alternative index on given hash value and tag.

append(PageId, int, byte[], CacheContext) - Method in interface alluxio.client.file.cache.CacheManager

append(PageId, int, byte[], CacheContext) - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

append(PageId, int, byte[], CacheContext) - Method in class alluxio.client.file.cache.LocalCacheManager

append(PageId, int, byte[], CacheContext) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

approximateElementCount() - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

approximateElementCount(CacheScope) - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

approximateElementCount() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

approximateElementCount(CacheScope) - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

approximateElementSize() - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

approximateElementSize(CacheScope) - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

approximateElementSize() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

approximateElementSize(CacheScope) - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

asyncUpdateFileAccessTime(AlluxioURI) - Method in class alluxio.client.file.MetadataCachingFileSystem

Asynchronously update file's last access time.

B

backup(BackupPRequest) - Method in interface alluxio.client.meta.MetaMasterClient

Takes a backup.

backup(BackupPRequest) - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient

BaseFileSystem - Class in alluxio.client.file

Default implementation of the FileSystem interface.

BaseFileSystem(FileSystemContext) - 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.

BlockStoreClient - Class in alluxio.client.block

Alluxio Block Store client.

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(UserState, GrpcServerAddress, int, int, AlluxioConfiguration) - Constructor for class alluxio.client.block.stream.BlockWorkerClientPool

Creates a new block master client pool.

BlockWorkerDataReader - Class in alluxio.client.block.stream

A data reader that reads from a worker in the same process of this client directly.

BlockWorkerDataReader.Factory - Class in alluxio.client.block.stream

Factory class to create BlockWorkerDataReaders.

BlockWorkerDataWriter - Class in alluxio.client.block.stream

A data writer that issues from a client embedded in a worker to write data to the worker directly via internal communication channel.

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.

BufferCachingGrpcDataReader - Class in alluxio.client.block.stream

A gRPC data reader that responsible for reading from a specific block.

BufferCachingGrpcDataReader(WorkerNetAddress, CloseableResource<BlockWorkerClient>, long, ReadRequest, GrpcBlockingStream<ReadRequest, ReadResponse>) - Constructor for class alluxio.client.block.stream.BufferCachingGrpcDataReader

Creates an instance of BufferCachingGrpcDataReader.

build() - Method in class alluxio.client.file.options.FileSystemOptions.Builder

Builder() - Constructor for class alluxio.client.file.options.FileSystemOptions.Builder

Constructor.

byteArray() - Method in class alluxio.client.file.cache.store.ByteArrayTargetBuffer

byteArray() - Method in class alluxio.client.file.cache.store.ByteBufferTargetBuffer

byteArray() - Method in interface alluxio.client.file.cache.store.PageReadTargetBuffer

ByteArrayTargetBuffer - Class in alluxio.client.file.cache.store

Target buffer backed by bytes array for zero-copy read from page store.

ByteArrayTargetBuffer(byte[], int) - Constructor for class alluxio.client.file.cache.store.ByteArrayTargetBuffer

Constructor.

byteBuffer() - Method in class alluxio.client.file.cache.store.ByteArrayTargetBuffer

byteBuffer() - Method in class alluxio.client.file.cache.store.ByteBufferTargetBuffer

byteBuffer() - Method in interface alluxio.client.file.cache.store.PageReadTargetBuffer

ByteBufferTargetBuffer - Class in alluxio.client.file.cache.store

Target buffer backed by nio ByteBuffer for zero-copy read from page store.

ByteBufferTargetBuffer(ByteBuffer) - Constructor for class alluxio.client.file.cache.store.ByteBufferTargetBuffer

Constructor.

byteChannel() - Method in class alluxio.client.file.cache.store.ByteArrayTargetBuffer

byteChannel() - Method in class alluxio.client.file.cache.store.ByteBufferTargetBuffer

byteChannel() - Method in interface alluxio.client.file.cache.store.PageReadTargetBuffer

bytes() - Method in class alluxio.client.file.cache.DefaultPageMetaStore

bytes() - Method in interface alluxio.client.file.cache.PageMetaStore

bytes(CacheScope) - Method in class alluxio.client.file.cache.QuotaPageMetaStore

C

cache(CacheRequest) - Method in interface alluxio.client.block.stream.BlockWorkerClient

Caches a block.

cache(CacheRequest) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient

CACHE_CLEAN_ERRORS - Static variable in class alluxio.client.file.cache.PageStore.Metrics

Number of failures when cleaning out the existing cache directory to initialize a new cache.

CacheEvictor - Interface in alluxio.client.file.cache.evictor

Interface for client-side cache eviction policy.

CacheEvictorOptions - Class in alluxio.client.file.cache.evictor

Options for initiating cache evictor.

CacheEvictorOptions() - Constructor for class alluxio.client.file.cache.evictor.CacheEvictorOptions

CacheFilter - Interface in alluxio.client.file.cache.filter

The Cache Filter interface which is used to determine whether a particular file (URI) needs to be cached.

CacheManager - Interface in alluxio.client.file.cache

Interface for managing cached pages.

CacheManager.Factory - Class in alluxio.client.file.cache

Factory class to get or create a CacheManager.

CacheManager.State - Enum in alluxio.client.file.cache

State of a cache.

CacheManagerOptions - Class in alluxio.client.file.cache

Options for initiating local cache manager.

CacheManagerOptions() - Constructor for class alluxio.client.file.cache.CacheManagerOptions

Constructor.

CacheManagerWithShadowCache - Class in alluxio.client.file.cache

A wrapper class of CacheManager with shadow cache.

CacheManagerWithShadowCache(CacheManager, AlluxioConfiguration) - Constructor for class alluxio.client.file.cache.CacheManagerWithShadowCache

CacheManagerWithShadowCache.PageIdFunnel - Enum in alluxio.client.file.cache

Funnel for PageId.

cancel() - Method in class alluxio.client.block.stream.BlockOutStream

cancel() - Method in class alluxio.client.block.stream.BlockWorkerDataWriter

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.AlluxioFileOutStream

cancel() - Method in class alluxio.client.file.FileOutStream

Aborts the output stream.

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.

CapacityBaseRandomPolicy - Class in alluxio.client.block.policy

Randomly distribute workload based on the worker capacities so bigger workers get more requests.

CapacityBaseRandomPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.CapacityBaseRandomPolicy

Constructs a new CapacityBaseRandomPolicy needed for instantiation in BlockLocationPolicy.Factory.

checkAccess(AlluxioURI, CheckAccessPOptions) - Method in class alluxio.client.file.BaseFileSystem

checkAccess(AlluxioURI, CheckAccessPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

checkAccess(AlluxioURI, CheckAccessPOptions) - Method in interface alluxio.client.file.FileSystem

Checks access to a path.

checkAccess(AlluxioURI, CheckAccessPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient

Check access to a path.

checkAccess(AlluxioURI, CheckAccessPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

checkAccessDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

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.FileSystemOptionsUtils

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

checkUri(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem

Checks an AlluxioURI for scheme and authority information.

chunkSize() - Method in class alluxio.client.block.stream.BlockWorkerDataWriter

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

clear(Path) - Static method in interface alluxio.client.file.cache.store.PageStoreDir

Clear the dir.

clearMetrics(ClearMetricsRequest) - Method in interface alluxio.client.block.stream.BlockWorkerClient

Clear the worker metrics.

clearMetrics(ClearMetricsRequest) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient

clearMetrics() - Method in interface alluxio.client.metrics.MetricsMasterClient

Clear the master metrics.

clearMetrics() - Method in class alluxio.client.metrics.RetryHandlingMetricsMasterClient

ClientMasterSync - Class in alluxio.client.metrics

Task that carries the client metrics information to master through heartheat.

ClientMasterSync(String, ClientContext, MasterInquireClient) - Constructor for class alluxio.client.metrics.ClientMasterSync

Constructs a new ClientMasterSync.

ClockCuckooFilter<T> - Interface in alluxio.client.file.cache.cuckoofilter

This interface represents a clock cuckoo filter that supports Put/Get/Delete operations.

ClockCuckooShadowCacheManager - Class in alluxio.client.file.cache

This class is a shadow cache with ClockCuckooFilter implementation.

ClockCuckooShadowCacheManager(AlluxioConfiguration) - Constructor for class alluxio.client.file.cache.ClockCuckooShadowCacheManager

Create a ClockCuckooShadowCacheManager.

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.BlockWorkerDataReader

close() - Method in class alluxio.client.block.stream.BlockWorkerDataReader.Factory

close() - Method in class alluxio.client.block.stream.BlockWorkerDataWriter

close() - Method in class alluxio.client.block.stream.BufferCachingGrpcDataReader

Closes the BufferCachingGrpcDataReader.

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.SharedGrpcDataReader

close() - Method in class alluxio.client.block.stream.SharedGrpcDataReader.Factory

close() - Method in class alluxio.client.block.stream.UfsFallbackLocalFileDataWriter

close() - Method in class alluxio.client.file.AlluxioFileInStream

close() - Method in class alluxio.client.file.AlluxioFileOutStream

close() - Method in class alluxio.client.file.BaseFileSystem

Shuts down the FileSystem.

close() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

close() - Method in class alluxio.client.file.cache.LocalCacheFileInStream

close() - Method in class alluxio.client.file.cache.LocalCacheManager

close() - Method in class alluxio.client.file.cache.NoExceptionCacheManager

close() - Method in class alluxio.client.file.cache.store.LocalPageStore

close() - Method in class alluxio.client.file.cache.store.MemoryPageStore

close() - Method in interface alluxio.client.file.cache.store.PageStoreDir

Close the page store dir.

close() - Method in class alluxio.client.file.cache.store.RocksPageStore

close() - Method in class alluxio.client.file.cache.TimeBoundPageStore

close() - Method in class alluxio.client.file.ConfigHashSync

close() - Method in class alluxio.client.file.DelegatingFileSystem

close() - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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.MetadataCachingFileSystem

close() - Method in class alluxio.client.metrics.ClientMasterSync

Close the metrics master client.

CLOSED_FS_ERROR_MESSAGE - Static variable in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

closeResource(BlockMasterClient) - Method in class alluxio.client.block.BlockMasterClientPool

closeResource(BlockWorkerClient) - Method in class alluxio.client.block.stream.BlockWorkerClientPool

closeResource(FileSystemMasterClient) - Method in class alluxio.client.file.FileSystemMasterClientPool

commit(String) - Method in interface alluxio.client.file.cache.PageStore

Commit a temporary file.

commit(String, String) - Method in interface alluxio.client.file.cache.PageStore

Commit a temporary file with a new file ID.

commit(String, String) - Method in class alluxio.client.file.cache.store.LocalPageStore

commit(String) - Method in interface alluxio.client.file.cache.store.PageStoreDir

Commit a temporary file.

commit(String, String) - Method in interface alluxio.client.file.cache.store.PageStoreDir

Commit a temporary file with a new file ID.

commitFile(String, String) - Method in class alluxio.client.file.cache.DefaultPageMetaStore

commitFile(String, String) - Method in interface alluxio.client.file.cache.PageMetaStore

Commits a temp file so that all its pages become permanent.

commonDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

commonDefaults(AlluxioConfiguration, boolean) - Static method in class alluxio.util.FileSystemOptionsUtils

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

ConcurrentClockCuckooFilter<T> - Class in alluxio.client.file.cache.cuckoofilter

A concurrent cuckoo filter with three customized field: clock, size and scope.

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(MasterClientContext) - Static method in class alluxio.client.block.BlockMasterClient.Factory

Factory method for BlockMasterClient.

create(FileSystemContext) - Static method in class alluxio.client.block.BlockStoreClient

Creates an Alluxio block store with default local hostname.

create(Class<?>, 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(UserState, GrpcServerAddress, AlluxioConfiguration) - Static method in class alluxio.client.block.stream.BlockWorkerClient.Factory

Creates a new block worker client.

create(long, long) - Method in class alluxio.client.block.stream.BlockWorkerDataReader.Factory

create(FileSystemContext, long, long, OutStreamOptions) - Static method in class alluxio.client.block.stream.BlockWorkerDataWriter

Creates an instance of BlockWorkerDataWriter.

create(FileSystemContext, WorkerNetAddress, ReadRequest) - Static method in class alluxio.client.block.stream.BufferCachingGrpcDataReader

Creates an instance of BufferCachingGrpcDataReader for block reads.

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, long, OutStreamOptions) - Static method in class alluxio.client.block.stream.LocalFileDataWriter

Creates an instance of LocalFileDataWriter.

create(long, long) - Method in class alluxio.client.block.stream.SharedGrpcDataReader.Factory

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(AlluxioConfiguration) - Static method in class alluxio.client.file.cache.CacheManager.Factory

create(AlluxioConfiguration, CacheManagerOptions, PageMetaStore) - Static method in class alluxio.client.file.cache.CacheManager.Factory

create(AlluxioConfiguration) - Static method in class alluxio.client.file.cache.CacheManagerOptions

create(Funnel<? super T>, long, int, int, int, SlidingWindowType, long, double, double, HashFunction) - Static method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

Create a concurrent cuckoo filter with specified parameters.

create(Funnel<? super T>, long, int, int, int, int, SlidingWindowType, long, double, double, HashFunction) - Static method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

Create a concurrent cuckoo filter with size encoder.

create(Funnel<? super T>, long, int, int, int, SlidingWindowType, long, double, double) - Static method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

Create a concurrent cuckoo filter with specified parameters.

create(Funnel<? super T>, long, int, int, int, SlidingWindowType, long, double) - Static method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

Create a concurrent cuckoo filter with specified parameters.

create(Funnel<? super T>, long, int, int, int, SlidingWindowType, long) - Static method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

Create a concurrent cuckoo filter with specified parameters.

create(Funnel<? super T>, long, int, int, int) - Static method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

Create a concurrent cuckoo filter with specified parameters.

create(CacheEvictorOptions) - Static method in interface alluxio.client.file.cache.evictor.CacheEvictor

create(AlluxioConfiguration) - Static method in interface alluxio.client.file.cache.filter.CacheFilter

Create a CacheFilter.

create(CacheManagerOptions, PageMetaStore) - Static method in class alluxio.client.file.cache.LocalCacheManager

create(CacheManagerOptions) - Static method in interface alluxio.client.file.cache.PageMetaStore

create(PageStoreOptions) - Static method in interface alluxio.client.file.cache.PageStore

Create an instance of PageStore.

create(AlluxioConfiguration) - Static method in interface alluxio.client.file.cache.ShadowCacheManager

create(AlluxioConfiguration) - Static method in class alluxio.client.file.cache.store.PageStoreOptions

create() - Static method in class alluxio.client.file.FileSystem.Factory

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(FileSystemContext, FileSystemOptions) - Static method in class alluxio.client.file.FileSystem.Factory

create(AlluxioConfiguration, List<InetSocketAddress>) - Static method in class alluxio.client.file.FileSystemContext

Creates a FileSystemContext with an empty subject , a null local block worker, and the given master addresses.

create() - Static method in class alluxio.client.file.FileSystemContext

Creates a FileSystemContext with an empty subject, default config and a null local block worker.

create(AlluxioConfiguration) - Static method in class alluxio.client.file.FileSystemContext

Creates a FileSystemContext with an empty subject and a null local block worker.

create(Subject, AlluxioConfiguration) - Static method in class alluxio.client.file.FileSystemContext

create(ClientContext) - Static method in class alluxio.client.file.FileSystemContext

create(ClientContext, BlockWorker) - Static method in class alluxio.client.file.FileSystemContext

create(ClientContext, BlockWorker, List<InetSocketAddress>) - 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, java.util.List<java.net.InetSocketAddress>) methods.

create(MasterClientContext) - Static method in class alluxio.client.file.FileSystemMasterClient.Factory

Factory method for FileSystemMasterClient.

create(AlluxioConfiguration) - Static method in class alluxio.client.file.options.FileSystemOptions.Builder

Creates a new Builder based on configuration.

create(AlluxioConfiguration) - Static method in class alluxio.client.file.options.FileSystemOptions

Creates the file system options.

createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in class alluxio.client.file.BaseFileSystem

createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient

Creates a new directory.

createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in class alluxio.client.file.MetadataCachingFileSystem

createDirectory(AlluxioURI, CreateDirectoryPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

createDirectoryDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

createDirectoryDefaults(AlluxioConfiguration, boolean) - Static method in class alluxio.util.FileSystemOptionsUtils

createFile(AlluxioURI, CreateFilePOptions) - Method in class alluxio.client.file.BaseFileSystem

createFile(AlluxioURI, CreateFilePOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

createFile(AlluxioURI, CreateFilePOptions) - Method in interface alluxio.client.file.FileSystemMasterClient

Creates a new file.

createFile(AlluxioURI, CreateFilePOptions) - Method in class alluxio.client.file.MetadataCachingFileSystem

createFile(AlluxioURI, CreateFilePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

createFileDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

createFileDefaults(AlluxioConfiguration, boolean) - Static method in class alluxio.util.FileSystemOptionsUtils

createForWorker(AlluxioConfiguration) - Static method in class alluxio.client.file.cache.CacheManagerOptions

createForWorkerPageStore(AlluxioConfiguration) - Static method in class alluxio.client.file.cache.store.PageStoreOptions

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

createNewInterator() - Method in class alluxio.client.file.cache.store.RocksPageStore

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

createPageStoreDir(CacheEvictorOptions, PageStoreOptions) - Static method in interface alluxio.client.file.cache.store.PageStoreDir

Create an instance of PageStoreDir.

createPageStoreDirs(CacheManagerOptions) - Static method in interface alluxio.client.file.cache.store.PageStoreDir

Create a list of PageStoreDir based on the configuration.

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.

createUnstartedStopwatch() - Method in class alluxio.client.file.cache.LocalCacheFileInStream

CuckooTable - Interface in alluxio.client.file.cache.cuckoofilter

The cuckoo table that supports to store and access data positioned by a specific bucket and slot.

CuckooUtils - Class in alluxio.client.file.cache.cuckoofilter

This class provides some useful methods for cuckoo filters.

CuckooUtils() - Constructor for class alluxio.client.file.cache.cuckoofilter.CuckooUtils

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.

dec(int) - Method in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

Decrements the size from the encoder.

DEFAULT_FPP - Static variable in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

DEFAULT_LOAD_FACTOR - Static variable in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

DefaultBlockWorkerClient - Class in alluxio.client.block.stream

Default implementation of BlockWorkerClient.

DefaultBlockWorkerClient(UserState, GrpcServerAddress, AlluxioConfiguration) - Constructor for class alluxio.client.block.stream.DefaultBlockWorkerClient

Creates a client instance for communicating with block worker.

DefaultCacheFilter - Class in alluxio.client.file.cache.filter

Default Cache Filter cache everything.

DefaultCacheFilter(AlluxioConfiguration, String) - Constructor for class alluxio.client.file.cache.filter.DefaultCacheFilter

The default constructor.

DefaultPageMetaStore - Class in alluxio.client.file.cache

The default implementation of a metadata store for pages stored in cache.

DefaultPageMetaStore(List<PageStoreDir>) - Constructor for class alluxio.client.file.cache.DefaultPageMetaStore

DefaultPageMetaStore(List<PageStoreDir>, Allocator) - Constructor for class alluxio.client.file.cache.DefaultPageMetaStore

Constructor of DefaultMetaStore.

defaults() - Static method in class alluxio.client.block.options.GetWorkerReportOptions

defaults() - Static method in class alluxio.client.block.policy.options.GetWorkerOptions

defaults() - Static method in class alluxio.client.file.options.FileSystemOptions

Creates the default file system options.

defaults(FileSystemContext, AlluxioConfiguration) - Static method in class alluxio.client.file.options.OutStreamOptions

defaults(FileSystemContext) - Static method in class alluxio.client.file.options.OutStreamOptions

DelegatingFileSystem - Class in alluxio.client.file

A wrapper of a FileSystem instance.

DelegatingFileSystem(FileSystem) - Constructor for class alluxio.client.file.DelegatingFileSystem

Wraps a file system instance to forward messages.

delete(AlluxioURI, DeletePOptions) - Method in class alluxio.client.file.BaseFileSystem

delete(PageId) - Method in interface alluxio.client.file.cache.CacheManager

Deletes a page from the cache.

delete(PageId) - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

delete(PageId) - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

delete(T) - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

Delete an item from cuckoo filter.

delete(T) - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

delete(PageId) - Method in class alluxio.client.file.cache.LocalCacheManager

delete(PageId) - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

delete(PageId) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

delete(PageId) - Method in interface alluxio.client.file.cache.PageStore

Deletes a page from the store.

delete(PageId) - Method in interface alluxio.client.file.cache.ShadowCacheManager

Deletes a page from the cache.

delete(PageId) - Method in class alluxio.client.file.cache.store.LocalPageStore

delete(PageId) - Method in class alluxio.client.file.cache.store.MemoryPageStore

delete(PageId) - Method in class alluxio.client.file.cache.store.RocksPageStore

delete(PageId) - Method in class alluxio.client.file.cache.TimeBoundPageStore

delete(AlluxioURI, DeletePOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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.MetadataCachingFileSystem

delete(AlluxioURI, DeletePOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

deleteDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

deleteDefaults(AlluxioConfiguration, boolean) - Static method in class alluxio.util.FileSystemOptionsUtils

deletePage(PageInfo) - Method in interface alluxio.client.file.cache.store.PageStoreDir

deleteTag(int, int) - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

Delete a tag in specified bucket and return its position.

deleteTag(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

deRef() - Method in class alluxio.client.block.stream.BufferCachingGrpcDataReader

Decreases the reference count and return the current count.

DeterministicHashPolicy - Class in alluxio.client.block.policy

This policy maps the blockId to several deterministic Alluxio workers.

DeterministicHashPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.DeterministicHashPolicy

Constructs a new DeterministicHashPolicy needed for instantiation in BlockLocationPolicy.Factory.

dropMetadataCache(AlluxioURI) - Method in class alluxio.client.file.MetadataCachingFileSystem

Best efforts to drops metadata cache of a given uri, all its ancestors and descendants.

dropMetadataCacheAll() - Method in class alluxio.client.file.MetadataCachingFileSystem

Drop all metadata cache.

dumpInfo() - Method in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

Get info of buckets in the encoder.

E

encode(CacheScope) - Method in class alluxio.client.file.cache.cuckoofilter.ScopeEncoder

Encode scope information into integer.

encode(int) - Method in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

Encode the size into a group.

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.cache.PageId

equals(Object) - Method in class alluxio.client.file.cache.PageInfo

equals(Object) - Method in class alluxio.client.file.FileSystemCache.Key

equals(Object) - Method in class alluxio.client.file.options.InStreamOptions

equals(Object) - Method in class alluxio.client.file.options.OutStreamOptions

evict(CacheScope, PageStoreDir) - Method in class alluxio.client.file.cache.DefaultPageMetaStore

evict() - Method in interface alluxio.client.file.cache.evictor.CacheEvictor

evict() - Method in class alluxio.client.file.cache.evictor.FIFOCacheEvictor

evict() - Method in class alluxio.client.file.cache.evictor.LFUCacheEvictor

evict() - Method in class alluxio.client.file.cache.evictor.LRUCacheEvictor

evict() - Method in class alluxio.client.file.cache.evictor.NondeterministicLRUCacheEvictor

evict() - Method in class alluxio.client.file.cache.evictor.UnevictableCacheEvictor

evict(PageStoreDir) - Method in interface alluxio.client.file.cache.PageMetaStore

evict(CacheScope, PageStoreDir) - Method in interface alluxio.client.file.cache.PageMetaStore

evict(CacheScope, PageStoreDir) - Method in class alluxio.client.file.cache.QuotaPageMetaStore

evictMatching(Predicate<PageId>) - Method in interface alluxio.client.file.cache.evictor.CacheEvictor

Picks the first candidate for eviction that satisfies the given criterion.

evictMatching(Predicate<PageId>) - Method in class alluxio.client.file.cache.evictor.FIFOCacheEvictor

evictMatching(Predicate<PageId>) - Method in class alluxio.client.file.cache.evictor.LFUCacheEvictor

evictMatching(Predicate<PageId>) - Method in class alluxio.client.file.cache.evictor.LRUCacheEvictor

evictMatching(Predicate<PageId>) - Method in class alluxio.client.file.cache.evictor.NondeterministicLRUCacheEvictor

evictMatching(Predicate<PageId>) - Method in class alluxio.client.file.cache.evictor.UnevictableCacheEvictor

exists(AlluxioURI, ExistsPOptions) - Method in class alluxio.client.file.BaseFileSystem

exists(AlluxioURI, ExistsPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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.

exists(AlluxioURI, ExistsPOptions) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

exists(AlluxioURI, ExistsPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient

Checks whether a file or directory exists.

exists(AlluxioURI, ExistsPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

existsDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

expectedFpp() - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

expectedFpp() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

F

Factory() - Constructor for class alluxio.client.block.stream.BlockWorkerClient.Factory

Factory(BlockWorker, long, long, InStreamOptions) - Constructor for class alluxio.client.block.stream.BlockWorkerDataReader.Factory

Creates an instance of BlockWorkerDataReader.Factory.

Factory(FileSystemContext, WorkerNetAddress, ReadRequest.Builder) - 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.

Factory(FileSystemContext, WorkerNetAddress, ReadRequest.Builder, long) - Constructor for class alluxio.client.block.stream.SharedGrpcDataReader.Factory

Creates an instance of SharedGrpcDataReader.Factory for block reads.

FIFOCacheEvictor - Class in alluxio.client.file.cache.evictor

Implementation of Evictor using FIFO eviction policy.

FIFOCacheEvictor(CacheEvictorOptions) - Constructor for class alluxio.client.file.cache.evictor.FIFOCacheEvictor

Required constructor.

FileInStream - Class in alluxio.client.file

A streaming API to read a file.

FileInStream() - Constructor for class alluxio.client.file.FileInStream

FileOutStream - Class in alluxio.client.file

An abstraction of the output stream API in Alluxio to write data to a file or a block.

FileOutStream() - Constructor for class alluxio.client.file.FileOutStream

FileSystem - Interface in alluxio.client.file

Basic file system interface supporting metadata operations and data operations.

FileSystem.Factory - Class in alluxio.client.file

Factory for FileSystem.

FILESYSTEM_CACHE - Static variable in class alluxio.client.file.FileSystem.Factory

FileSystemCache - Class in alluxio.client.file

A cache for storing FileSystem clients.

FileSystemCache() - Constructor for class alluxio.client.file.FileSystemCache

Constructs a new cache for file system instances.

FileSystemCache.InstanceCachingFileSystem - Class in alluxio.client.file

A wrapper class on a FileSystem instance.

FileSystemCache.Key - Class in alluxio.client.file

A key which can be used to look up a FileSystem instance in the FileSystemCache.

FileSystemCache.Value - Class in alluxio.client.file

A value wraps a FileSystem instance and a ref count in the FileSystemCache.

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.

FileSystemMasterClient - Interface in alluxio.client.file

A client to use for interacting with a file system master.

FileSystemMasterClient.Factory - Class in alluxio.client.file

Factory for FileSystemMasterClient.

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.client.file.options

Options for creating the FileSystem.

FileSystemOptions.Builder - Class in alluxio.client.file.options

Builder class for FileSystemOptions.

FileSystemOptionsUtils - 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.

FileSystemOptionsUtils() - Constructor for class alluxio.util.FileSystemOptionsUtils

FileSystemUtils - Class in alluxio.client.file

Collection of utility methods to handle with FileSystem related objects.

findCacheWorker(GetWorkerOptions) - Method in class alluxio.client.block.policy.CapacityBaseRandomPolicy

findTag(int, int) - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

Find a tag in specified bucket and return its position.

findTag(int, int, int) - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

Find a tag in specified two buckets and return its position.

findTag(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

findTag(int, int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

flush() - Method in class alluxio.client.block.stream.BlockOutStream

flush() - Method in class alluxio.client.block.stream.BlockWorkerDataWriter

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.AlluxioFileOutStream

free(AlluxioURI, FreePOptions) - Method in class alluxio.client.file.BaseFileSystem

free(AlluxioURI, FreePOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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.FileSystemOptionsUtils

fromProto(WorkerInfoField) - Static method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerInfoField

fromProto(WorkerRange) - Static method in enum alluxio.client.block.options.GetWorkerReportOptions.WorkerRange

funnel(PageId, PrimitiveSink) - Method in enum alluxio.client.file.cache.CacheManagerWithShadowCache.PageIdFunnel

G

get(AlluxioConfiguration) - Static method in class alluxio.client.file.cache.CacheManager.Factory

get(PageId, int, byte[], int) - Method in interface alluxio.client.file.cache.CacheManager

Reads the entire page if the queried page is found in the cache, stores the result in buffer.

get(PageId, int, int, byte[], int) - Method in interface alluxio.client.file.cache.CacheManager

Reads a part of a page if the queried page is found in the cache, stores the result in buffer.

get(PageId, int, int, byte[], int, CacheContext) - Method in interface alluxio.client.file.cache.CacheManager

Reads a part of a page if the queried page is found in the cache, stores the result in buffer.

get(PageId, int, int, PageReadTargetBuffer, CacheContext) - Method in interface alluxio.client.file.cache.CacheManager

Reads a part of a page if the queried page is found in the cache, stores the result in buffer.

get(PageId, int, int, PageReadTargetBuffer, CacheContext) - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

get(PageId, int, CacheScope) - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

get(PageId, int, int, PageReadTargetBuffer, CacheContext) - Method in class alluxio.client.file.cache.LocalCacheManager

get(PageId, int, CacheScope) - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

get(PageId, int, byte[], int) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

get(PageId, int, int, byte[], int) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

get(PageId, int, int, byte[], int, CacheContext) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

get(PageId, int, int, PageReadTargetBuffer, CacheContext) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

get(PageId, PageReadTargetBuffer) - Method in interface alluxio.client.file.cache.PageStore

Gets a page from the store to the destination buffer.

get(PageId, int, int, PageReadTargetBuffer) - Method in interface alluxio.client.file.cache.PageStore

Gets part of a page from the store to the destination buffer.

get(PageId, int, int, PageReadTargetBuffer, boolean) - Method in interface alluxio.client.file.cache.PageStore

Gets part of a page from the store to the destination buffer.

get(PageId, int, CacheScope) - Method in interface alluxio.client.file.cache.ShadowCacheManager

Reads the entire page and refresh its access time if the queried page is found in the cache.

get(PageId, int, int, PageReadTargetBuffer, boolean) - Method in class alluxio.client.file.cache.store.LocalPageStore

get(PageId, int, int, PageReadTargetBuffer, boolean) - Method in class alluxio.client.file.cache.store.MemoryPageStore

get(PageId, int, int, PageReadTargetBuffer, boolean) - Method in class alluxio.client.file.cache.store.RocksPageStore

get(PageId, int, int, PageReadTargetBuffer, boolean) - Method in class alluxio.client.file.cache.TimeBoundPageStore

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.

get(Subject, AlluxioConfiguration) - Static method in class alluxio.client.file.FileSystem.Factory

Get a FileSystem from the cache with a given subject.

get(FileSystemCache.Key) - Method in class alluxio.client.file.FileSystemCache

Gets a FileSystem instance from the cache.

get(AlluxioURI) - Method in class alluxio.client.file.MetadataCache

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

getAge(T) - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

Get the item's clock value (age).

getAlluxioStorageType() - Method in class alluxio.client.file.options.OutStreamOptions

getAlluxioVersion() - Method in class alluxio.client.file.cache.store.PageStoreOptions

getAsyncWriteThreads() - Method in class alluxio.client.file.cache.CacheManagerOptions

getBackupStatus(UUID) - Method in interface alluxio.client.meta.MetaMasterClient

Queries the status of a backup.

getBackupStatus(UUID) - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient

getBitsPerClock() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

getBitsPerScope() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

getBitsPerSize() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

getBitsPerTag() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

getBitsPerTag() - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

getBitsPerTag() - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

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

getBlockInfo(long) - Method in class alluxio.client.file.options.InStreamOptions

getBlockLocations(URIStatus) - Method in class alluxio.client.file.BaseFileSystem

getBlockLocations(AlluxioURI) - Method in class alluxio.client.file.DelegatingFileSystem

getBlockLocations(URIStatus) - Method in class alluxio.client.file.DelegatingFileSystem

getBlockLocations(AlluxioURI) - Method in interface alluxio.client.file.FileSystem

Builds a list of BlockLocationInfo for the given file.

getBlockLocations(URIStatus) - Method in interface alluxio.client.file.FileSystem

Builds a list of BlockLocationInfo for the given file.

getBlockLocations(AlluxioURI) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

getBlockLocations(URIStatus) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

getBlockLocations(AlluxioURI) - Method in class alluxio.client.file.MetadataCachingFileSystem

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

getBucketIndex() - Method in class alluxio.client.file.cache.cuckoofilter.TagPosition

getBytesWritten() - Method in class alluxio.client.file.FileOutStream

getCachedBytes() - Method in interface alluxio.client.file.cache.store.PageStoreDir

getCachedPageIdsByFileId(String, long) - Method in interface alluxio.client.file.cache.CacheManager

Get page ids by the given file id.

getCachedPageIdsByFileId(String, long) - Method in class alluxio.client.file.cache.LocalCacheManager

getCachedPageIdsByFileId(String, long) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

getCachedWorkers() - Method in class alluxio.client.file.FileSystemContext

Gets the cached worker information list.

getCacheEvictorOptions() - Method in class alluxio.client.file.cache.CacheManagerOptions

getCacheSize() - Method in class alluxio.client.file.cache.store.PageStoreOptions

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.BlockStoreClient

Gets the total capacity of Alluxio's BlockStore.

getCapacityBytes() - Method in class alluxio.client.block.BlockWorkerInfo

getCapacityBytes() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient

getCapacityBytes() - Method in interface alluxio.client.file.cache.store.PageStoreDir

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 class alluxio.client.file.cache.LocalCacheFileSystem

getConf() - Method in class alluxio.client.file.DelegatingFileSystem

getConf() - Method in interface alluxio.client.file.FileSystem

getConf() - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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

getDataReaderFactory() - Method in class alluxio.client.block.stream.BlockInStream

getDataSourceAndType(BlockInfo, URIStatus, BlockLocationPolicy, Map<WorkerNetAddress, Long>) - Method in class alluxio.client.block.BlockStoreClient

Gets the data source and type of data source of a block.

getEvictor() - Method in interface alluxio.client.file.cache.store.PageStoreDir

getEvictorClass() - Method in class alluxio.client.file.cache.evictor.CacheEvictorOptions

getException() - Method in class alluxio.client.file.ConfigHashSync

getFalsePositiveRatio() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getFalsePositiveRatio() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getFalsePositiveRatio() - Method in interface alluxio.client.file.cache.ShadowCacheManager

getFieldRange() - Method in class alluxio.client.block.options.GetWorkerReportOptions

getFileBucket(int, String) - Static method in interface alluxio.client.file.cache.store.PageStoreDir

getFileBuckets() - Method in class alluxio.client.file.cache.store.PageStoreOptions

getFileId() - Method in class alluxio.client.file.cache.PageId

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

getIndex() - Method in class alluxio.client.file.cache.store.PageStoreOptions

getInfo(long) - Method in class alluxio.client.block.BlockStoreClient

Gets the block info of a block, if it exists.

getInStream(long, InStreamOptions) - Method in class alluxio.client.block.BlockStoreClient

Gets a stream to read the data of a block.

getInStream(long, InStreamOptions, Map<WorkerNetAddress, Long>) - Method in class alluxio.client.block.BlockStoreClient

Gets a stream to read the data of a block.

getInStream(BlockInfo, InStreamOptions, Map<WorkerNetAddress, Long>) - Method in class alluxio.client.block.BlockStoreClient

BlockStoreClient.getInStream(long, InStreamOptions, Map).

getKeyFromPageId(PageId) - Method in class alluxio.client.file.cache.store.MemoryPageStore

getLFULogBase() - Method in class alluxio.client.file.cache.evictor.CacheEvictorOptions

getLocalCacheDir() - Method in class alluxio.client.file.cache.PageInfo

getLocationPolicy() - Method in class alluxio.client.file.options.OutStreamOptions

getLock() - Method in class alluxio.client.file.cache.DefaultPageMetaStore

getLock() - Method in interface alluxio.client.file.cache.PageMetaStore

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

getMaxEvictionRetries() - Method in class alluxio.client.file.cache.CacheManagerOptions

getMediumType() - Method in class alluxio.client.file.options.OutStreamOptions

getMetadataCacheSize() - Method in class alluxio.client.file.MetadataCachingFileSystem

getMetricCounter() - Method in class alluxio.client.block.BlockMasterClientPool

getMetricCounter() - Method in class alluxio.client.block.stream.BlockWorkerClientPool

getMetricCounter() - Method in class alluxio.client.file.FileSystemMasterClientPool

getMetrics() - Method in interface alluxio.client.metrics.MetricsMasterClient

Gets all the metrics stored in the current master from metric name to metric value.

getMetrics() - Method in class alluxio.client.metrics.RetryHandlingMetricsMasterClient

getMode() - Method in class alluxio.client.file.options.OutStreamOptions

getMountId() - Method in class alluxio.client.file.options.OutStreamOptions

getMountTable(boolean) - Method in class alluxio.client.file.BaseFileSystem

getMountTable(boolean) - Method in class alluxio.client.file.DelegatingFileSystem

getMountTable() - Method in interface alluxio.client.file.FileSystem

Lists all mount points and their corresponding under storage addresses.

getMountTable(boolean) - Method in interface alluxio.client.file.FileSystem

Lists all mount points and their corresponding under storage addresses.

getMountTable(boolean) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

getMountTable() - Method in interface alluxio.client.file.FileSystemMasterClient

Lists all mount points and their corresponding under storage addresses.

getMountTable(boolean) - Method in interface alluxio.client.file.FileSystemMasterClient

Lists all mount points and their corresponding under storage addresses.

getMountTable(boolean) - 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

getNodeLocalWorker() - Method in class alluxio.client.file.FileSystemContext

getNumBuckets() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

getNumBuckets() - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

getNumBuckets() - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

getNumBucketsPerSegment() - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

getNumLocks() - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

getNumTagsPerBuckets() - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

getNumTagsPerBuckets() - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

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.BlockStoreClient

Gets a stream to write data to a block.

getOutStream(long, long, OutStreamOptions) - Method in class alluxio.client.block.BlockStoreClient

Gets a stream to write data to a block based on the options.

getOverheadRatio() - Method in class alluxio.client.file.cache.store.PageStoreOptions

getOwner() - Method in class alluxio.client.file.options.OutStreamOptions

getPageId() - Method in class alluxio.client.file.cache.PageInfo

getPageIndex() - Method in class alluxio.client.file.cache.PageId

getPageInfo(PageId) - Method in class alluxio.client.file.cache.DefaultPageMetaStore

getPageInfo(PageId) - Method in interface alluxio.client.file.cache.PageMetaStore

getPageInfo(PageId) - Method in class alluxio.client.file.cache.QuotaPageMetaStore

getPagePath(PageId, boolean) - Method in class alluxio.client.file.cache.store.LocalPageStore

getPageSize() - Method in class alluxio.client.file.cache.CacheManagerOptions

getPageSize() - Method in class alluxio.client.file.cache.PageInfo

getPageSize() - Method in class alluxio.client.file.cache.store.PageStoreOptions

getPageStore() - Method in class alluxio.client.file.cache.store.LocalPageStoreDir

Getter for pageStore.

getPageStore() - Method in class alluxio.client.file.cache.store.MemoryPageStoreDir

getPageStore() - Method in interface alluxio.client.file.cache.store.PageStoreDir

getPageStore() - Method in class alluxio.client.file.cache.store.RocksPageStoreDir

getPageStoreOptions() - Method in class alluxio.client.file.cache.CacheManagerOptions

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.AlluxioFileInStream

getPos() - Method in class alluxio.client.file.cache.LocalCacheFileInStream

getPositionShort() - Method in class alluxio.client.file.options.InStreamOptions

getProcessLocalWorker() - Method in class alluxio.client.file.FileSystemContext

Acquires the internal block worker as a gateway for worker internal clients to communicate with the local worker directly without going through external RPC frameworks.

getQuorumInfo() - Method in interface alluxio.client.journal.JournalMasterClient

Quorum information for participating servers in journal.

getQuorumInfo() - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

getReadBlockLocationPolicy(AlluxioConfiguration) - Method in class alluxio.client.file.FileSystemContext

Gets the readBlockLocationPolicy.

getRefCount() - Method in class alluxio.client.block.stream.BufferCachingGrpcDataReader

getRemoteServiceType() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient

getRemoteServiceType() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

getRemoteServiceType() - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

getRemoteServiceType() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient

getRemoteServiceType() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient

getRemoteServiceType() - Method in class alluxio.client.metrics.RetryHandlingMetricsMasterClient

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

getRootDir() - Method in class alluxio.client.file.cache.store.PageStoreOptions

getRootPath() - Method in interface alluxio.client.file.cache.store.PageStoreDir

getScope() - Method in class alluxio.client.file.cache.PageInfo

getSegmentIndex(int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

getSegmentStartPos(int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

getServiceName() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient

getServiceName() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

getServiceName() - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

getServiceName() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient

getServiceName() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient

getServiceName() - Method in class alluxio.client.metrics.RetryHandlingMetricsMasterClient

getServiceVersion() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient

getServiceVersion() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

getServiceVersion() - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

getServiceVersion() - Method in class alluxio.client.meta.RetryHandlingMetaMasterClient

getServiceVersion() - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient

getServiceVersion() - Method in class alluxio.client.metrics.RetryHandlingMetricsMasterClient

getShadowCacheByteHit() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

getShadowCacheByteHit() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getShadowCacheByteHit() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getShadowCacheByteHit() - Method in interface alluxio.client.file.cache.ShadowCacheManager

getShadowCacheByteRead() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

getShadowCacheByteRead() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getShadowCacheByteRead() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getShadowCacheByteRead() - Method in interface alluxio.client.file.cache.ShadowCacheManager

getShadowCacheBytes() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

getShadowCacheBytes() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getShadowCacheBytes(CacheScope) - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getShadowCacheBytes() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getShadowCacheBytes(CacheScope) - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getShadowCacheBytes() - Method in interface alluxio.client.file.cache.ShadowCacheManager

getShadowCacheBytes(CacheScope) - Method in interface alluxio.client.file.cache.ShadowCacheManager

getShadowCachePageHit() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

getShadowCachePageHit() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getShadowCachePageHit() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getShadowCachePageHit() - Method in interface alluxio.client.file.cache.ShadowCacheManager

getShadowCachePageRead() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

getShadowCachePageRead() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getShadowCachePageRead() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getShadowCachePageRead() - Method in interface alluxio.client.file.cache.ShadowCacheManager

getShadowCachePages() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

getShadowCachePages() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getShadowCachePages(CacheScope) - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

getShadowCachePages() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getShadowCachePages(CacheScope) - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

getShadowCachePages() - Method in interface alluxio.client.file.cache.ShadowCacheManager

getShadowCachePages(CacheScope) - Method in interface alluxio.client.file.cache.ShadowCacheManager

getSizeInBytes() - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

getSizeInBytes() - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

getSizeInTags() - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

getSizeInTags() - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

getSlotIndex() - Method in class alluxio.client.file.cache.cuckoofilter.TagPosition

getSource() - Method in class alluxio.client.block.stream.BlockInStream

getStateLockHolders() - Method in interface alluxio.client.file.FileSystemMasterClient

getStateLockHolders() - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

getStatus(AlluxioURI, GetStatusPOptions) - Method in class alluxio.client.file.BaseFileSystem

getStatus() - Method in class alluxio.client.file.cache.cuckoofilter.TagPosition

getStatus(AlluxioURI, GetStatusPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

getStatus(AlluxioURI, GetStatusPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient

getStatus(AlluxioURI, GetStatusPOptions) - Method in class alluxio.client.file.MetadataCachingFileSystem

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.FileSystemOptionsUtils

getStoreDirs() - Method in class alluxio.client.file.cache.DefaultPageMetaStore

getStoreDirs() - Method in interface alluxio.client.file.cache.PageMetaStore

Gets the storage directories.

getSummary() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

getSyncPathList() - Method in class alluxio.client.file.BaseFileSystem

getSyncPathList() - Method in class alluxio.client.file.DelegatingFileSystem

getSyncPathList() - Method in interface alluxio.client.file.FileSystem

Lists all the actively synced paths.

getSyncPathList() - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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

getTagsPerBucket() - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

getTimeoutDuration() - Method in class alluxio.client.file.cache.store.PageStoreOptions

getTimeoutThreads() - Method in class alluxio.client.file.cache.store.PageStoreOptions

getTransferLeaderMessage(String) - Method in interface alluxio.client.journal.JournalMasterClient

Gets exception messages thrown when transferring the leader.

getTransferLeaderMessage(String) - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

getType() - Method in class alluxio.client.file.cache.store.PageStoreOptions

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

getUriValidationEnabled() - Method in class alluxio.client.file.FileSystemContext

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.BlockStoreClient

Gets the used bytes of Alluxio's BlockStore.

getUsedBytes() - Method in class alluxio.client.block.BlockWorkerInfo

getUsedBytes() - Method in class alluxio.client.block.RetryHandlingBlockMasterClient

getValue() - Method in enum alluxio.client.file.cache.CacheManager.State

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.CapacityBaseRandomPolicy

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

The policy returns null if no worker is qualified.

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

Returns null if no active worker matches the hostname provided in WORKER_HOSTNAME (alluxio.worker.hostname).

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

Method options for BlockLocationPolicy.getWorker(GetWorkerOptions).

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.

getWriteBlockLocationPolicy(AlluxioConfiguration) - Method in class alluxio.client.file.FileSystemContext

Gets the writeBlockLocationPolicy.

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

hasFile(String) - Method in interface alluxio.client.file.cache.store.PageStoreDir

HashAllocator - Class in alluxio.client.file.cache.allocator

An implementation of Allocator base on the hash of the file id for local cache.

HashAllocator(List<PageStoreDir>) - Constructor for class alluxio.client.file.cache.allocator.HashAllocator

HashAllocator(List<PageStoreDir>, Function<String, Integer>) - Constructor for class alluxio.client.file.cache.allocator.HashAllocator

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.cache.PageId

hashCode() - Method in class alluxio.client.file.cache.PageInfo

hashCode() - Method in class alluxio.client.file.FileSystemCache.Key

hashCode() - Method in class alluxio.client.file.options.InStreamOptions

hashCode() - Method in class alluxio.client.file.options.OutStreamOptions

hasNodeLocalWorker() - Method in class alluxio.client.file.FileSystemContext

hasPage(PageId) - Method in class alluxio.client.file.cache.DefaultPageMetaStore

hasPage(PageId) - Method in interface alluxio.client.file.cache.PageMetaStore

hasProcessLocalWorker() - Method in class alluxio.client.file.FileSystemContext

hasTempFile(String) - Method in interface alluxio.client.file.cache.store.PageStoreDir

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 interface alluxio.client.metrics.MetricsMasterClient

The method the worker should periodically execute to heartbeat back to the master.

heartbeat(List<ClientMetrics>) - Method in class alluxio.client.metrics.RetryHandlingMetricsMasterClient

I

increaseOperationCount(int) - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

By calling this method, cuckoo filter is informed of the number of entries have passed.

indexHash(int, int) - Static method in class alluxio.client.file.cache.cuckoofilter.CuckooUtils

Computes the bucket index on given hash value.

insertOrKickTag(int, int) - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

Insert a tag into specified bucket.

insertOrKickTag(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

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, AlluxioConfiguration, FileSystemContext) - Constructor for class alluxio.client.file.options.InStreamOptions

Creates with the default OpenFilePOptions.

InStreamOptions(URIStatus, OpenFilePOptions, AlluxioConfiguration, FileSystemContext) - 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

invalidate(AlluxioURI) - Method in class alluxio.client.file.MetadataCache

Invalidates the cache of path.

invalidate(String) - Method in class alluxio.client.file.MetadataCache

Invalidates the cache of path.

invalidateAll() - Method in class alluxio.client.file.MetadataCache

Invalidates all the cache.

isAsyncRestoreEnabled() - Method in class alluxio.client.file.cache.CacheManagerOptions

isAsyncWriteEnabled() - Method in class alluxio.client.file.cache.CacheManagerOptions

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 class alluxio.client.file.DelegatingFileSystem

isClosed() - Method in interface alluxio.client.file.FileSystem

If there are operations currently running and close is called concurrently the behavior is undefined.

isClosed() - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

isDataCacheEnabled() - Method in class alluxio.client.file.options.FileSystemOptions

isHealthy(BlockMasterClient) - Method in class alluxio.client.block.BlockMasterClientPool

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

isHealthy(FileSystemMasterClient) - Method in class alluxio.client.file.FileSystemMasterClientPool

isMetadataCacheEnabled() - Method in class alluxio.client.file.options.FileSystemOptions

isNondeterministic() - Method in class alluxio.client.file.cache.evictor.CacheEvictorOptions

isOpen() - Method in class alluxio.client.block.stream.GrpcBlockingStream

isQuotaEnabled() - Method in class alluxio.client.file.cache.CacheManagerOptions

isShutdown() - Method in interface alluxio.client.block.stream.BlockWorkerClient

isShutdown() - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient

iterateStatus(AlluxioURI, ListStatusPOptions, Consumer<? super URIStatus>) - Method in class alluxio.client.file.BaseFileSystem

iterateStatus(AlluxioURI, ListStatusPOptions, Consumer<? super URIStatus>) - Method in class alluxio.client.file.DelegatingFileSystem

iterateStatus(AlluxioURI, Consumer<? super URIStatus>) - Method in interface alluxio.client.file.FileSystem

Performs a specific action on each URIStatus in the result of FileSystem.listStatus(alluxio.AlluxioURI).

iterateStatus(AlluxioURI, ListStatusPOptions, Consumer<? super URIStatus>) - Method in interface alluxio.client.file.FileSystem

Performs a specific action on each URIStatus in the result of FileSystem.listStatus(alluxio.AlluxioURI).

iterateStatus(AlluxioURI, ListStatusPOptions, Consumer<? super URIStatus>) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

iterateStatus(AlluxioURI, ListStatusPOptions, Consumer<? super URIStatus>) - Method in interface alluxio.client.file.FileSystemMasterClient

Performs a specific action on each URIStatus in the result of FileSystemMasterClient.listStatus(alluxio.AlluxioURI, alluxio.grpc.ListStatusPOptions).

iterateStatus(AlluxioURI, ListStatusPOptions, Consumer<? super URIStatus>) - Method in class alluxio.client.file.MetadataCachingFileSystem

iterateStatus(AlluxioURI, ListStatusPOptions, Consumer<? super URIStatus>) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

J

JournalMasterClient - Interface in alluxio.client.journal

Interface for a journal master client.

K

Key(Subject, AlluxioConfiguration) - Constructor for class alluxio.client.file.FileSystemCache.Key

L

LFUCacheEvictor - Class in alluxio.client.file.cache.evictor

LFU client-side cache eviction policy.

LFUCacheEvictor(CacheEvictorOptions) - Constructor for class alluxio.client.file.cache.evictor.LFUCacheEvictor

Required constructor.

listStatus(AlluxioURI, ListStatusPOptions) - Method in class alluxio.client.file.BaseFileSystem

listStatus(AlluxioURI, ListStatusPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

listStatus(AlluxioURI, ListStatusPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient

listStatus(AlluxioURI) - Method in class alluxio.client.file.MetadataCache

listStatus(String) - Method in class alluxio.client.file.MetadataCache

listStatus(AlluxioURI, ListStatusPOptions) - Method in class alluxio.client.file.MetadataCachingFileSystem

listStatus(AlluxioURI, ListStatusPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

listStatusDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

listStatusPartial(AlluxioURI, ListStatusPartialPOptions) - Method in class alluxio.client.file.BaseFileSystem

listStatusPartial(AlluxioURI, ListStatusPartialPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

listStatusPartial(AlluxioURI, ListStatusPartialPOptions) - Method in interface alluxio.client.file.FileSystem

Same as FileSystem.listStatus(AlluxioURI, ListStatusPOptions) except may only return a subset of the results as determined by the options parameter.

listStatusPartial(AlluxioURI, ListStatusPartialPOptions) - Method in interface alluxio.client.file.FileSystemMasterClient

listStatusPartial(AlluxioURI, ListStatusPartialPOptions) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

listStatusPartialDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

load(LoadRequest) - Method in interface alluxio.client.block.stream.BlockWorkerClient

load blocks into alluxio.

load(LoadRequest) - Method in class alluxio.client.block.stream.DefaultBlockWorkerClient

loadMetadata(AlluxioURI, ListStatusPOptions) - Method in class alluxio.client.file.BaseFileSystem

loadMetadata(AlluxioURI, ListStatusPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

loadMetadata(AlluxioURI) - Method in interface alluxio.client.file.FileSystem

Convenience method for FileSystem.loadMetadata(AlluxioURI, ListStatusPOptions) with default options.

loadMetadata(AlluxioURI, ListStatusPOptions) - Method in interface alluxio.client.file.FileSystem

Loads metadata about a path in the UFS to Alluxio.

loadMetadataDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

LocalCacheFileInStream - Class in alluxio.client.file.cache

Implementation of FileInStream that reads from a local cache if possible.

LocalCacheFileInStream(URIStatus, LocalCacheFileInStream.FileInStreamOpener, CacheManager, AlluxioConfiguration) - Constructor for class alluxio.client.file.cache.LocalCacheFileInStream

Constructor when the URIStatus is already available.

LocalCacheFileInStream.FileInStreamOpener - Interface in alluxio.client.file.cache

Interface to wrap open method of file system.

LocalCacheFileSystem - Class in alluxio.client.file.cache

A FileSystem implementation with a local cache.

LocalCacheFileSystem(CacheManager, FileSystem, AlluxioConfiguration) - Constructor for class alluxio.client.file.cache.LocalCacheFileSystem

LocalCacheManager - Class in alluxio.client.file.cache

A class to manage & serve cached pages.

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 the local worker first, and if the local worker doesn't exist or doesn't have enough availability, will select the nearest worker from the active workers list with sufficient availability.

LocalFirstAvoidEvictionPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.LocalFirstAvoidEvictionPolicy

Constructs a new LocalFirstAvoidEvictionPolicy.

LocalFirstPolicy - Class in alluxio.client.block.policy

A policy that returns the local worker first, and if the local worker doesn't exist or doesn't have enough availability, will select the nearest worker from the active workers list with sufficient availability.

LocalFirstPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.LocalFirstPolicy

Constructs a new LocalFirstPolicy.

LocalPageStore - Class in alluxio.client.file.cache.store

The LocalPageStore is an implementation of PageStore which stores all pages in a directory somewhere on the local disk.

LocalPageStore(PageStoreOptions) - Constructor for class alluxio.client.file.cache.store.LocalPageStore

Creates a new instance of LocalPageStore.

LocalPageStoreDir - Class in alluxio.client.file.cache.store

LocalPageStoreDir(PageStoreOptions, PageStore, CacheEvictor) - Constructor for class alluxio.client.file.cache.store.LocalPageStoreDir

Constructor for LocalCacheDir.

LOG - Static variable in class alluxio.client.block.stream.DataWriter.Factory

LOG - Static variable in interface alluxio.client.file.cache.PageStore

LOG - Static variable in interface alluxio.client.file.cache.store.PageStoreDir

LRUCacheEvictor - Class in alluxio.client.file.cache.evictor

LRU client-side cache eviction policy.

LRUCacheEvictor(CacheEvictorOptions) - Constructor for class alluxio.client.file.cache.evictor.LRUCacheEvictor

Constructor.

M

mBitsPerBucket - Variable in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

mBlockStore - Variable in class alluxio.client.file.BaseFileSystem

mBuckets - Variable in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

mBytesWritten - Variable in class alluxio.client.file.FileOutStream

The number of bytes written.

mClosed - Variable in class alluxio.client.file.BaseFileSystem

mDelegatedFileSystem - Variable in class alluxio.client.file.DelegatingFileSystem

mDirs - Variable in class alluxio.client.file.cache.allocator.HashAllocator

MemoryPageStore - Class in alluxio.client.file.cache.store

The MemoryPageStore is an implementation of PageStore which stores all pages in memory.

MemoryPageStore(int) - Constructor for class alluxio.client.file.cache.store.MemoryPageStore

Constructor of MemoryPageStore.

MemoryPageStoreDir - Class in alluxio.client.file.cache.store

Represents the dir and file level metadata of the MemPageStore.

MemoryPageStoreDir(PageStoreOptions, MemoryPageStore, CacheEvictor) - Constructor for class alluxio.client.file.cache.store.MemoryPageStoreDir

Constructor of MemPageStoreDir.

MetadataCache - Class in alluxio.client.file

Cache for metadata of paths.

MetadataCache(int, long) - Constructor for class alluxio.client.file.MetadataCache

MetadataCachingFileSystem - Class in alluxio.client.file

FileSystem implementation with the capability of caching metadata of paths.

MetadataCachingFileSystem(FileSystem, FileSystemContext) - Constructor for class alluxio.client.file.MetadataCachingFileSystem

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.

Metrics() - Constructor for class alluxio.client.file.cache.PageStore.Metrics

MetricsHeartbeatContext - Class in alluxio.client.metrics

A class used to track metrics heartbeats to a master.

MetricsMasterClient - Interface in alluxio.client.metrics

Interface for a metrics master client.

mFsContext - Variable in class alluxio.client.file.BaseFileSystem

mightContain(T) - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

Check whether an item is in cuckoo filter or not.

mightContain(T) - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

mightContainAndResetClock(T) - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

Check whether an item is in cuckoo filter (and reset its clock to MAX) or not.

mightContainAndResetClock(T) - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

mLock - Variable in class alluxio.client.file.cache.DefaultPageMetaStore

mLRUCache - Variable in class alluxio.client.file.cache.evictor.LRUCacheEvictor

mMaxSizeBits - Variable in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

mNumBuckets - Variable in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

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 needed for instantiation in BlockLocationPolicy.Factory.

mount(AlluxioURI, AlluxioURI, MountPOptions) - Method in class alluxio.client.file.BaseFileSystem

mount(AlluxioURI, AlluxioURI, MountPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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.FileSystemOptionsUtils

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

mPageSize - Variable in class alluxio.client.file.cache.LocalCacheFileInStream

Page size in bytes.

mPosToRead - Variable in class alluxio.client.block.stream.BufferCachingGrpcDataReader

The next pos to read.

mSizeGroupBits - Variable in class alluxio.client.file.cache.cuckoofilter.SizeEncoder

MultipleBloomShadowCacheManager - Class in alluxio.client.file.cache

This class is a shadow cache with multiple bloom filter implementation.

MultipleBloomShadowCacheManager(AlluxioConfiguration) - Constructor for class alluxio.client.file.cache.MultipleBloomShadowCacheManager

Create a MultipleBloomShadowCacheManager.

mUri - Variable in class alluxio.client.file.AlluxioFileOutStream

N

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

needsCache(URIStatus) - Method in interface alluxio.client.file.cache.filter.CacheFilter

Whether the specific uri needs to be cached or not.

needsCache(URIStatus) - Method in class alluxio.client.file.cache.filter.DefaultCacheFilter

The implementation of needsCache.

needsSync(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem

needsSync(AlluxioURI) - Method in class alluxio.client.file.DelegatingFileSystem

needsSync(AlluxioURI) - Method in interface alluxio.client.file.FileSystem

Marks the path in Alluxio as needing sync with the UFS.

needsSync(AlluxioURI) - Method in interface alluxio.client.file.FileSystemMasterClient

Mark a path as needed synchronization with the UFS, when this path or any of its children are accessed, a sync with the UFS will be performed.

needsSync(AlluxioURI) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

NoExceptionCacheManager - Class in alluxio.client.file.cache

A wrapper class of CacheManager without throwing unchecked exceptions.

NoExceptionCacheManager(CacheManager) - Constructor for class alluxio.client.file.cache.NoExceptionCacheManager

NondeterministicLRUCacheEvictor - Class in alluxio.client.file.cache.evictor

LRU with non-deterministic cache eviction policy.

NondeterministicLRUCacheEvictor(CacheEvictorOptions) - Constructor for class alluxio.client.file.cache.evictor.NondeterministicLRUCacheEvictor

Consturctor.

numPages() - Method in class alluxio.client.file.cache.DefaultPageMetaStore

numPages() - Method in interface alluxio.client.file.cache.PageMetaStore

O

offset() - Method in class alluxio.client.file.cache.store.ByteArrayTargetBuffer

offset() - Method in class alluxio.client.file.cache.store.ByteBufferTargetBuffer

offset() - Method in interface alluxio.client.file.cache.store.PageReadTargetBuffer

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.

open(URIStatus) - Method in interface alluxio.client.file.cache.LocalCacheFileInStream.FileInStreamOpener

Opens an FSDataInputStream at the indicated Path.

open(PageStoreOptions) - Static method in class alluxio.client.file.cache.store.RocksPageStore

openFile(AlluxioURI, OpenFilePOptions) - Method in class alluxio.client.file.BaseFileSystem

openFile(URIStatus, OpenFilePOptions) - Method in class alluxio.client.file.BaseFileSystem

openFile(AlluxioURI, OpenFilePOptions) - Method in class alluxio.client.file.cache.LocalCacheFileSystem

openFile(URIStatus, OpenFilePOptions) - Method in class alluxio.client.file.cache.LocalCacheFileSystem

openFile(AlluxioURI, OpenFilePOptions) - Method in class alluxio.client.file.DelegatingFileSystem

openFile(URIStatus, OpenFilePOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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.

openFile(URIStatus, OpenFilePOptions) - Method in interface alluxio.client.file.FileSystem

Opens a file for reading.

openFile(AlluxioURI, OpenFilePOptions) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

openFile(URIStatus, OpenFilePOptions) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

openFile(AlluxioURI, OpenFilePOptions) - Method in class alluxio.client.file.MetadataCachingFileSystem

openFileDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

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

optimalBitsPerTag(double, double) - Static method in class alluxio.client.file.cache.cuckoofilter.CuckooUtils

Compute the number of bits of each tag on given fpp.

optimalBuckets(long, double, int) - Static method in class alluxio.client.file.cache.cuckoofilter.CuckooUtils

Compute the number of buckets using the expected number of insertions, the load factor, and the number of tags per bucket.

OutStreamOptions - Class in alluxio.client.file.options

Method options for writing a file.

OutStreamOptions(CreateFilePOptions, FileSystemContext, AlluxioConfiguration) - Constructor for class alluxio.client.file.options.OutStreamOptions

Creates an OutStreamOptions instance from given options.

P

PageId - Class in alluxio.client.file.cache

A class identifies a single cached page.

PageId(String, long) - Constructor for class alluxio.client.file.cache.PageId

PageInfo - Class in alluxio.client.file.cache

A class identifies the information of a single cached page.

PageInfo(PageId, long, PageStoreDir) - Constructor for class alluxio.client.file.cache.PageInfo

PageInfo(PageId, long, CacheScope, PageStoreDir) - Constructor for class alluxio.client.file.cache.PageInfo

PageMetaStore - Interface in alluxio.client.file.cache

The metadata store for pages stored in cache.

PageReadTargetBuffer - Interface in alluxio.client.file.cache.store

TargetBuffer for zero-copy read from page store.

PageStore - Interface in alluxio.client.file.cache

A simple abstraction on the storage to put, get and delete pages.

PageStore.Metrics - Class in alluxio.client.file.cache

Metrics.

PageStoreDir - Interface in alluxio.client.file.cache.store

Directory of page store.

PageStoreOptions - Class in alluxio.client.file.cache.store

Options used to instantiate a PageStore.

PageStoreOptions() - Constructor for class alluxio.client.file.cache.store.PageStoreOptions

persist(AlluxioURI, ScheduleAsyncPersistencePOptions) - Method in class alluxio.client.file.BaseFileSystem

persist(AlluxioURI, ScheduleAsyncPersistencePOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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.

persist(AlluxioURI, ScheduleAsyncPersistencePOptions) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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 class alluxio.client.block.stream.BlockWorkerDataReader

pos() - Method in class alluxio.client.block.stream.BlockWorkerDataWriter

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.SharedGrpcDataReader

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.AlluxioFileInStream

positionedRead(long, byte[], int, int) - Method in class alluxio.client.file.cache.LocalCacheFileInStream

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.

put(PageId, byte[]) - Method in interface alluxio.client.file.cache.CacheManager

Puts a page into the cache manager.

put(PageId, ByteBuffer) - Method in interface alluxio.client.file.cache.CacheManager

Puts a page into the cache manager.

put(PageId, byte[], CacheContext) - Method in interface alluxio.client.file.cache.CacheManager

Puts a page into the cache manager with scope and quota respected.

put(PageId, ByteBuffer, CacheContext) - Method in interface alluxio.client.file.cache.CacheManager

Puts a page into the cache manager with scope and quota respected.

put(PageId, ByteBuffer, CacheContext) - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

put(PageId, int, CacheScope) - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

put(T, int, CacheScope) - Method in interface alluxio.client.file.cache.cuckoofilter.ClockCuckooFilter

Insert an item into cuckoo filter.

put(T, int, CacheScope) - Method in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

put(PageId, ByteBuffer, CacheContext) - Method in class alluxio.client.file.cache.LocalCacheManager

put(PageId, int, CacheScope) - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

put(PageId, byte[]) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

put(PageId, ByteBuffer, CacheContext) - Method in class alluxio.client.file.cache.NoExceptionCacheManager

put(PageId, byte[]) - Method in interface alluxio.client.file.cache.PageStore

Writes a new page from a source channel to the store.

put(PageId, byte[], boolean) - Method in interface alluxio.client.file.cache.PageStore

Writes a new page from a source channel to the store.

put(PageId, ByteBuffer, boolean) - Method in interface alluxio.client.file.cache.PageStore

Writes a new page from a source channel to the store.

put(PageId, int, CacheScope) - Method in interface alluxio.client.file.cache.ShadowCacheManager

Puts a page with specified size and scope into the shadow cache manager.

put(PageId, ByteBuffer, boolean) - Method in class alluxio.client.file.cache.store.LocalPageStore

put(PageId, ByteBuffer, boolean) - Method in class alluxio.client.file.cache.store.MemoryPageStore

put(PageId, ByteBuffer, boolean) - Method in class alluxio.client.file.cache.store.RocksPageStore

put(PageId, ByteBuffer, boolean) - Method in class alluxio.client.file.cache.TimeBoundPageStore

put(AlluxioURI, URIStatus) - Method in class alluxio.client.file.MetadataCache

put(String, URIStatus) - Method in class alluxio.client.file.MetadataCache

put(AlluxioURI, List<URIStatus>) - Method in class alluxio.client.file.MetadataCache

Caches list status results of a directory.

putPage(PageInfo) - Method in interface alluxio.client.file.cache.store.PageStoreDir

putTempFile(String) - Method in interface alluxio.client.file.cache.store.PageStoreDir

putTemporary(PageId, byte[]) - Method in interface alluxio.client.file.cache.PageStore

Writes a new temporary page from a source channel to the store.

putTempPage(PageInfo) - Method in interface alluxio.client.file.cache.store.PageStoreDir

Q

QuotaPageMetaStore - Class in alluxio.client.file.cache

A metastore implementation that tracking usage associated with each cache scope.

QuotaPageMetaStore(CacheEvictorOptions, List<PageStoreDir>) - Constructor for class alluxio.client.file.cache.QuotaPageMetaStore

R

randomInCapacity(long) - Method in class alluxio.client.block.policy.CapacityBaseRandomPolicy

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(ByteBuffer, int, int) - Method in class alluxio.client.block.stream.BlockInStream

Reads up to len bytes of data from the input stream into the byte buffer.

read() - Method in class alluxio.client.file.AlluxioFileInStream

read(ByteBuffer, int, int) - Method in class alluxio.client.file.AlluxioFileInStream

read(byte[], int, int) - Method in class alluxio.client.file.cache.LocalCacheFileInStream

read(ByteBuffer, int, int) - Method in class alluxio.client.file.cache.LocalCacheFileInStream

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

read(ByteBuffer) - Method in class alluxio.client.file.FileInStream

Reads up to buf.remaining() bytes into buf.

read(ByteBuffer, int, int) - Method in class alluxio.client.file.FileInStream

Reads up to len bytes of data from the input stream into the byte buffer.

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 class alluxio.client.block.stream.BlockWorkerDataReader

readChunk(int) - Method in class alluxio.client.block.stream.BufferCachingGrpcDataReader

Reads a specific chunk from the block.

readChunk() - Method in class alluxio.client.block.stream.BufferCachingGrpcDataReader

Reads a chunk of data.

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

readChunk() - Method in class alluxio.client.block.stream.SharedGrpcDataReader

readFromFile(RandomAccessFile, int) - Method in class alluxio.client.file.cache.store.ByteArrayTargetBuffer

readFromFile(RandomAccessFile, int) - Method in class alluxio.client.file.cache.store.ByteBufferTargetBuffer

readFromFile(RandomAccessFile, int) - Method in interface alluxio.client.file.cache.store.PageReadTargetBuffer

readLock(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Non-exclusively acquires the locks of two buckets, blocking if necessary until available.

readTag(int, int) - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

Reads the value of tag in specified position.

readTag(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

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.

ref() - Method in class alluxio.client.block.stream.BufferCachingGrpcDataReader

Increases the reference count and return the current count.

registerMetrics() - Static method in class alluxio.client.file.cache.LocalCacheFileInStream

Registers metrics.

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.

release(long) - Method in interface alluxio.client.file.cache.store.PageStoreDir

Release the pre-reserved space.

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.AlluxioFileInStream

remaining() - Method in class alluxio.client.file.cache.LocalCacheFileInStream

remaining() - Method in class alluxio.client.file.cache.store.ByteArrayTargetBuffer

remaining() - Method in class alluxio.client.file.cache.store.ByteBufferTargetBuffer

remaining() - Method in interface alluxio.client.file.cache.store.PageReadTargetBuffer

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.

removePage(PageId) - Method in class alluxio.client.file.cache.DefaultPageMetaStore

removePage(PageId) - Method in interface alluxio.client.file.cache.PageMetaStore

Removes a page.

removePage(PageId) - Method in class alluxio.client.file.cache.QuotaPageMetaStore

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

removeQuorumServer(NetAddress) - Method in interface alluxio.client.journal.JournalMasterClient

Removes a server from journal quorum.

removeQuorumServer(NetAddress) - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

rename(AlluxioURI, AlluxioURI, RenamePOptions) - Method in class alluxio.client.file.BaseFileSystem

rename(AlluxioURI, AlluxioURI, RenamePOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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, RenamePOptions) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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, RenamePOptions) - Method in class alluxio.client.file.MetadataCachingFileSystem

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.FileSystemOptionsUtils

renameDefaults(AlluxioConfiguration, boolean) - Static method in class alluxio.util.FileSystemOptionsUtils

reserve(long) - Method in interface alluxio.client.file.cache.store.PageStoreDir

reset() - Method in class alluxio.client.file.cache.DefaultPageMetaStore

reset() - Method in interface alluxio.client.file.cache.evictor.CacheEvictor

Resets the evictor.

reset() - Method in class alluxio.client.file.cache.evictor.FIFOCacheEvictor

reset() - Method in class alluxio.client.file.cache.evictor.LFUCacheEvictor

reset() - Method in class alluxio.client.file.cache.evictor.LRUCacheEvictor

reset() - Method in class alluxio.client.file.cache.evictor.UnevictableCacheEvictor

reset() - Method in interface alluxio.client.file.cache.PageMetaStore

Resets the meta store.

reset() - Method in class alluxio.client.file.cache.QuotaPageMetaStore

reset() - Method in class alluxio.client.file.cache.store.LocalPageStoreDir

Reset page store.

reset() - Method in class alluxio.client.file.cache.store.MemoryPageStore

reset() - Method in class alluxio.client.file.cache.store.MemoryPageStoreDir

reset() - Method in interface alluxio.client.file.cache.store.PageStoreDir

Reset page store.

reset() - Method in class alluxio.client.file.cache.store.RocksPageStoreDir

resetMetaMasterConfigClient(MasterClientContext) - Method in class alluxio.client.file.ConfigHashSync

Resets the internal meta master client based on the new configuration.

resetPriorities() - Method in interface alluxio.client.journal.JournalMasterClient

Resets RaftPeer priorities.

resetPriorities() - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

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.

RetryHandlingJournalMasterClient - Class in alluxio.client.journal

A wrapper for the gRPC client to interact with the journal master, used by alluxio clients.

RetryHandlingJournalMasterClient(MasterClientContext) - Constructor for class alluxio.client.journal.RetryHandlingJournalMasterClient

Creates a new journal master client.

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.

RetryHandlingMetricsMasterClient - Class in alluxio.client.metrics

A wrapper for the gRPC client to interact with the metrics master.

RetryHandlingMetricsMasterClient(MasterClientContext) - Constructor for class alluxio.client.metrics.RetryHandlingMetricsMasterClient

Creates a new metrics master client.

reverseResolve(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem

reverseResolve(AlluxioURI) - Method in class alluxio.client.file.DelegatingFileSystem

reverseResolve(AlluxioURI) - Method in interface alluxio.client.file.FileSystem

Reverse resolve a ufs uri.

reverseResolve(AlluxioURI) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

reverseResolve(AlluxioURI) - Method in interface alluxio.client.file.FileSystemMasterClient

Reverse resolve a ufs uri.

reverseResolve(AlluxioURI) - Method in class alluxio.client.file.RetryHandlingFileSystemMasterClient

RocksPageStore - Class in alluxio.client.file.cache.store

A page store implementation which utilizes rocksDB to persist the data.

RocksPageStoreDir - Class in alluxio.client.file.cache.store

Represent the dir and file level metadata of a rocksdb page store.

RocksPageStoreDir(PageStoreOptions, PageStore, CacheEvictor) - Constructor for class alluxio.client.file.cache.store.RocksPageStoreDir

Constructor of RocksPageStoreDir.

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

scanPages(Consumer<Optional<PageInfo>>) - Method in class alluxio.client.file.cache.store.LocalPageStoreDir

Gets a stream of all pages from the page store.

scanPages(Consumer<Optional<PageInfo>>) - Method in class alluxio.client.file.cache.store.MemoryPageStoreDir

scanPages(Consumer<Optional<PageInfo>>) - Method in interface alluxio.client.file.cache.store.PageStoreDir

Scan the pages under this dir.

scanPages(Consumer<Optional<PageInfo>>) - Method in class alluxio.client.file.cache.store.RocksPageStoreDir

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.FileSystemOptionsUtils

scheduleAsyncPersistenceDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

ScopeEncoder - Class in alluxio.client.file.cache.cuckoofilter

A scope encoder that supports encode/decode scope information.

ScopeEncoder(int) - Constructor for class alluxio.client.file.cache.cuckoofilter.ScopeEncoder

Create a scope encoder.

seek(long) - Method in class alluxio.client.block.stream.BlockInStream

seek(long) - Method in class alluxio.client.block.stream.SharedGrpcDataReader

Seeks to a specific position.

seek(long) - Method in class alluxio.client.file.AlluxioFileInStream

seek(long) - Method in class alluxio.client.file.cache.LocalCacheFileInStream

SegmentedLock - Class in alluxio.client.file.cache.cuckoofilter

A segmented lock that supports methods to lock/unlock multiple buckets in order to avoid dead lock.

SegmentedLock(int, int) - Constructor for class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Create a segmented lock with specified locks.

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>, SetAclPOptions) - Method in class alluxio.client.file.BaseFileSystem

setAcl(AlluxioURI, SetAclAction, List<AclEntry>, SetAclPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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.FileSystemOptionsUtils

setAddresses(Set<String>) - Method in class alluxio.client.block.options.GetWorkerReportOptions

setAlluxioVersion(String) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setAsyncRestoreEnabled(boolean) - Method in class alluxio.client.file.cache.CacheManagerOptions

setAsyncWriteThreads(int) - Method in class alluxio.client.file.cache.CacheManagerOptions

setAttribute(AlluxioURI, SetAttributePOptions) - Method in class alluxio.client.file.BaseFileSystem

setAttribute(AlluxioURI, SetAttributePOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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 class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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.FileSystemOptionsUtils

Defaults for the SetAttribute RPC which should only be used on the client side.

setAttributeDefaults(AlluxioConfiguration) - Static method in class alluxio.util.FileSystemOptionsUtils

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

setBucketAndSlot(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.TagPosition

Set the bucket and slot.

setBucketIndex(int) - Method in class alluxio.client.file.cache.cuckoofilter.TagPosition

Set the bucket index.

setCacheEvictorOptions(CacheEvictorOptions) - Method in class alluxio.client.file.cache.CacheManagerOptions

setCacheSize(long) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setDataCacheEnabled(boolean) - Method in class alluxio.client.file.options.FileSystemOptions.Builder

setEvictorClass(Class<? extends CacheEvictor>) - Method in class alluxio.client.file.cache.evictor.CacheEvictorOptions

setFieldRange(Set<GetWorkerReportOptions.WorkerInfoField>) - Method in class alluxio.client.block.options.GetWorkerReportOptions

setFileBuckets(int) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setGroup(String) - Method in class alluxio.client.file.options.OutStreamOptions

setIndex(int) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setIsAsyncWriteEnabled(boolean) - Method in class alluxio.client.file.cache.CacheManagerOptions

setIsNondeterministic(boolean) - Method in class alluxio.client.file.cache.evictor.CacheEvictorOptions

setLFULogBase(double) - Method in class alluxio.client.file.cache.evictor.CacheEvictorOptions

setLocationPolicy(BlockLocationPolicy) - Method in class alluxio.client.file.options.OutStreamOptions

setMaxEvictionRetries(int) - Method in class alluxio.client.file.cache.CacheManagerOptions

setMediumType(String) - Method in class alluxio.client.file.options.OutStreamOptions

Set the write medium type of the file.

setMetadataCacheEnabled(boolean) - Method in class alluxio.client.file.options.FileSystemOptions.Builder

setMode(Mode) - Method in class alluxio.client.file.options.OutStreamOptions

setMountId(long) - Method in class alluxio.client.file.options.OutStreamOptions

setNumOfCandidate(int) - Method in class alluxio.client.file.cache.evictor.NondeterministicLRUCacheEvictor

setOverheadRatio(double) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setOwner(String) - Method in class alluxio.client.file.options.OutStreamOptions

setPageSize(long) - Method in class alluxio.client.file.cache.CacheManagerOptions

setPageSize(long) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setPageStoreOptions(List<PageStoreOptions>) - Method in class alluxio.client.file.cache.CacheManagerOptions

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

setPositionShort(boolean) - Method in class alluxio.client.file.options.InStreamOptions

Sets whether the operation is positioned read to a small buffer.

setQuotaEnabled(boolean) - Method in class alluxio.client.file.cache.CacheManagerOptions

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

setRootDir(Path) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setSlotIndex(int) - Method in class alluxio.client.file.cache.cuckoofilter.TagPosition

Set the slot index.

setStatus(CuckooStatus) - Method in class alluxio.client.file.cache.cuckoofilter.TagPosition

Set the status of this tag position.

setStoreType(PageStoreType) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setTimeoutDuration(long) - Method in class alluxio.client.file.cache.store.PageStoreOptions

setTimeoutThreads(int) - Method in class alluxio.client.file.cache.store.PageStoreOptions

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.

ShadowCacheManager - Interface in alluxio.client.file.cache

The interface represents a shadow cache which supports put/read/delete/aging operations.

SharedGrpcDataReader - Class in alluxio.client.block.stream

A shared gRPC data reader that cache blocks data for multi-thread accessing.

SharedGrpcDataReader(ReadRequest, BufferCachingGrpcDataReader) - Constructor for class alluxio.client.block.stream.SharedGrpcDataReader

Creates an instance of SharedGrpcDataReader.

SharedGrpcDataReader.Factory - Class in alluxio.client.block.stream

Factory class to create SharedGrpcDataReaders.

shouldGc(DynamicResourcePool<BlockMasterClient>.ResourceInternal<BlockMasterClient>) - Method in class alluxio.client.block.BlockMasterClientPool

shouldGc(DynamicResourcePool<BlockWorkerClient>.ResourceInternal<BlockWorkerClient>) - Method in class alluxio.client.block.stream.BlockWorkerClientPool

shouldGc(DynamicResourcePool<FileSystemMasterClient>.ResourceInternal<FileSystemMasterClient>) - Method in class alluxio.client.file.FileSystemMasterClientPool

SimpleCuckooTable - Class in alluxio.client.file.cache.cuckoofilter

A simple cuckoo table.

SimpleCuckooTable(BitSet, int, int, int) - Constructor for class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

Create a single cuckoo table on given bit set.

size() - Method in class alluxio.client.file.MetadataCache

SizeEncoder - Class in alluxio.client.file.cache.cuckoofilter

A size encoder that supports encode/decode size information.

SizeEncoder(int, int) - Constructor for class alluxio.client.file.cache.cuckoofilter.SizeEncoder

Creates a new instance of SizeEncoder.

skip(long) - Method in class alluxio.client.block.stream.BlockInStream

skip(long) - Method in class alluxio.client.file.AlluxioFileInStream

skip(long) - Method in class alluxio.client.file.cache.LocalCacheFileInStream

SlidingWindowType - Enum in alluxio.client.file.cache.cuckoofilter

This class represents the type of sliding window.

SpecificHostPolicy - Class in alluxio.client.block.policy

Always returns a worker with the hostname specified by PropertyKey.WORKER_HOSTNAME (alluxio.worker.hostname).

SpecificHostPolicy(AlluxioConfiguration) - Constructor for class alluxio.client.block.policy.SpecificHostPolicy

Constructs a new SpecificHostPolicy needed for instantiation in BlockLocationPolicy.Factory.

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 class alluxio.client.file.DelegatingFileSystem

startSync(AlluxioURI) - Method in interface alluxio.client.file.FileSystem

Starts the active syncing process on an Alluxio path.

startSync(AlluxioURI) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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

state() - Method in interface alluxio.client.file.cache.CacheManager

state() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

state() - Method in class alluxio.client.file.cache.LocalCacheManager

state() - Method in class alluxio.client.file.cache.NoExceptionCacheManager

stopSync(AlluxioURI) - Method in class alluxio.client.file.BaseFileSystem

Stops the active syncing process on an Alluxio path.

stopSync(AlluxioURI) - Method in class alluxio.client.file.DelegatingFileSystem

stopSync(AlluxioURI) - Method in interface alluxio.client.file.FileSystem

Stops the active syncing process on an Alluxio path.

stopSync(AlluxioURI) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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

stopUpdate() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

Stop to switch bloom filters and update working set size.

stopUpdate() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

stopUpdate() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

stopUpdate() - Method in interface alluxio.client.file.cache.ShadowCacheManager

Stop the background aging task.

StreamSerializationClientInterceptor - Class in alluxio.client.block.stream

Serialization interceptor for client.

StreamSerializationClientInterceptor() - Constructor for class alluxio.client.block.stream.StreamSerializationClientInterceptor

T

tagHash(int, int) - Static method in class alluxio.client.file.cache.cuckoofilter.CuckooUtils

Compute the fingerprint on given hash value.

TagPosition - Class in alluxio.client.file.cache.cuckoofilter

This class represents a position of a tag.

TagPosition(int, int, CuckooStatus) - Constructor for class alluxio.client.file.cache.cuckoofilter.TagPosition

Create a tag position with given position and status.

TAGS_PER_BUCKET - Static variable in class alluxio.client.file.cache.cuckoofilter.ConcurrentClockCuckooFilter

TEMP_DIR - Static variable in class alluxio.client.file.cache.store.LocalPageStore

TimeBoundPageStore - Class in alluxio.client.file.cache

A wrapper class on PageStore with timeout.

TimeBoundPageStore(PageStore, PageStoreOptions) - Constructor for class alluxio.client.file.cache.TimeBoundPageStore

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

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.cache.cuckoofilter.TagPosition

toString() - Method in class alluxio.client.file.cache.PageId

toString() - Method in class alluxio.client.file.cache.PageInfo

toString() - Method in class alluxio.client.file.options.InStreamOptions

toString() - Method in class alluxio.client.file.options.OutStreamOptions

transferLeadership(NetAddress) - Method in interface alluxio.client.journal.JournalMasterClient

Initiates changing the leading master of the quorum.

transferLeadership(NetAddress) - Method in class alluxio.client.journal.RetryHandlingJournalMasterClient

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.

UnevictableCacheEvictor - Class in alluxio.client.file.cache.evictor

A client-side cache eviction policy that evicts nothing for debugging purposes.

UnevictableCacheEvictor(CacheEvictorOptions) - Constructor for class alluxio.client.file.cache.evictor.UnevictableCacheEvictor

Required constructor.

unlockRead(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Releases the read locks of two buckets if they are held.

unlockWrite(int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Releases the write lock of bucket if it is held.

unlockWrite(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Releases the write locks of two buckets if they are held.

unlockWrite(int, int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Releases the write locks of three buckets if they are held.

unlockWriteSegment(int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Releases the write lock of the ith segment if it is held.

unmount(AlluxioURI, UnmountPOptions) - Method in class alluxio.client.file.BaseFileSystem

unmount(AlluxioURI, UnmountPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

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, UnmountPOptions) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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.FileSystemOptionsUtils

updateConfiguration(Map<PropertyKey, String>) - Method in interface alluxio.client.meta.MetaMasterConfigClient

Updates properties.

updateConfiguration(Map<PropertyKey, String>) - Method in class alluxio.client.meta.RetryHandlingMetaMasterConfigClient

updateMount(AlluxioURI, MountPOptions) - Method in class alluxio.client.file.BaseFileSystem

updateMount(AlluxioURI, MountPOptions) - Method in class alluxio.client.file.DelegatingFileSystem

updateMount(AlluxioURI, MountPOptions) - Method in interface alluxio.client.file.FileSystem

Updates the options for an existing mount point.

updateMount(AlluxioURI, MountPOptions) - Method in class alluxio.client.file.FileSystemCache.InstanceCachingFileSystem

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

updateOnDelete(PageId) - Method in interface alluxio.client.file.cache.evictor.CacheEvictor

Updates evictor after a delete operation.

updateOnDelete(PageId) - Method in class alluxio.client.file.cache.evictor.FIFOCacheEvictor

updateOnDelete(PageId) - Method in class alluxio.client.file.cache.evictor.LFUCacheEvictor

updateOnDelete(PageId) - Method in class alluxio.client.file.cache.evictor.LRUCacheEvictor

updateOnDelete(PageId) - Method in class alluxio.client.file.cache.evictor.UnevictableCacheEvictor

updateOnGet(PageId) - Method in interface alluxio.client.file.cache.evictor.CacheEvictor

Updates evictor after a get operation.

updateOnGet(PageId) - Method in class alluxio.client.file.cache.evictor.FIFOCacheEvictor

updateOnGet(PageId) - Method in class alluxio.client.file.cache.evictor.LFUCacheEvictor

updateOnGet(PageId) - Method in class alluxio.client.file.cache.evictor.LRUCacheEvictor

updateOnGet(PageId) - Method in class alluxio.client.file.cache.evictor.UnevictableCacheEvictor

updateOnPut(PageId) - Method in interface alluxio.client.file.cache.evictor.CacheEvictor

Updates evictor after a put operation.

updateOnPut(PageId) - Method in class alluxio.client.file.cache.evictor.FIFOCacheEvictor

updateOnPut(PageId) - Method in class alluxio.client.file.cache.evictor.LFUCacheEvictor

updateOnPut(PageId) - Method in class alluxio.client.file.cache.evictor.LRUCacheEvictor

updateOnPut(PageId) - Method in class alluxio.client.file.cache.evictor.UnevictableCacheEvictor

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

updateWorkingSetSize() - Method in class alluxio.client.file.cache.CacheManagerWithShadowCache

Update working set size in number of pages and bytes.

updateWorkingSetSize() - Method in class alluxio.client.file.cache.ClockCuckooShadowCacheManager

updateWorkingSetSize() - Method in class alluxio.client.file.cache.MultipleBloomShadowCacheManager

updateWorkingSetSize() - Method in interface alluxio.client.file.cache.ShadowCacheManager

Update working set size in number of pages and bytes.

V

Value(FileSystem, int) - Constructor for class alluxio.client.file.FileSystemCache.Value

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.file.cache.CacheManager.State

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum alluxio.client.file.cache.CacheManagerWithShadowCache.PageIdFunnel

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum alluxio.client.file.cache.cuckoofilter.SlidingWindowType

Returns the enum constant of this type with the specified name.

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.file.cache.CacheManager.State

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum alluxio.client.file.cache.CacheManagerWithShadowCache.PageIdFunnel

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum alluxio.client.file.cache.cuckoofilter.SlidingWindowType

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.

waitForAlluxioPercentage(FileSystem, AlluxioURI, int) - Static method in class alluxio.client.file.FileSystemUtils

Waits until the specified file has the desired percentage in Alluxio.

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.AlluxioFileOutStream

write(byte[]) - Method in class alluxio.client.file.AlluxioFileOutStream

write(byte[], int, int) - Method in class alluxio.client.file.AlluxioFileOutStream

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

writeBytes(byte[], int, int) - Method in class alluxio.client.file.cache.store.ByteArrayTargetBuffer

writeBytes(byte[], int, int) - Method in class alluxio.client.file.cache.store.ByteBufferTargetBuffer

writeBytes(byte[], int, int) - Method in interface alluxio.client.file.cache.store.PageReadTargetBuffer

writeChunk(ByteBuf) - Method in class alluxio.client.block.stream.BlockWorkerDataWriter

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.

writeLock(int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Exclusively acquires the lock of the bucket, blocking if necessary until available.

writeLock(int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Exclusively acquires the locks of two buckets, blocking if necessary until available.

writeLock(int, int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Exclusively acquires the locks of three buckets, blocking if necessary until available.

writeLockSegment(int) - Method in class alluxio.client.file.cache.cuckoofilter.SegmentedLock

Exclusively acquires the lock of the ith segment, blocking if necessary until available.

writeTag(int, int, int) - Method in interface alluxio.client.file.cache.cuckoofilter.CuckooTable

Set the value of tag in specified position.

writeTag(int, int, int) - Method in class alluxio.client.file.cache.cuckoofilter.SimpleCuckooTable

A B C D E F G H I J K L M N O P Q R S T U V W