Package | Description |
---|---|
alluxio.master | |
alluxio.web | |
alluxio.worker |
Worker process and utils for working with the worker remotely.
|
alluxio.worker.grpc |
Modifier and Type | Field and Description |
---|---|
protected List<WorkerProcess> |
AbstractLocalAlluxioCluster.mWorkers |
Modifier and Type | Method and Description |
---|---|
WorkerProcess |
LocalAlluxioCluster.getWorkerProcess() |
Constructor and Description |
---|
WorkerWebServer(InetSocketAddress webAddress,
WorkerProcess workerProcess,
BlockWorker blockWorker,
String connectHost,
long startTimeMs)
Creates a new instance of
WorkerWebServer . |
Modifier and Type | Class and Description |
---|---|
class |
AlluxioWorkerProcess
This class encapsulates the different worker services that are configured to run.
|
Modifier and Type | Method and Description |
---|---|
static WorkerProcess |
WorkerProcess.Factory.create() |
static WorkerProcess |
WorkerProcess.Factory.create(TieredIdentity tieredIdentity) |
Constructor and Description |
---|
BlockWorkerClientServiceHandler(WorkerProcess workerProcess,
FileSystemContext fsContext,
boolean domainSocketEnabled)
Creates a new implementation of gRPC BlockWorker interface.
|
DelegationWriteHandler(WorkerProcess workerProcess,
io.grpc.stub.StreamObserver<WriteResponse> responseObserver,
AuthenticatedUserInfo userInfo,
boolean domainSocketEnabled) |
GrpcDataServer(String hostName,
SocketAddress bindAddress,
WorkerProcess workerProcess)
Creates a new instance of
GrpcDataServer . |
Copyright © 2023. All Rights Reserved.