alluxio.client.block.stream

Class DefaultBlockWorkerClient

java.lang.Object

alluxio.client.block.stream.DefaultBlockWorkerClient

All Implemented Interfaces:

BlockWorkerClient, Closeable, AutoCloseable

public class DefaultBlockWorkerClient
extends Object
implements BlockWorkerClient

Default implementation of BlockWorkerClient.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.client.block.stream.BlockWorkerClient

BlockWorkerClient.Factory

Constructor Summary

Constructors

Constructor and Description
DefaultBlockWorkerClient(UserState userState, GrpcServerAddress address, AlluxioConfiguration alluxioConf) Creates a client instance for communicating with block worker.

Method Summary

Modifier and Type	Method and Description
void	cache(CacheRequest request) Caches a block.
ClearMetricsResponse	clearMetrics(ClearMetricsRequest request) Clear the worker metrics.
void	close()
io.grpc.stub.StreamObserver<CreateLocalBlockRequest>	createLocalBlock(io.grpc.stub.StreamObserver<CreateLocalBlockResponse> responseObserver) Creates a local block on the worker.
void	freeWorker() Free this worker.
boolean	isHealthy()
boolean	isShutdown()
com.google.common.util.concurrent.ListenableFuture<LoadResponse>	load(LoadRequest request) load blocks into alluxio.
MoveBlockResponse	moveBlock(MoveBlockRequest request) Move a block from worker.
io.grpc.stub.StreamObserver<OpenLocalBlockRequest>	openLocalBlock(io.grpc.stub.StreamObserver<OpenLocalBlockResponse> responseObserver) Opens a local block.
io.grpc.stub.StreamObserver<ReadRequest>	readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver) Reads a block from the worker.
RemoveBlockResponse	removeBlock(RemoveBlockRequest request) Removes a block from worker.
io.grpc.stub.StreamObserver<WriteRequest>	writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver) Writes a block to the worker asynchronously.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBlockWorkerClient

public DefaultBlockWorkerClient(UserState userState,
                                GrpcServerAddress address,
                                AlluxioConfiguration alluxioConf)
                         throws IOException

Creates a client instance for communicating with block worker.

Parameters:

userState - the user state

address - the address of the worker

alluxioConf - Alluxio configuration

Throws:

IOException

Method Detail

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface BlockWorkerClient

Returns:

whether the client is shutdown

isHealthy

public boolean isHealthy()

Specified by:

isHealthy in interface BlockWorkerClient

Returns:

whether the client is healthy

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

writeBlock

public io.grpc.stub.StreamObserver<WriteRequest> writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

Description copied from interface: BlockWorkerClient

Writes a block to the worker asynchronously. The caller should pass in a response observer for receiving server responses and handling errors.

Specified by:

writeBlock in interface BlockWorkerClient

Parameters:

responseObserver - the stream observer for the server response

Returns:

the stream observer for the client request

readBlock

public io.grpc.stub.StreamObserver<ReadRequest> readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)

Description copied from interface: BlockWorkerClient

Reads a block from the worker. When client is done with the file, it should close the stream using the gRPC context.

Specified by:

readBlock in interface BlockWorkerClient

Parameters:

responseObserver - the stream observer for the server response

Returns:

the stream observer for the client request

createLocalBlock

public io.grpc.stub.StreamObserver<CreateLocalBlockRequest> createLocalBlock(io.grpc.stub.StreamObserver<CreateLocalBlockResponse> responseObserver)

Description copied from interface: BlockWorkerClient

Creates a local block on the worker. This is a two stage operations: 1. Client sends a create request through the request stream. Server will respond with the name of the file to write to. 2. When client is done with the file, it should signal complete or cancel on the request stream based on the intent. The server will signal complete on the response stream once the operation is done.

Specified by:

createLocalBlock in interface BlockWorkerClient

Parameters:

responseObserver - the stream observer for the server response

Returns:

the stream observer for the client request

openLocalBlock

public io.grpc.stub.StreamObserver<OpenLocalBlockRequest> openLocalBlock(io.grpc.stub.StreamObserver<OpenLocalBlockResponse> responseObserver)

Description copied from interface: BlockWorkerClient

Opens a local block. This is a two stage operations: 1. Client sends an open request through the request stream. Server will respond with the name of the file to read from. 2. When client is done with the file, it should close the stream.

Specified by:

openLocalBlock in interface BlockWorkerClient

Parameters:

responseObserver - the stream observer for the server response

Returns:

the stream observer for the client request

removeBlock

public RemoveBlockResponse removeBlock(RemoveBlockRequest request)

Description copied from interface: BlockWorkerClient

Removes a block from worker.

Specified by:

removeBlock in interface BlockWorkerClient

Parameters:

request - the remove block request

Returns:

the response from server

moveBlock

public MoveBlockResponse moveBlock(MoveBlockRequest request)

Description copied from interface: BlockWorkerClient

Move a block from worker.

Specified by:

moveBlock in interface BlockWorkerClient

Parameters:

request - the remove block request

Returns:

the response from server

clearMetrics

public ClearMetricsResponse clearMetrics(ClearMetricsRequest request)

Description copied from interface: BlockWorkerClient

Clear the worker metrics.

Specified by:

clearMetrics in interface BlockWorkerClient

Parameters:

request - the request to clear metrics

Returns:

the response from server

cache

public void cache(CacheRequest request)

Description copied from interface: BlockWorkerClient

Caches a block.

Specified by:

cache in interface BlockWorkerClient

Parameters:

request - the cache request

freeWorker

public void freeWorker()

Description copied from interface: BlockWorkerClient

Free this worker.

Specified by:

freeWorker in interface BlockWorkerClient

load

public com.google.common.util.concurrent.ListenableFuture<LoadResponse> load(LoadRequest request)

Description copied from interface: BlockWorkerClient

load blocks into alluxio.

Specified by:

load in interface BlockWorkerClient

Parameters:

request - the cache request

Returns:

listenable future of LoadResponse