alluxio.client.lineage

Class LineageFileSystem

java.lang.Object

alluxio.client.file.BaseFileSystem

alluxio.client.lineage.LineageFileSystem

All Implemented Interfaces:

FileSystem

@PublicApi
 @ThreadSafe
public final class LineageFileSystem
extends BaseFileSystem

Alluxio lineage file system client. This class provides lineage support in the file system operations.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.client.file.FileSystem

FileSystem.Factory

Field Summary

Fields inherited from class alluxio.client.file.BaseFileSystem

mFileSystemContext

Method Summary

Modifier and Type	Method and Description
FileOutStream	createFile(AlluxioURI path, CreateFileOptions options) Gets the output stream for lineage job.
static LineageFileSystem	get(FileSystemContext fileSystemContext, LineageContext lineageContext)
void	reportLostFile(AlluxioURI path) Reports a file as lost.

Methods inherited from class alluxio.client.file.BaseFileSystem

createDirectory, createDirectory, createFile, delete, delete, exists, exists, free, free, get, getMountTable, getStatus, getStatus, listStatus, listStatus, loadMetadata, loadMetadata, mount, mount, openFile, openFile, rename, rename, setAttribute, setAttribute, unmount, unmount

Methods inherited from class java.lang.Object

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

Method Detail

get

public static LineageFileSystem get(FileSystemContext fileSystemContext,
                                    LineageContext lineageContext)

Parameters:

fileSystemContext - file system context

lineageContext - lineage context

Returns:

the current lineage file system for Alluxio

createFile

public FileOutStream createFile(AlluxioURI path,
                                CreateFileOptions options)
                         throws IOException,
                                AlluxioException

Gets the output stream for lineage job. If the file already exists on master, returns a dummy output stream.

Specified by:

createFile in interface FileSystem

Overrides:

createFile in class BaseFileSystem

Parameters:

path - the Alluxio path of the file

options - the set of options specific to this operation

Returns:

an output stream to write the file

Throws:

FileAlreadyExistsException - if there is already a file at the given path

InvalidPathException - if the path is invalid

IOException

AlluxioException

reportLostFile

public void reportLostFile(AlluxioURI path)
                    throws IOException,
                           FileDoesNotExistException,
                           AlluxioException

Reports a file as lost.

Parameters:

path - the path to the lost file

Throws:

FileDoesNotExistException - if the file does not exist

IOException

AlluxioException