alluxio.worker.grpc

Class WriteRequestContext<T extends WriteRequest>

java.lang.Object

alluxio.worker.grpc.WriteRequestContext<T>

Type Parameters:

T - type of the write request

Direct Known Subclasses:

BlockWriteRequestContext, UfsFileWriteRequestContext

@ThreadSafe
public class WriteRequestContext<T extends WriteRequest>
extends Object

Represents the context of a write request received from gRPC stream. This class serves the shared states of the request and can be accessed concurrently by the gRPC event thread and I/O thread.

Constructor Summary

Constructors

Constructor and Description
WriteRequestContext(T request)

Method Summary

Modifier and Type	Method and Description
Optional<String>	getContentHash()
com.codahale.metrics.Counter	getCounter()
alluxio.worker.grpc.Error	getError()
com.codahale.metrics.Meter	getMeter()
long	getPos()
T	getRequest()
boolean	isDoneUnsafe()
void	setContentHash(String contentHash)
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

WriteRequestContext

public WriteRequestContext(T request)

Parameters:

request - the write request

Method Detail

getRequest

public T getRequest()

Returns:

the write request

getContentHash

public Optional<String> getContentHash()

Returns:

the content hash

setContentHash

public void setContentHash(String contentHash)

Parameters:

contentHash - the content hash of the written file

getError

@Nullable
public alluxio.worker.grpc.Error getError()

Returns:

the error

getPos

public long getPos()

Returns:

the next position to write to the block worker

getCounter

@Nullable
public com.codahale.metrics.Counter getCounter()

Returns:

metrics counter associated with this request

getMeter

@Nullable
public com.codahale.metrics.Meter getMeter()

Returns:

metrics meter associated with this request

isDoneUnsafe

public boolean isDoneUnsafe()

Returns:

true when the EOF or CANCEL is received, false otherwise

setError

public void setError(alluxio.worker.grpc.Error error)

Parameters:

error - the error

setPos

public void setPos(long posToWrite)

Parameters:

posToWrite - the next position to write to the block worker

setDoneUnsafe

public void setDoneUnsafe(boolean done)

Parameters:

done - whether the EOF or CANCEL is received

setCounter

public void setCounter(com.codahale.metrics.Counter counter)

Parameters:

counter - counter to set

setMeter

public void setMeter(com.codahale.metrics.Meter meter)

Parameters:

meter - meter to set