| Package | Description |
|---|---|
| alluxio.client.block.stream |
| Modifier and Type | Class and Description |
|---|---|
class |
GrpcDataMessageBlockingStream<ReqT,ResT>
A helper class for accessing gRPC bi-directional stream synchronously.
|
| Constructor and Description |
|---|
BufferCachingGrpcDataReader(WorkerNetAddress address,
CloseableResource<BlockWorkerClient> client,
long dataTimeoutMs,
ReadRequest readRequest,
GrpcBlockingStream<ReadRequest,ReadResponse> stream)
Creates an instance of
BufferCachingGrpcDataReader. |
Copyright © 2022. All Rights Reserved.