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() |
WorkerProcess |
MultiMasterEmbeddedJournalLocalAlluxioCluster.getWorkerProcess(int index) |
WorkerProcess |
MultiMasterLocalAlluxioCluster.getWorkerProcess(int index) |
Constructor and Description |
---|
WorkerWebServer(InetSocketAddress webAddress,
WorkerProcess workerProcess,
BlockWorker blockWorker)
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,
boolean domainSocketEnabled)
Creates a new implementation of gRPC BlockWorker interface.
|
GrpcDataServer(String hostName,
SocketAddress bindAddress,
WorkerProcess workerProcess)
Creates a new instance of
GrpcDataServer . |
Copyright © 2023. All Rights Reserved.