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,
GrpcServerAddress address,
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(DynamicResourcePool.ResourceInternal<BlockWorkerClient> clientResourceInternal) |
Modifier and Type | Method and Description |
---|---|
CloseableResource<BlockWorkerClient> |
FileSystemContext.acquireBlockWorkerClient(WorkerNetAddress workerNetAddress)
Acquires a block worker client from the client pools.
|
Copyright © 2023. All Rights Reserved.