Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.block.stream | |
alluxio.client.file |
Class and Description |
---|
BlockInStream
Provides an
InputStream implementation that is based on DataReader s to
stream data chunk by chunk. |
BlockOutStream
Provides an
OutputStream implementation that is based on DataWriter which
streams data chunk by chunk. |
Class and Description |
---|
BlockInStream
Provides an
InputStream implementation that is based on DataReader s to
stream data chunk by chunk. |
BlockInStream.BlockInStreamSource
the source tracking where the block is from.
|
BlockOutStream
Provides an
OutputStream implementation that is based on DataWriter which
streams data chunk by chunk. |
BlockWorkerClient
gRPC client for worker communication.
|
BufferCachingGrpcDataReader
A gRPC data reader that responsible for reading from a specific block.
|
DataReader
The interface to read data chunks.
|
DataReader.Factory
The factory interface to create
DataReader s. |
DataWriter
The interface to write data.
|
GrpcBlockingStream
A helper class for accessing gRPC bi-directional stream synchronously.
|
GrpcDataWriter
A gRPC data writer that streams a full block or a UFS file to a gRPC data server.
|
LocalFileDataWriter
A local data writer that simply writes packets to a local file.
|
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.
|
Class and Description |
---|
BlockWorkerClient
gRPC client for worker communication.
|
Copyright © 2023. All Rights Reserved.