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
BlockInStream	Provides an InputStream implementation that is based on DataReaders to stream data chunk by chunk.
BlockOutStream	Provides an OutputStream implementation that is based on DataWriter which streams data chunk by chunk.
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.
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.
LocalFileDataReader	A data reader that simply reads packets from a local file.
LocalFileDataReader.Factory	Factory class to create LocalFileDataReaders.
LocalFileDataWriter	A local data writer that simply writes packets to a local file.
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.
UfsFallbackLocalFileDataWriter	A data writer that writes to local first and fallback to UFS block writes when the block storage on this local worker is full.
UnderFileSystemFileOutStream	Provides a streaming API to write to a file in the under file system through an Alluxio worker's data server.

Enum Summary

Enum	Description
BlockInStream.BlockInStreamSource	the source tracking where the block is from.