alluxio.worker.grpc

Class BlockWriteRequestContext

java.lang.Object

alluxio.worker.grpc.WriteRequestContext<BlockWriteRequest>

alluxio.worker.grpc.BlockWriteRequestContext

@NotThreadSafe
public final class BlockWriteRequestContext
extends WriteRequestContext<BlockWriteRequest>

The block write request internal representation.

Method Summary

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)

Methods inherited from class alluxio.worker.grpc.WriteRequestContext

getCounter, getError, getMeter, getPos, getRequest, isDoneUnsafe, setCounter, setDoneUnsafe, setError, setMeter, setPos

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getBlockWriter

@Nullable
public BlockWriter getBlockWriter()

Returns:

the block writer

getBytesReserved

public long getBytesReserved()

Returns:

the bytes reserved

setBlockWriter

public void setBlockWriter(BlockWriter blockWriter)

Parameters:

blockWriter - block writer to set

setBytesReserved

public void setBytesReserved(long bytesReserved)

Parameters:

bytesReserved - the bytes reserved to set

isWritingToLocal

public boolean isWritingToLocal()

Returns:

is the current request writing to UFS

getUfsPath

@Nullable
public String getUfsPath()

Returns:

the UFS path of the block

getOutputStream

@Nullable
public OutputStream getOutputStream()

Returns:

the output stream

getUfsResource

@Nullable
public CloseableResource<UnderFileSystem> getUfsResource()

Returns:

the handler of the UFS

setWritingToLocal

public void setWritingToLocal(boolean writingToLocal)

Parameters:

writingToLocal - whether the current request is writing to UFS

setOutputStream

public void setOutputStream(OutputStream outputStream)

Parameters:

outputStream - output stream to set

setUfsResource

public void setUfsResource(CloseableResource<UnderFileSystem> ufsResource)

Parameters:

ufsResource - UFS to set

setUfsPath

public void setUfsPath(String ufsPath)

Parameters:

ufsPath - UFS path to set