T
- type of the write request@ThreadSafe public class WriteRequestContext<T extends WriteRequest> extends Object
Constructor and Description |
---|
WriteRequestContext(T request) |
Modifier and Type | Method and Description |
---|---|
com.codahale.metrics.Counter |
getCounter() |
alluxio.worker.grpc.Error |
getError() |
com.codahale.metrics.Meter |
getMeter() |
long |
getPos() |
T |
getRequest() |
boolean |
isDoneUnsafe() |
void |
setCounter(com.codahale.metrics.Counter counter) |
void |
setDoneUnsafe(boolean done) |
void |
setError(alluxio.worker.grpc.Error error) |
void |
setMeter(com.codahale.metrics.Meter meter) |
void |
setPos(long posToWrite) |
public WriteRequestContext(T request)
request
- the write requestpublic T getRequest()
@Nullable public alluxio.worker.grpc.Error getError()
public long getPos()
@Nullable public com.codahale.metrics.Counter getCounter()
@Nullable public com.codahale.metrics.Meter getMeter()
public boolean isDoneUnsafe()
public void setError(alluxio.worker.grpc.Error error)
error
- the errorpublic void setPos(long posToWrite)
posToWrite
- the next position to write to the block workerpublic void setDoneUnsafe(boolean done)
done
- whether the EOF or CANCEL is receivedpublic void setCounter(com.codahale.metrics.Counter counter)
counter
- counter to setpublic void setMeter(com.codahale.metrics.Meter meter)
meter
- meter to setCopyright © 2023. All Rights Reserved.