| Package | Description |
|---|---|
| alluxio.client.block.stream | |
| alluxio.client.file |
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultBlockWorkerClient
Default implementation of
BlockWorkerClient. |
| Modifier and Type | Method and Description |
|---|---|
static BlockWorkerClient |
BlockWorkerClient.Factory.create(Subject subject,
alluxio.grpc.GrpcServerAddress address,
alluxio.conf.AlluxioConfiguration alluxioConf,
io.netty.channel.EventLoopGroup workerGroup)
Creates a new block worker client.
|
protected BlockWorkerClient |
BlockWorkerClientPool.createNewResource() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
BlockWorkerClientPool.closeResource(BlockWorkerClient client) |
protected boolean |
BlockWorkerClientPool.isHealthy(BlockWorkerClient client)
Checks whether a client is healthy.
|
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
BlockWorkerClientPool.shouldGc(alluxio.resource.DynamicResourcePool.ResourceInternal<BlockWorkerClient> clientResourceInternal) |
| Modifier and Type | Method and Description |
|---|---|
BlockWorkerClient |
FileSystemContext.acquireBlockWorkerClient(alluxio.wire.WorkerNetAddress workerNetAddress)
Acquires a block worker client from the client pools.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FileSystemContext.releaseBlockWorkerClient(alluxio.wire.WorkerNetAddress workerNetAddress,
BlockWorkerClient client)
Releases a block worker client to the client pools.
|
Copyright © 2024. All Rights Reserved.