@NotThreadSafe public final class BlockWriteRequestContext extends WriteRequestContext<BlockWriteRequest>
Modifier and Type | Method and Description |
---|---|
BlockWriter |
getBlockWriter() |
long |
getBytesReserved() |
OutputStream |
getOutputStream() |
String |
getUfsPath() |
CloseableResource<UnderFileSystem> |
getUfsResource() |
boolean |
isWritingToLocal() |
void |
setBlockWriter(BlockWriter blockWriter) |
void |
setBytesReserved(long bytesReserved) |
void |
setOutputStream(OutputStream outputStream) |
void |
setUfsPath(String ufsPath) |
void |
setUfsResource(CloseableResource<UnderFileSystem> ufsResource) |
void |
setWritingToLocal(boolean writingToLocal) |
getCounter, getError, getMeter, getPos, getRequest, isDoneUnsafe, setCounter, setDoneUnsafe, setError, setMeter, setPos
@Nullable public BlockWriter getBlockWriter()
public long getBytesReserved()
public void setBlockWriter(BlockWriter blockWriter)
blockWriter
- block writer to setpublic void setBytesReserved(long bytesReserved)
bytesReserved
- the bytes reserved to setpublic boolean isWritingToLocal()
@Nullable public OutputStream getOutputStream()
@Nullable public CloseableResource<UnderFileSystem> getUfsResource()
public void setWritingToLocal(boolean writingToLocal)
writingToLocal
- whether the current request is writing to UFSpublic void setOutputStream(OutputStream outputStream)
outputStream
- output stream to setpublic void setUfsResource(CloseableResource<UnderFileSystem> ufsResource)
ufsResource
- UFS to setpublic void setUfsPath(String ufsPath)
ufsPath
- UFS path to setCopyright © 2023. All Rights Reserved.