Package | Description |
---|---|
alluxio | |
alluxio.client.block.stream | |
alluxio.client.file | |
alluxio.client.file.cache.cuckoofilter | |
alluxio.collections | |
alluxio.file | |
alluxio.fsmaster | |
alluxio.grpc | |
alluxio.master.backcompat.ops | |
alluxio.master.file | |
alluxio.master.job | |
alluxio.master.journal | |
alluxio.master.journal.raft | |
alluxio.master.scheduler | |
alluxio.security.user | |
alluxio.snapshot | |
alluxio.stress.cli | |
alluxio.stress.cli.client | |
alluxio.stress.cli.worker | |
alluxio.stress.common | |
alluxio.util | |
alluxio.worker |
Worker process and utils for working with the worker remotely.
|
alluxio.worker.grpc | |
alluxio.worker.netty |
Modifier and Type | Field and Description |
---|---|
protected ServiceVersionClientServiceGrpc.ServiceVersionClientServiceBlockingStub |
AbstractClient.mVersionService |
Modifier and Type | Method and Description |
---|---|
int |
DefaultStorageTierAssoc.getOrdinal(String alias) |
Modifier and Type | Method and Description |
---|---|
DataReader |
SharedGrpcDataReader.Factory.create(long offset,
long len) |
Modifier and Type | Class and Description |
---|---|
class |
DoraCacheFileSystem
Dora Cache file system implementation.
|
class |
FileSystemContext
An object which houses resources and information for performing
FileSystem operations. |
Modifier and Type | Method and Description |
---|---|
int |
ScopeEncoder.encode(CacheScope scopeInfo)
Encode scope information into integer.
|
Constructor and Description |
---|
UnmodifiableArrayList(T[] elements) |
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayTargetBuffer
Target buffer backed by bytes array for zero-copy read from page store.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSystemBench |
Modifier and Type | Method and Description |
---|---|
void |
ServiceVersionClientServiceHandler.getServiceVersion(GetServiceVersionPRequest request,
io.grpc.stub.StreamObserver<GetServiceVersionPResponse> responseObserver) |
Modifier and Type | Method and Description |
---|---|
void |
Mount.apply(FileSystem fs) |
Modifier and Type | Method and Description |
---|---|
void |
UfsSyncChecker.checkDirectory(InodeDirectory inode,
AlluxioURI alluxioUri)
Check if immediate children of directory are in sync with UFS.
|
Modifier and Type | Class and Description |
---|---|
class |
JournalLoadJobFactory
Factory for creating
LoadJob s from journal entries. |
Modifier and Type | Class and Description |
---|---|
class |
AsyncJournalWriter
This enables async journal writing, as well as some batched journal flushing.
|
Modifier and Type | Method and Description |
---|---|
static Matcher |
SnapshotDirStateMachineStorage.matchSnapshotPath(Path path) |
Modifier and Type | Class and Description |
---|---|
class |
Scheduler
The Scheduler which controls jobs.
|
class |
Scheduler.BoundedPriorityBlockingQueue<E>
Bounded priority queue impl.
|
class |
Scheduler.WorkerInfoHub
Worker information hub.
|
Modifier and Type | Field and Description |
---|---|
static ArrayList<UserStateFactory> |
UserState.FACTORIES
An ordered list of factories for creating UserState instances.
|
Modifier and Type | Class and Description |
---|---|
class |
SnapshotBench |
Modifier and Type | Method and Description |
---|---|
protected Map<String,Benchmark.MethodStatistics> |
Benchmark.processMethodProfiles(long startMs,
long endMs,
java.util.function.Function<Benchmark.ProfileInput,String> nameTransformer) |
Modifier and Type | Method and Description |
---|---|
Map<String,SummaryStatistics> |
StressClientIOBench.addAdditionalResult(long startMs,
long endMs)
Read the log file from java agent log file.
|
void |
StressClientIOBench.prepare() |
ClientIOTaskResult |
StressClientIOBench.runLocal() |
Modifier and Type | Class and Description |
---|---|
class |
StressWorkerBench
Single node stress test.
|
Modifier and Type | Field and Description |
---|---|
long[] |
TaskResultStatistics.mMaxResponseTimeNs |
float[] |
SummaryStatistics.mMaxTimeMs
max time over time, over the duration of the test.
|
byte[] |
TaskResultStatistics.mResponseTimeNsRaw |
float[] |
SummaryStatistics.mTime99PercentileMs
percentiles of just 99.x%.
|
float[] |
SummaryStatistics.mTimePercentileMs
response times for all percentiles from 0 -> 100 (101 values).
|
Modifier and Type | Method and Description |
---|---|
static boolean |
EnvironmentUtils.isDocker()
Utility to detect the docker deployment environment.
|
Modifier and Type | Class and Description |
---|---|
class |
DataServerFactory
Factory for data server.
|
Modifier and Type | Class and Description |
---|---|
class |
DoraWorkerClientServiceHandler
Server side implementation of the gRPC dora worker interface.
|
class |
UfsFileWriteHandler
This handler handles writes to a file in the under file system.
|
Modifier and Type | Class and Description |
---|---|
class |
FileWriteHandler
This handler handles block write request.
|
class |
UfsFileWriteHandler
This handler handles writes to a file in the under file system.
|
Copyright © 2023. All Rights Reserved.