Package | Description |
---|---|
alluxio.client.block.stream |
Modifier and Type | Class and Description |
---|---|
class |
BlockWorkerDataWriter
A data writer that issues from a client embedded in a worker to write data to the worker directly
via internal communication channel.
|
class |
GrpcDataWriter
A gRPC data writer that streams a full block or a UFS file to a gRPC data server.
|
class |
LocalFileDataWriter
A local data writer that simply writes packets to a local file.
|
class |
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.
|
Modifier and Type | Method and Description |
---|---|
static DataWriter |
DataWriter.Factory.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options) |
DataWriter |
UnderFileSystemFileOutStream.getDataWriter() |
Constructor and Description |
---|
BlockOutStream(DataWriter dataWriter,
long length,
WorkerNetAddress address)
Constructs a new
BlockOutStream with only one DataWriter . |
UnderFileSystemFileOutStream(DataWriter dataWriter,
WorkerNetAddress address)
Constructs a new
UnderFileSystemFileOutStream with only one DataWriter . |
Constructor and Description |
---|
BlockOutStream(List<DataWriter> dataWriters,
long length,
List<WorkerNetAddress> workerNetAddresses)
Constructs a new
BlockOutStream with only one DataWriter . |
Copyright © 2023. All Rights Reserved.