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