| 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(UserState userState,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf)
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) |
| Constructor and Description |
|---|
BufferCachingGrpcDataReader(WorkerNetAddress address,
CloseableResource<BlockWorkerClient> client,
long dataTimeoutMs,
ReadRequest readRequest,
GrpcBlockingStream<ReadRequest,ReadResponse> stream)
Creates an instance of
BufferCachingGrpcDataReader. |
| Modifier and Type | Method and Description |
|---|---|
CloseableResource<BlockWorkerClient> |
FileSystemContext.acquireBlockWorkerClient(WorkerNetAddress workerNetAddress)
Acquires a block worker client from the client pools.
|
Copyright © 2022. All Rights Reserved.