Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.grpc | |
alluxio.worker.grpc |
Modifier and Type | Method and Description |
---|---|
DataMessage<ResT,DataBuffer> |
GrpcDataMessageBlockingStream.receiveDataMessage(long timeoutMs)
Receives a response with data buffer from the server.
|
Modifier and Type | Method and Description |
---|---|
void |
GrpcDataMessageBlockingStream.sendDataMessage(DataMessage<ReqT,DataBuffer> message,
long timeoutMs)
Sends a request.
|
Modifier and Type | Method and Description |
---|---|
ReadResponse |
ReadResponseMarshaller.combineData(DataMessage<ReadResponse,DataBuffer> message) |
abstract T |
DataMessageMarshaller.combineData(DataMessage<T,DataBuffer> message)
Combines the data buffer into the message.
|
WriteRequest |
WriteRequestMarshaller.combineData(DataMessage<WriteRequest,DataBuffer> message) |
Modifier and Type | Method and Description |
---|---|
void |
DataMessageServerStreamObserver.onNext(DataMessage<T,DataBuffer> value)
Receives a message with data buffer from the stream.
|
Copyright © 2023. All Rights Reserved.