alluxio.worker.grpc

Class UfsFileWriteRequestContext

java.lang.Object

alluxio.worker.grpc.WriteRequestContext<UfsFileWriteRequest>

alluxio.worker.grpc.UfsFileWriteRequestContext

@NotThreadSafe
public final class UfsFileWriteRequestContext
extends WriteRequestContext<UfsFileWriteRequest>

The UFS File write request internal representation.

Method Summary

Modifier and Type	Method and Description
CreateOptions	getCreateOptions()
OutputStream	getOutputStream()
CloseableResource<UnderFileSystem>	getUfsResource()
void	setCreateOptions(CreateOptions createOptions)
void	setOutputStream(OutputStream outputStream)
void	setUfsResource(CloseableResource<UnderFileSystem> ufsResource)

Methods inherited from class alluxio.worker.grpc.WriteRequestContext

getContentHash, getCounter, getError, getMeter, getPos, getRequest, isDoneUnsafe, setContentHash, 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

getCreateOptions

@Nullable
public CreateOptions getCreateOptions()

Returns:

the create options

getOutputStream

@Nullable
public OutputStream getOutputStream()

Returns:

the output stream

getUfsResource

@Nullable
public CloseableResource<UnderFileSystem> getUfsResource()

Returns:

the handler of the UFS

setCreateOptions

public void setCreateOptions(CreateOptions createOptions)

Parameters:

createOptions - the create options to set

setOutputStream

public void setOutputStream(OutputStream outputStream)

Parameters:

outputStream - output stream to set

setUfsResource

public void setUfsResource(CloseableResource<UnderFileSystem> ufsResource)

Parameters:

ufsResource - UFS to set