alluxio.master.block

Class BlockMasterWorkerServiceHandler

java.lang.Object

alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

alluxio.master.block.BlockMasterWorkerServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

public final class BlockMasterWorkerServiceHandler
extends BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

This class is a gRPC handler for block master RPCs invoked by an Alluxio worker.

Constructor Summary

Constructors

Constructor and Description
BlockMasterWorkerServiceHandler(BlockMaster blockMaster) Creates a new instance of BlockMasterWorkerServiceHandler.

Method Summary

Modifier and Type	Method and Description
void	blockHeartbeat(BlockHeartbeatPRequest request, io.grpc.stub.StreamObserver<BlockHeartbeatPResponse> responseObserver) Periodic block worker heartbeat returns an optional command for the block worker to execute.
void	commitBlock(CommitBlockPRequest request, io.grpc.stub.StreamObserver<CommitBlockPResponse> responseObserver) Marks the given block as committed.
void	commitBlockInUfs(CommitBlockInUfsPRequest request, io.grpc.stub.StreamObserver<CommitBlockInUfsPResponse> responseObserver) Marks the given block as committed which resides in UFS.
void	getWorkerId(GetWorkerIdPRequest request, io.grpc.stub.StreamObserver<GetWorkerIdPResponse> responseObserver) Returns a worker id for the given network address.
void	notifyWorkerId(NotifyWorkerIdPRequest request, io.grpc.stub.StreamObserver<NotifyWorkerIdPResponse> responseObserver) Notify all masters about the worker ID.
void	registerWorker(RegisterWorkerPRequest request, io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Registers a worker.
io.grpc.stub.StreamObserver<RegisterWorkerPRequest>	registerWorkerStream(io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Registers a worker in a streaming way
void	requestRegisterLease(GetRegisterLeasePRequest request, io.grpc.stub.StreamObserver<GetRegisterLeasePResponse> responseObserver) Requests a lease for registration

Methods inherited from class alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockMasterWorkerServiceHandler

public BlockMasterWorkerServiceHandler(BlockMaster blockMaster)

Creates a new instance of BlockMasterWorkerServiceHandler.

Parameters:

blockMaster - the BlockMaster the handler uses internally

Method Detail

blockHeartbeat

public void blockHeartbeat(BlockHeartbeatPRequest request,
                           io.grpc.stub.StreamObserver<BlockHeartbeatPResponse> responseObserver)

Description copied from class: BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

 Periodic block worker heartbeat returns an optional command for the block worker to execute.
 

Overrides:

blockHeartbeat in class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

commitBlock

public void commitBlock(CommitBlockPRequest request,
                        io.grpc.stub.StreamObserver<CommitBlockPResponse> responseObserver)

Description copied from class: BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

 Marks the given block as committed.
 

Overrides:

commitBlock in class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

commitBlockInUfs

public void commitBlockInUfs(CommitBlockInUfsPRequest request,
                             io.grpc.stub.StreamObserver<CommitBlockInUfsPResponse> responseObserver)

Description copied from class: BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

 Marks the given block as committed which resides in UFS.
 

Overrides:

commitBlockInUfs in class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

getWorkerId

public void getWorkerId(GetWorkerIdPRequest request,
                        io.grpc.stub.StreamObserver<GetWorkerIdPResponse> responseObserver)

Description copied from class: BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

 Returns a worker id for the given network address.
 

Overrides:

getWorkerId in class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

requestRegisterLease

public void requestRegisterLease(GetRegisterLeasePRequest request,
                                 io.grpc.stub.StreamObserver<GetRegisterLeasePResponse> responseObserver)

Description copied from class: BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

 Requests a lease for registration
 

Overrides:

requestRegisterLease in class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

registerWorker

public void registerWorker(RegisterWorkerPRequest request,
                           io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver)

Description copied from class: BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

 Registers a worker.
 

Overrides:

registerWorker in class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

registerWorkerStream

public io.grpc.stub.StreamObserver<RegisterWorkerPRequest> registerWorkerStream(io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver)

Description copied from class: BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

 Registers a worker in a streaming way
 

Overrides:

registerWorkerStream in class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

notifyWorkerId

public void notifyWorkerId(NotifyWorkerIdPRequest request,
                           io.grpc.stub.StreamObserver<NotifyWorkerIdPResponse> responseObserver)

Description copied from class: BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

 Notify all masters about the worker ID.
 

Overrides:

notifyWorkerId in class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase