Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.grpc | |
alluxio.network.protocol.databuffer | |
alluxio.worker.block.io | |
alluxio.worker.grpc | |
alluxio.worker.page |
Modifier and Type | Field and Description |
---|---|
protected DataBuffer |
BlockInStream.mCurrentChunk
The current data chunk.
|
Modifier and Type | Method and Description |
---|---|
DataBuffer |
GrpcDataReader.readChunk() |
DataBuffer |
BlockWorkerDataReader.readChunk() |
DataBuffer |
LocalFileDataReader.readChunk() |
protected DataBuffer |
BufferCachingGrpcDataReader.readChunk()
Reads a chunk of data.
|
DataBuffer |
SharedGrpcDataReader.readChunk() |
DataBuffer |
DataReader.readChunk()
Reads a chunk.
|
DataBuffer |
BufferCachingGrpcDataReader.readChunk(int index)
Reads a specific chunk from the block.
|
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 | Class and Description |
---|---|
class |
ReadableDataBuffer
Class for making wrapping
ReadableBuffer as DataBuffer . |
Modifier and Type | Method and Description |
---|---|
DataBuffer |
DataMessageMarshaller.pollBuffer(T message) |
Modifier and Type | Method and Description |
---|---|
void |
DataMessageMarshaller.offerBuffer(DataBuffer buffer,
T message) |
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 | Class and Description |
---|---|
class |
NettyDataBuffer
A DataBuffer with the underlying data being a
ByteBuf . |
class |
NioDataBuffer
A DataBuffer with the underlying data being a
ByteBuffer . |
Modifier and Type | Method and Description |
---|---|
long |
LocalFileBlockWriter.append(DataBuffer buffer) |
abstract long |
BlockWriter.append(DataBuffer buffer)
Appends buffer.readableBytes() bytes to the end of this block writer from the given buffer.
|
Modifier and Type | Method and Description |
---|---|
protected void |
UfsFallbackBlockWriteHandler.writeBuf(BlockWriteRequestContext context,
io.grpc.stub.StreamObserver<WriteResponse> responseObserver,
DataBuffer buf,
long pos) |
protected void |
BlockWriteHandler.writeBuf(BlockWriteRequestContext context,
io.grpc.stub.StreamObserver<WriteResponse> observer,
DataBuffer buf,
long pos) |
protected void |
UfsFileWriteHandler.writeBuf(UfsFileWriteRequestContext context,
io.grpc.stub.StreamObserver<WriteResponse> observer,
DataBuffer buf,
long pos) |
Modifier and Type | Method and Description |
---|---|
void |
DataMessageServerStreamObserver.onNext(DataMessage<T,DataBuffer> value)
Receives a message with data buffer from the stream.
|
Constructor and Description |
---|
DataMessageServerStreamObserver(io.grpc.stub.CallStreamObserver<T> observer,
BufferRepository<T,DataBuffer> bufferRepository) |
Modifier and Type | Method and Description |
---|---|
long |
PagedBlockWriter.append(DataBuffer buffer) |
Copyright © 2023. All Rights Reserved.