Package alluxio.client.block.stream

Interface Summary

Interface	Description
BlockWorkerClient	gRPC client for worker communication.
DataReader	The interface to read data chunks.
DataReader.Factory	The factory interface to create DataReaders.
DataWriter	The interface to write data.

Class Summary

Class	Description
BlockWorkerClient.Factory	Factory for block worker client.
BlockWorkerClientPool	Class for managing block worker clients.
BlockWorkerDataReader	A data reader that reads from a worker in the same process of this client directly.
BlockWorkerDataReader.Factory	Factory class to create BlockWorkerDataReaders.
BlockWorkerDataWriter	A data writer that issues from a client embedded in a worker to write data to the worker directly via internal communication channel.
BufferCachingGrpcDataReader	A gRPC data reader that responsible for reading from a specific block.
DataMessageClientResponseObserver<ReqT,RespT>	A StreamObserver that handles raw data buffers.
DataWriter.Factory	Factory for DataWriter.
DefaultBlockWorkerClient	Default implementation of BlockWorkerClient.
DefaultBlockWorkerClient.NoDataReadStreamObserver	No data read stream observer.
GrpcBlockingStream<ReqT,ResT>	A helper class for accessing gRPC bi-directional stream synchronously.
GrpcDataMessageBlockingStream<ReqT,ResT>	A helper class for accessing gRPC bi-directional stream synchronously.
GrpcDataReader	A gRPC data reader that streams a region from gRPC data server.
GrpcDataReader.Factory	Factory class to create GrpcDataReaders.
GrpcDataWriter	A gRPC data writer that streams a full block or a UFS file to a gRPC data server.
NettyDataReader	A netty packet reader that streams a region from a netty data server.
NettyDataReader.Factory	Factory class to create NettyDataReaders.
NettyDataWriter	A netty packet writer that streams a full block or a UFS file to a netty data server.
SharedGrpcDataReader	A shared gRPC data reader that cache blocks data for multi-thread accessing.
SharedGrpcDataReader.Factory	Factory class to create SharedGrpcDataReaders.
StreamSerializationClientInterceptor	Serialization interceptor for client.