Uses of Interface
alluxio.network.protocol.databuffer.DataBuffer

Packages that use DataBuffer

Package	Description
alluxio.client.block.stream
alluxio.grpc
alluxio.network.protocol.databuffer
alluxio.worker.block.io
alluxio.worker.grpc

Uses of DataBuffer in alluxio.client.block.stream

Methods in alluxio.client.block.stream that return DataBuffer

Modifier and Type	Method and Description
DataBuffer	LocalFileDataReader.readChunk()
DataBuffer	GrpcDataReader.readChunk()
DataBuffer	DataReader.readChunk() Reads a chunk.

Methods in alluxio.client.block.stream that return types with arguments of type DataBuffer

Modifier and Type	Method and Description
DataMessage<ResT,DataBuffer>	GrpcDataMessageBlockingStream.receiveDataMessage(long timeoutMs) Receives a response with data buffer from the server.

Method parameters in alluxio.client.block.stream with type arguments of type DataBuffer

Modifier and Type	Method and Description
void	GrpcDataMessageBlockingStream.sendDataMessage(DataMessage<ReqT,DataBuffer> message, long timeoutMs) Sends a request.

Uses of DataBuffer in alluxio.grpc

Classes in alluxio.grpc that implement DataBuffer

Modifier and Type	Class and Description
class	ReadableDataBuffer Class for making wrapping ReadableBuffer as DataBuffer.

Methods in alluxio.grpc that return DataBuffer

Modifier and Type	Method and Description
DataBuffer	DataMessageMarshaller.pollBuffer(T message)

Methods in alluxio.grpc with parameters of type DataBuffer

Modifier and Type	Method and Description
void	DataMessageMarshaller.offerBuffer(DataBuffer buffer, T message)

Method parameters in alluxio.grpc with type arguments of type DataBuffer

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)

Uses of DataBuffer in alluxio.network.protocol.databuffer

Classes in alluxio.network.protocol.databuffer that implement DataBuffer

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.

Uses of DataBuffer in alluxio.worker.block.io

Methods in alluxio.worker.block.io with parameters of type DataBuffer

Modifier and Type	Method and Description
long	BlockWriter.append(DataBuffer buffer) Appends buffer.readableBytes() bytes to the end of this block writer from the given buffer.
long	LocalFileBlockWriter.append(DataBuffer buffer)

Uses of DataBuffer in alluxio.worker.grpc

Methods in alluxio.worker.grpc that return DataBuffer

Modifier and Type	Method and Description
protected DataBuffer	BlockReadHandler.BlockDataReader.getDataBuffer(BlockReadRequestContext context, io.grpc.stub.StreamObserver<ReadResponse> response, long offset, int len)

Methods in alluxio.worker.grpc with parameters of type DataBuffer

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)

Method parameters in alluxio.worker.grpc with type arguments of type DataBuffer

Modifier and Type	Method and Description
void	DataMessageServerStreamObserver.onNext(DataMessage<T,DataBuffer> value) Receives a message with data buffer from the stream.

Constructor parameters in alluxio.worker.grpc with type arguments of type DataBuffer

Constructor and Description
DataMessageServerStreamObserver(io.grpc.stub.CallStreamObserver<T> observer, BufferRepository<T,DataBuffer> bufferRepository)