alluxio.worker.grpc

Class BlockWorkerImpl

java.lang.Object

alluxio.grpc.BlockWorkerGrpc.BlockWorkerImplBase

alluxio.worker.grpc.BlockWorkerImpl

All Implemented Interfaces:

io.grpc.BindableService

public class BlockWorkerImpl
extends BlockWorkerGrpc.BlockWorkerImplBase

Server side implementation of the gRPC BlockWorker interface.

Constructor Summary

Constructors

Constructor and Description
BlockWorkerImpl(WorkerProcess workerProcess, FileSystemContext fsContext, boolean domainSocketEnabled) Creates a new implementation of gRPC BlockWorker interface.

Method Summary

Modifier and Type	Method and Description
void	asyncCache(AsyncCacheRequest request, io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)
void	clearMetrics(ClearMetricsRequest request, io.grpc.stub.StreamObserver<ClearMetricsResponse> responseObserver) TODO(lu) Move to metrics worker
io.grpc.stub.StreamObserver<CreateLocalBlockRequest>	createLocalBlock(io.grpc.stub.StreamObserver<CreateLocalBlockResponse> responseObserver) Replaces ShortCircuitBlockWriteHandler.
Map<io.grpc.MethodDescriptor,io.grpc.MethodDescriptor>	getOverriddenMethodDescriptors()
void	moveBlock(MoveBlockRequest request, io.grpc.stub.StreamObserver<MoveBlockResponse> responseObserver)
io.grpc.stub.StreamObserver<OpenLocalBlockRequest>	openLocalBlock(io.grpc.stub.StreamObserver<OpenLocalBlockResponse> responseObserver) Replaces ShortCircuitBlockReadHandler.
io.grpc.stub.StreamObserver<ReadRequest>	readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
void	removeBlock(RemoveBlockRequest request, io.grpc.stub.StreamObserver<RemoveBlockResponse> responseObserver)
io.grpc.stub.StreamObserver<WriteRequest>	writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

Methods inherited from class alluxio.grpc.BlockWorkerGrpc.BlockWorkerImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockWorkerImpl

public BlockWorkerImpl(WorkerProcess workerProcess,
                       FileSystemContext fsContext,
                       boolean domainSocketEnabled)

Creates a new implementation of gRPC BlockWorker interface.

Parameters:

workerProcess - the worker process

fsContext - context used to read blocks

domainSocketEnabled - is using domain sockets

Method Detail

getOverriddenMethodDescriptors

public Map<io.grpc.MethodDescriptor,io.grpc.MethodDescriptor> getOverriddenMethodDescriptors()

Returns:

a map of gRPC methods with overridden descriptors

readBlock

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

Overrides:

readBlock in class BlockWorkerGrpc.BlockWorkerImplBase

writeBlock

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

Overrides:

writeBlock in class BlockWorkerGrpc.BlockWorkerImplBase

openLocalBlock

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

Description copied from class: BlockWorkerGrpc.BlockWorkerImplBase

 Replaces ShortCircuitBlockReadHandler.
 

Overrides:

openLocalBlock in class BlockWorkerGrpc.BlockWorkerImplBase

createLocalBlock

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

Description copied from class: BlockWorkerGrpc.BlockWorkerImplBase

 Replaces ShortCircuitBlockWriteHandler.
 

Overrides:

createLocalBlock in class BlockWorkerGrpc.BlockWorkerImplBase

asyncCache

public void asyncCache(AsyncCacheRequest request,
                       io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)

Overrides:

asyncCache in class BlockWorkerGrpc.BlockWorkerImplBase

removeBlock

public void removeBlock(RemoveBlockRequest request,
                        io.grpc.stub.StreamObserver<RemoveBlockResponse> responseObserver)

Overrides:

removeBlock in class BlockWorkerGrpc.BlockWorkerImplBase

moveBlock

public void moveBlock(MoveBlockRequest request,
                      io.grpc.stub.StreamObserver<MoveBlockResponse> responseObserver)

Overrides:

moveBlock in class BlockWorkerGrpc.BlockWorkerImplBase

clearMetrics

public void clearMetrics(ClearMetricsRequest request,
                         io.grpc.stub.StreamObserver<ClearMetricsResponse> responseObserver)

Description copied from class: BlockWorkerGrpc.BlockWorkerImplBase

 TODO(lu) Move to metrics worker
 

Overrides:

clearMetrics in class BlockWorkerGrpc.BlockWorkerImplBase