alluxio.client.block.stream

Class UnderFileSystemFileOutStream

java.lang.Object

java.io.OutputStream

alluxio.client.block.stream.BlockOutStream

alluxio.client.block.stream.UnderFileSystemFileOutStream

All Implemented Interfaces:

BoundedStream, Cancelable, Closeable, Flushable, AutoCloseable

@NotThreadSafe
public class UnderFileSystemFileOutStream
extends BlockOutStream

Provides a streaming API to write to a file in the under file system through an Alluxio worker's data server.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	UnderFileSystemFileOutStream(DataWriter dataWriter, WorkerNetAddress address) Constructs a new UnderFileSystemFileOutStream with only one DataWriter.

Method Summary

Modifier and Type	Method and Description
void	close()
static UnderFileSystemFileOutStream	create(FileSystemContext context, WorkerNetAddress address, OutStreamOptions options) Creates an instance of UnderFileSystemFileOutStream that writes to a UFS file.
DataWriter	getDataWriter()

Methods inherited from class alluxio.client.block.stream.BlockOutStream

cancel, createReplicatedBlockOutStream, flush, getAddress, remaining, write, write, write, write, write

Methods inherited from class java.lang.Object

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

Constructor Detail

UnderFileSystemFileOutStream

protected UnderFileSystemFileOutStream(DataWriter dataWriter,
                                       WorkerNetAddress address)

Constructs a new UnderFileSystemFileOutStream with only one DataWriter.

Parameters:

dataWriter - the data writer

Method Detail

create

public static UnderFileSystemFileOutStream create(FileSystemContext context,
                                                  WorkerNetAddress address,
                                                  OutStreamOptions options)
                                           throws IOException

Creates an instance of UnderFileSystemFileOutStream that writes to a UFS file.

Parameters:

context - the file system context

address - the data server address

options - the out stream options

Returns:

the under file system output stream

Throws:

IOException

getDataWriter

public DataWriter getDataWriter()

Returns:

the data writer for the stream

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class BlockOutStream

Throws:

IOException