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 | Method and Description |
---|---|
int |
ScopeEncoder.encode(CacheScope scopeInfo)
Encode scope information into integer.
|
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayTargetBuffer
Target buffer backed by bytes array for zero-copy read from page store.
|
Constructor and Description |
---|
UnmodifiableArrayList(T[] elements) |
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 |
AsyncJournalWriter
This enables async journal writing, as well as some batched journal flushing.
|
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 |
MaxFileBench
MaxFile StressBench class.
|
Modifier and Type | Method and Description |
---|---|
void |
StressMasterBenchBase.BenchContext.addAdditionalResult() |
protected void |
StressMasterBenchBase.applyNativeOperation(FileSystem fs,
Operation operation,
long counter,
org.apache.hadoop.fs.Path basePath,
org.apache.hadoop.fs.Path fixedBasePath,
int fixedCount) |
Void |
MultiOperationStressMasterBench.BenchThread.call() |
Void |
StressMasterBench.BenchThread.call() |
protected void |
StressMasterBenchBase.deletePaths(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path basePath) |
protected StressMasterBench.BenchThread |
StressMasterBench.getBenchThread(StressMasterBenchBase.BenchContext context,
int index) |
protected MultiOperationStressMasterBench.BenchThread |
MultiOperationStressMasterBench.getBenchThread(StressMasterBenchBase.BenchContext context,
int index) |
protected StressMasterBenchBase.BenchContext |
MultiOperationStressMasterBench.getContext() |
protected StressMasterBenchBase.BenchContext |
StressMasterBench.getContext() |
void |
MultiOperationStressMasterBench.prepare() |
void |
StressMasterBench.prepare() |
protected Map<String,Benchmark.MethodStatistics> |
Benchmark.processMethodProfiles(long startMs,
long endMs,
java.util.function.Function<Benchmark.ProfileInput,String> nameTransformer) |
T |
StressMasterBenchBase.runLocal() |
void |
MultiOperationStressMasterBench.validateParams() |
Constructor and Description |
---|
BenchContext(com.google.common.util.concurrent.RateLimiter rateLimiter,
Operation operation,
String duration) |
MultiOperationStressMasterBench()
Creates instance.
|
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 | Method and Description |
---|---|
Map<String,SummaryStatistics> |
FuseIOBench.addAdditionalResult(long startMs,
long endMs)
Reads the log file from java agent log file.
|
Modifier and Type | Method and Description |
---|---|
void |
StressWorkerBench.prepare() |
WorkerBenchTaskResult |
StressWorkerBench.runLocal() |
Modifier and Type | Class and Description |
---|---|
static class |
CompactionTaskResult.CompactionSummary
Summary of the benchmark results.
|
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).
|
Constructor and Description |
---|
MasterBenchSummary(MasterBenchTaskResult mergedTaskResults,
Map<String,MasterBenchTaskResult> nodes)
Creates an instance.
|
MultiOperationMasterBenchSummary(MultiOperationMasterBenchTaskResult mergedTaskResults,
Map<String,MultiOperationMasterBenchTaskResult> nodes)
Creates an instance.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
EnvironmentUtils.isDocker()
Utility to detect the docker deployment environment.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultBlockWorker.freeWorker() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultStorageDir.removeTempBlockMeta(TempBlockMeta tempBlockMeta) |
Modifier and Type | Class and Description |
---|---|
class |
BlockWorkerClientServiceHandler
Server side implementation of the gRPC BlockWorker interface.
|
class |
BlockWriteHandler
This handler handles block write request.
|
class |
UfsFallbackBlockWriteHandler
This handler handles UFS block write request.
|
class |
UfsFileWriteHandler
This handler handles writes to a file in the under file system.
|
Copyright © 2023. All Rights Reserved.