Modifier and Type | Field and Description |
---|---|
protected ServiceVersionClientServiceGrpc.ServiceVersionClientServiceBlockingStub |
AbstractClient.mVersionService |
Modifier and Type | Method and Description |
---|---|
DataReader |
SharedGrpcDataReader.Factory.create(long offset,
long len) |
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 | 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 | 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.
|
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 | 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 |
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.