alluxio.client.lineage

Class LineageFileOutStream

java.lang.Object

java.io.OutputStream

alluxio.client.AbstractOutStream

alluxio.client.file.FileOutStream

alluxio.client.lineage.LineageFileOutStream

All Implemented Interfaces:

Cancelable, Closeable, Flushable, AutoCloseable

@PublicApi
 @NotThreadSafe
public class LineageFileOutStream
extends FileOutStream

A stream API to write a file when lineage is enabled. It supports asynchronous persistence of the data to the under storage system.

Field Summary

Fields inherited from class alluxio.client.file.FileOutStream

mUri

Fields inherited from class alluxio.client.AbstractOutStream

mBytesWritten

Constructor Summary

Constructors

Constructor and Description
LineageFileOutStream(FileSystemContext context, AlluxioURI path, OutStreamOptions options) Creates a new file output stream when lineage is enabled.

Method Summary

Modifier and Type	Method and Description
protected void	scheduleAsyncPersist() Schedules the async persistence of the current file.

Methods inherited from class alluxio.client.file.FileOutStream

cancel, close, flush, write, write, write

Methods inherited from class alluxio.client.AbstractOutStream

getBytesWritten

Methods inherited from class java.lang.Object

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

Constructor Detail

LineageFileOutStream

public LineageFileOutStream(FileSystemContext context,
                            AlluxioURI path,
                            OutStreamOptions options)
                     throws IOException

Creates a new file output stream when lineage is enabled.

Parameters:

context - file system context

path - the path of the file

options - the set of options specific to this operation

Throws:

IOException

Method Detail

scheduleAsyncPersist

protected void scheduleAsyncPersist()
                             throws IOException

Description copied from class: FileOutStream

Schedules the async persistence of the current file.

Overrides:

scheduleAsyncPersist in class FileOutStream

Throws:

IOException