Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.client.file | |
alluxio.client.file.dora | |
alluxio.client.file.dora.netty | |
alluxio.client.file.options | |
alluxio.client.file.ufs |
Modifier and Type | Method and Description |
---|---|
static BlockWorkerDataWriter |
BlockWorkerDataWriter.create(FileSystemContext context,
long blockId,
long blockSize,
OutStreamOptions options)
Creates an instance of
BlockWorkerDataWriter . |
static DataWriter |
DataWriter.Factory.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options) |
static NettyDataWriter |
NettyDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long id,
long length,
RequestType type,
OutStreamOptions options) |
static GrpcDataWriter |
GrpcDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long id,
long length,
RequestType type,
OutStreamOptions options) |
Constructor and Description |
---|
DoraFileOutStream(DoraCacheClient doraClient,
NettyDataWriter dataWriter,
AlluxioURI path,
OutStreamOptions options,
FileSystemContext context,
FileOutStream ufsOutStream,
String uuid)
Creates a new file output stream.
|
Modifier and Type | Method and Description |
---|---|
DoraFileOutStream |
DoraCacheClient.getOutStream(AlluxioURI alluxioPath,
FileSystemContext fsContext,
OutStreamOptions outStreamOptions,
FileOutStream ufsOutStream,
String uuid)
Get a stream to write the data to dora cache cluster.
|
Modifier and Type | Method and Description |
---|---|
static NettyDataWriter |
NettyDataWriter.create(FileSystemContext context,
WorkerNetAddress address,
long length,
RequestType type,
OutStreamOptions options) |
Constructor and Description |
---|
NettyDataWriter(FileSystemContext context,
WorkerNetAddress address,
long length,
long packetSize,
RequestType type,
OutStreamOptions options,
io.netty.channel.Channel channel)
Creates an instance of
NettyDataWriter . |
Modifier and Type | Method and Description |
---|---|
static OutStreamOptions |
OutStreamOptions.defaults(FileSystemContext context) |
static OutStreamOptions |
OutStreamOptions.defaults(FileSystemContext context,
AlluxioConfiguration alluxioConf) |
OutStreamOptions |
OutStreamOptions.setAcl(AccessControlList acl)
Sets the acl of the file.
|
OutStreamOptions |
OutStreamOptions.setBlockSizeBytes(long blockSizeBytes)
Sets the size of the block in bytes.
|
protected OutStreamOptions |
OutStreamOptions.setCommonOptions(FileSystemMasterCommonPOptions commonOptions) |
OutStreamOptions |
OutStreamOptions.setGroup(String group) |
OutStreamOptions |
OutStreamOptions.setMediumType(String mediumType)
Set the write medium type of the file.
|
OutStreamOptions |
OutStreamOptions.setMode(Mode mode) |
OutStreamOptions |
OutStreamOptions.setMountId(long mountId) |
OutStreamOptions |
OutStreamOptions.setOwner(String owner) |
OutStreamOptions |
OutStreamOptions.setPersistenceWaitTime(long persistenceWaitTime) |
OutStreamOptions |
OutStreamOptions.setReplicationDurable(int replicationDurable) |
OutStreamOptions |
OutStreamOptions.setReplicationMax(int replicationMax) |
OutStreamOptions |
OutStreamOptions.setReplicationMin(int replicationMin) |
OutStreamOptions |
OutStreamOptions.setUfsPath(String ufsPath) |
OutStreamOptions |
OutStreamOptions.setWriteTier(int writeTier)
Sets the write tier.
|
OutStreamOptions |
OutStreamOptions.setWriteType(WriteType writeType)
Sets the
WriteType . |
Constructor and Description |
---|
DoraOutStream(AlluxioURI path,
OutStreamOptions options,
FileSystemContext context,
String uuid,
DoraCacheClient doraClient)
Creates a new file output stream.
|
Copyright © 2023. All Rights Reserved.