public static final class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub extends io.grpc.stub.AbstractFutureStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub>
This interface contains block master service endpoints for Alluxio workers.
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<BlockHeartbeatPResponse> |
blockHeartbeat(BlockHeartbeatPRequest request)
Periodic block worker heartbeat returns an optional command for the block worker to execute.
|
protected BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
com.google.common.util.concurrent.ListenableFuture<CommitBlockPResponse> |
commitBlock(CommitBlockPRequest request)
Marks the given block as committed.
|
com.google.common.util.concurrent.ListenableFuture<CommitBlockInUfsPResponse> |
commitBlockInUfs(CommitBlockInUfsPRequest request)
Marks the given block as committed which resides in UFS.
|
com.google.common.util.concurrent.ListenableFuture<GetWorkerIdPResponse> |
getWorkerId(GetWorkerIdPRequest request)
Returns a worker id for the given network address.
|
com.google.common.util.concurrent.ListenableFuture<RegisterWorkerPResponse> |
registerWorker(RegisterWorkerPRequest request)
Registers a worker.
|
protected BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub>
public com.google.common.util.concurrent.ListenableFuture<BlockHeartbeatPResponse> blockHeartbeat(BlockHeartbeatPRequest request)
Periodic block worker heartbeat returns an optional command for the block worker to execute.
public com.google.common.util.concurrent.ListenableFuture<CommitBlockPResponse> commitBlock(CommitBlockPRequest request)
Marks the given block as committed.
public com.google.common.util.concurrent.ListenableFuture<CommitBlockInUfsPResponse> commitBlockInUfs(CommitBlockInUfsPRequest request)
Marks the given block as committed which resides in UFS.
public com.google.common.util.concurrent.ListenableFuture<GetWorkerIdPResponse> getWorkerId(GetWorkerIdPRequest request)
Returns a worker id for the given network address.
public com.google.common.util.concurrent.ListenableFuture<RegisterWorkerPResponse> registerWorker(RegisterWorkerPRequest request)
Registers a worker.
Copyright © 2023. All Rights Reserved.