alluxio.worker.grpc

Class BlockWriteHandler

java.lang.Object

alluxio.worker.grpc.BlockWriteHandler

@NotThreadSafe
public final class BlockWriteHandler
extends Object

This handler handles block write request. Check more information in AbstractWriteHandler.

Field Summary

Fields

Modifier and Type	Field and Description
static long	FILE_BUFFER_SIZE
protected AuthenticatedUserInfo	mUserInfo

Method Summary

Modifier and Type	Method and Description
protected void	cancelRequest(BlockWriteRequestContext context) Cancels this write.
protected void	cleanupRequest(BlockWriteRequestContext context) Cleans up this write.
protected void	completeRequest(BlockWriteRequestContext context) Completes this write.
protected BlockWriteRequestContext	createRequestContext(WriteRequest msg) Creates a new request context.
protected void	flushRequest(BlockWriteRequestContext context) Flushes the buffered data.
String	getLocation()
protected String	getLocationInternal(BlockWriteRequestContext context)
protected void	handleCommand(WriteRequestCommand command, T context) Handles a command in the write request.
void	onCancel() Handles request cancellation event.
void	onCompleted() Handles request complete event.
void	onError(Throwable cause) Handles errors from the request.
void	write(WriteRequest writeRequest) Handles write request.
protected void	writeBuf(BlockWriteRequestContext context, io.grpc.stub.StreamObserver<WriteResponse> observer, DataBuffer buf, long pos) Writes the buffer.
void	writeDataMessage(WriteRequest request, DataBuffer buffer) Handles write request with data message.

Methods inherited from class java.lang.Object

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

Field Detail

FILE_BUFFER_SIZE

public static final long FILE_BUFFER_SIZE

See Also:

Constant Field Values

mUserInfo

protected AuthenticatedUserInfo mUserInfo

Method Detail

createRequestContext

protected BlockWriteRequestContext createRequestContext(WriteRequest msg)
                                                 throws Exception

Creates a new request context.

Parameters:

msg - the block write request

Throws:

Exception

completeRequest

protected void completeRequest(BlockWriteRequestContext context)
                        throws Exception

Completes this write. This is called when the write completes.

Parameters:

context - context of the request to complete

Throws:

Exception

cancelRequest

protected void cancelRequest(BlockWriteRequestContext context)
                      throws Exception

Cancels this write. This is called when the client issues a cancel request.

Parameters:

context - context of the request to complete

Throws:

Exception

cleanupRequest

protected void cleanupRequest(BlockWriteRequestContext context)
                       throws Exception

Cleans up this write. This is called when the write request is aborted due to any exception or session timeout.

Parameters:

context - context of the request to complete

Throws:

Exception

flushRequest

protected void flushRequest(BlockWriteRequestContext context)
                     throws Exception

Flushes the buffered data. Flush only happens after write.

Parameters:

context - context of the request to complete

Throws:

Exception

writeBuf

protected void writeBuf(BlockWriteRequestContext context,
                        io.grpc.stub.StreamObserver<WriteResponse> observer,
                        DataBuffer buf,
                        long pos)
                 throws Exception

Writes the buffer.

Parameters:

context - context of the request to complete

observer - the response observer

buf - the buffer

pos - the pos

Throws:

Exception

getLocationInternal

protected String getLocationInternal(BlockWriteRequestContext context)

Parameters:

context - the context of the request

Returns:

an informational string of the location the writer is writing to

write

public void write(WriteRequest writeRequest)

Handles write request.

Parameters:

writeRequest - the request from the client

writeDataMessage

public void writeDataMessage(WriteRequest request,
                             DataBuffer buffer)

Handles write request with data message.

Parameters:

request - the request from the client

buffer - the data associated with the request

onCompleted

public void onCompleted()

Handles request complete event.

onCancel

public void onCancel()

Handles request cancellation event.

onError

public void onError(Throwable cause)

Handles errors from the request.

Parameters:

cause - the exception

getLocation

public String getLocation()

Returns:

an informational string of the location the writer is writing to

handleCommand

protected void handleCommand(WriteRequestCommand command,
                             T context)
                      throws Exception

Handles a command in the write request.

Parameters:

command - the command to be handled

Throws:

Exception