Package | Description |
---|---|
alluxio.master.block |
Modifier and Type | Method and Description |
---|---|
static WorkerRegisterContext |
WorkerRegisterContext.create(BlockMaster blockMaster,
long workerId,
io.grpc.stub.StreamObserver<RegisterWorkerPRequest> workerRequestObserver)
Creates a new
WorkerRegisterContext . |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultBlockMaster.workerRegisterBatch(WorkerRegisterContext context,
RegisterWorkerPRequest chunk) |
void |
DefaultBlockMaster.workerRegisterFinish(WorkerRegisterContext context) |
void |
BlockMaster.workerRegisterFinish(WorkerRegisterContext context)
Completes the worker registration stream.
|
protected void |
DefaultBlockMaster.workerRegisterStart(WorkerRegisterContext context,
RegisterWorkerPRequest chunk) |
void |
DefaultBlockMaster.workerRegisterStream(WorkerRegisterContext context,
RegisterWorkerPRequest chunk,
boolean isFirstMsg) |
void |
BlockMaster.workerRegisterStream(WorkerRegisterContext context,
RegisterWorkerPRequest chunk,
boolean isFirstMsg)
Handles messages in a register stream.
|
Copyright © 2023. All Rights Reserved.