| Package | Description |
|---|---|
| alluxio.client.block | |
| alluxio.client.block.stream | |
| alluxio.client.file | |
| alluxio.client.file.options |
| Modifier and Type | Method and Description |
|---|---|
BlockOutStream |
AlluxioBlockStore.getOutStream(long blockId,
long blockSize,
OutStreamOptions options)
Gets a stream to write data to a block based on the options.
|
BlockOutStream |
AlluxioBlockStore.getOutStream(long blockId,
long blockSize,
alluxio.wire.WorkerNetAddress address,
OutStreamOptions options)
Gets a stream to write data to a block.
|
| Modifier and Type | Method and Description |
|---|---|
static DataWriter |
DataWriter.Factory.create(FileSystemContext context,
long blockId,
long blockSize,
alluxio.wire.WorkerNetAddress address,
OutStreamOptions options) |
static BlockOutStream |
BlockOutStream.create(FileSystemContext context,
long blockId,
long blockSize,
alluxio.wire.WorkerNetAddress address,
OutStreamOptions options)
Creates an
BlockOutStream. |
static UfsFallbackLocalFileDataWriter |
UfsFallbackLocalFileDataWriter.create(FileSystemContext context,
alluxio.wire.WorkerNetAddress address,
long blockId,
long blockSize,
OutStreamOptions options) |
static GrpcDataWriter |
GrpcDataWriter.create(FileSystemContext context,
alluxio.wire.WorkerNetAddress address,
long id,
long length,
alluxio.grpc.RequestType type,
OutStreamOptions options) |
static LocalFileDataWriter |
LocalFileDataWriter.create(FileSystemContext context,
alluxio.wire.WorkerNetAddress address,
long blockId,
OutStreamOptions options)
Creates an instance of
LocalFileDataWriter. |
static UnderFileSystemFileOutStream |
UnderFileSystemFileOutStream.create(FileSystemContext context,
alluxio.wire.WorkerNetAddress address,
OutStreamOptions options)
Creates an instance of
UnderFileSystemFileOutStream that writes to a UFS file. |
static BlockOutStream |
BlockOutStream.createReplicatedBlockOutStream(FileSystemContext context,
long blockId,
long blockSize,
List<alluxio.wire.WorkerNetAddress> workerNetAddresses,
OutStreamOptions options)
Creates a new remote block output stream.
|
| Constructor and Description |
|---|
FileOutStream(alluxio.AlluxioURI path,
OutStreamOptions options,
FileSystemContext context)
Creates a new file output stream.
|
| Modifier and Type | Method and Description |
|---|---|
static OutStreamOptions |
OutStreamOptions.defaults(alluxio.ClientContext context) |
static OutStreamOptions |
OutStreamOptions.defaults(alluxio.ClientContext context,
alluxio.conf.AlluxioConfiguration alluxioConf) |
OutStreamOptions |
OutStreamOptions.setAcl(alluxio.security.authorization.AccessControlList acl)
Sets the acl of the file.
|
OutStreamOptions |
OutStreamOptions.setBlockSizeBytes(long blockSizeBytes)
Sets the size of the block in bytes.
|
OutStreamOptions |
OutStreamOptions.setGroup(String group) |
OutStreamOptions |
OutStreamOptions.setLocationPolicy(BlockLocationPolicy locationPolicy) |
OutStreamOptions |
OutStreamOptions.setMediumType(String mediumType)
Set the write medium type of the file.
|
OutStreamOptions |
OutStreamOptions.setMode(alluxio.security.authorization.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. |
Copyright © 2024. All Rights Reserved.