alluxio.fuse.file

Class FuseFileInOrOutStream

java.lang.Object

alluxio.fuse.file.FuseFileInOrOutStream

All Implemented Interfaces:

FuseFileStream, java.lang.AutoCloseable

@ThreadSafe
public class FuseFileInOrOutStream
extends java.lang.Object
implements FuseFileStream

An implementation for FuseFileStream for read only or write only workloads. Fuse can open file for reading and writing concurrently but Alluxio only support read-only or write-only workloads. This class will be used as write only stream if O_TRUNC flag is provided or first operation is write() or truncate(), will be used as read only stream otherwise.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.fuse.file.FuseFileStream

FuseFileStream.Factory

Method Summary

Modifier and Type	Method and Description
void	close() Closes the stream.
static FuseFileInOrOutStream	create(FileSystem fileSystem, AuthPolicy authPolicy, AlluxioURI uri, int flags, long mode, java.util.Optional<URIStatus> status) Creates a FuseFileInOrOutStream.
void	flush() Flushes the stream.
long	getFileLength() Gets the file length.
int	read(java.nio.ByteBuffer buf, long size, long offset) Reads data from the stream.
void	truncate(long size) Truncates the file to the given size.
void	write(java.nio.ByteBuffer buf, long size, long offset) Writes data to the stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static FuseFileInOrOutStream create(FileSystem fileSystem,
                                           AuthPolicy authPolicy,
                                           AlluxioURI uri,
                                           int flags,
                                           long mode,
                                           java.util.Optional<URIStatus> status)

Creates a FuseFileInOrOutStream.

Parameters:

fileSystem - the Alluxio file system

authPolicy - the Authentication policy

uri - the alluxio uri

flags - the fuse create/open flags

mode - the filesystem mode, -1 if not set

status - the uri status, null if not uri does not exist

Returns:

a FuseFileInOrOutStream

read

public int read(java.nio.ByteBuffer buf,
                long size,
                long offset)

Description copied from interface: FuseFileStream

Reads data from the stream.

Specified by:

read in interface FuseFileStream

Parameters:

buf - the byte buffer to read data to

size - the size to read

offset - the offset of the target stream to begin reading

Returns:

the bytes read

write

public void write(java.nio.ByteBuffer buf,
                  long size,
                  long offset)

Description copied from interface: FuseFileStream

Writes data to the stream.

Specified by:

write in interface FuseFileStream

Parameters:

buf - the byte buffer to read data from and write to the stream

size - the size to write

offset - the offset to write

getFileLength

public long getFileLength()

Description copied from interface: FuseFileStream

Gets the file length.

Specified by:

getFileLength in interface FuseFileStream

Returns:

file length

flush

public void flush()

Description copied from interface: FuseFileStream

Flushes the stream.

Specified by:

flush in interface FuseFileStream

truncate

public void truncate(long size)

Description copied from interface: FuseFileStream

Truncates the file to the given size.

Specified by:

truncate in interface FuseFileStream

Parameters:

size - the truncate size

close

public void close()

Description copied from interface: FuseFileStream

Closes the stream.

Specified by:

close in interface FuseFileStream

Specified by:

close in interface java.lang.AutoCloseable