Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.block.stream | |
alluxio.client.file | |
alluxio.client.file.options | |
alluxio.client.lineage |
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,
WorkerNetAddress address,
OutStreamOptions options)
Gets a stream to write data to a block.
|
Modifier and Type | Method and Description |
---|---|
static PacketWriter |
PacketWriter.Factory.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options) |
static BlockOutStream |
BlockOutStream.create(FileSystemContext context,
long blockId,
long blockSize,
WorkerNetAddress address,
OutStreamOptions options)
Creates an
BlockOutStream . |
static NettyPacketWriter |
NettyPacketWriter.create(FileSystemContext context,
WorkerNetAddress address,
long id,
long length,
Protocol.RequestType type,
OutStreamOptions options) |
static LocalFilePacketWriter |
LocalFilePacketWriter.create(FileSystemContext context,
WorkerNetAddress address,
long blockId,
OutStreamOptions options)
Creates an instance of
LocalFilePacketWriter . |
static UnderFileSystemFileOutStream |
UnderFileSystemFileOutStream.create(FileSystemContext context,
WorkerNetAddress address,
OutStreamOptions options)
Creates an instance of
UnderFileSystemFileOutStream that writes to a UFS file. |
Constructor and Description |
---|
FileOutStream(AlluxioURI path,
OutStreamOptions options,
FileSystemContext context)
Creates a new file output stream.
|
Modifier and Type | Method and Description |
---|---|
static OutStreamOptions |
OutStreamOptions.defaults() |
OutStreamOptions |
OutStreamOptions.setBlockSizeBytes(long blockSizeBytes)
Sets the size of the block in bytes.
|
OutStreamOptions |
OutStreamOptions.setGroup(String group) |
OutStreamOptions |
OutStreamOptions.setLocationPolicy(FileWriteLocationPolicy locationPolicy) |
OutStreamOptions |
OutStreamOptions.setMode(Mode mode) |
OutStreamOptions |
OutStreamOptions.setMountId(long mountId) |
OutStreamOptions |
OutStreamOptions.setOwner(String owner) |
OutStreamOptions |
OutStreamOptions.setTtl(long ttl)
Sets the time to live.
|
OutStreamOptions |
OutStreamOptions.setTtlAction(TtlAction ttlAction) |
OutStreamOptions |
OutStreamOptions.setUfsPath(String ufsPath) |
OutStreamOptions |
OutStreamOptions.setWriteTier(int writeTier)
Sets the write tier.
|
OutStreamOptions |
OutStreamOptions.setWriteType(WriteType writeType)
Sets the
WriteType . |
OutStreamOptions |
CreateFileOptions.toOutStreamOptions() |
Constructor and Description |
---|
DummyFileOutputStream(AlluxioURI path,
OutStreamOptions options)
Constructs a new dummy file output stream.
|
LineageFileOutStream(FileSystemContext context,
AlluxioURI path,
OutStreamOptions options)
Creates a new file output stream when lineage is enabled.
|
Copyright © 2023. All Rights Reserved.