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 © 2023. All Rights Reserved.