| Package | Description |
|---|---|
| alluxio.client.block.stream |
| Modifier and Type | Class and Description |
|---|---|
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,
alluxio.wire.WorkerNetAddress address,
OutStreamOptions options) |
| Constructor and Description |
|---|
BlockOutStream(DataWriter dataWriter,
long length,
alluxio.wire.WorkerNetAddress address)
Constructs a new
BlockOutStream with only one DataWriter. |
UnderFileSystemFileOutStream(DataWriter dataWriter,
alluxio.wire.WorkerNetAddress address)
Constructs a new
UnderFileSystemFileOutStream with only one DataWriter. |
| Constructor and Description |
|---|
BlockOutStream(List<DataWriter> dataWriters,
long length,
List<alluxio.wire.WorkerNetAddress> workerNetAddresses)
Constructs a new
BlockOutStream with only one DataWriter. |
Copyright © 2024. All Rights Reserved.