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, alluxio.wire.WorkerNetAddress address) Constructs a new UnderFileSystemFileOutStream with only one DataWriter.

Method Summary

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

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

cancel, close, create, 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,
                                       alluxio.wire.WorkerNetAddress address)

Constructs a new UnderFileSystemFileOutStream with only one DataWriter.

Parameters:

dataWriter - the data writer

Method Detail

create

public static UnderFileSystemFileOutStream create(FileSystemContext context,
                                                  alluxio.wire.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