alluxio.master.block

Class WorkerRegisterContext

java.lang.Object

alluxio.master.block.WorkerRegisterContext

All Implemented Interfaces:

Closeable, AutoCloseable

public class WorkerRegisterContext
extends Object
implements Closeable

This holds the context while the worker is registering with the master with a stream. This context is initialized when the stream starts and closed when the stream is either completed or aborted.

Method Summary

Modifier and Type	Method and Description
void	close()
static WorkerRegisterContext	create(BlockMaster blockMaster, long workerId, io.grpc.stub.StreamObserver<RegisterWorkerPRequest> workerRequestObserver) Creates a new WorkerRegisterContext.
long	getWorkerId() Getter for worker ID.
boolean	isOpen() Checks whether the stream is still open.

Methods inherited from class java.lang.Object

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

Method Detail

getWorkerId

public long getWorkerId()

Getter for worker ID.

Returns:

worker ID

isOpen

public boolean isOpen()

Checks whether the stream is still open. If not open, no more operation should be permitted on the stream, and this stream has been closed and all the locks have been released.

Returns:

whether the stream is still open

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

create

public static WorkerRegisterContext create(BlockMaster blockMaster,
                                           long workerId,
                                           io.grpc.stub.StreamObserver<RegisterWorkerPRequest> workerRequestObserver)
                                    throws NotFoundException

Creates a new WorkerRegisterContext.

Parameters:

blockMaster - the block master

workerId - the worker ID

workerRequestObserver - receives requests from the worker

Returns:

a new WorkerRegisterContext

Throws:

NotFoundException