tachyon

Class UnderFileSystemHdfs

java.lang.Object

tachyon.UnderFileSystem

tachyon.UnderFileSystemHdfs

public class UnderFileSystemHdfs
extends UnderFileSystem

HDFS UnderFilesystem implementation.

Nested Class Summary

Nested classes/interfaces inherited from class tachyon.UnderFileSystem

UnderFileSystem.SpaceType

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.fs.FSDataOutputStream	create(String path)
org.apache.hadoop.fs.FSDataOutputStream	create(String path, int blockSizeByte) BlockSize should be a multiple of 512
org.apache.hadoop.fs.FSDataOutputStream	create(String path, short replication, int blockSizeByte)
boolean	delete(String path, boolean recursive)
boolean	exists(String path)
long	getBlockSizeByte(String path)
static UnderFileSystemHdfs	getClient(String path)
static UnderFileSystemHdfs	getClient(String path, Object conf)
Object	getConf() To get the configuration object for UnderFileSystem.
List<String>	getFileLocations(String path)
List<String>	getFileLocations(String path, long offset)
long	getFileSize(String path)
long	getModificationTimeMs(String path)
long	getSpace(String path, UnderFileSystem.SpaceType type)
boolean	isFile(String path)
String[]	list(String path) Returns an array of strings naming the files and directories in the directory denoted by this abstract pathname.
void	login(String keytabFileKey, String keytabFile, String principalKey, String principal, String hostname)
boolean	mkdirs(String path, boolean createParent) Creates the directory named by this abstract pathname.
org.apache.hadoop.fs.FSDataInputStream	open(String path)
boolean	rename(String src, String dst)
void	setConf(Object conf) To set the configuration object for UnderFileSystem.
void	setPermission(String path, String posixPerm) Change posix file permission

Methods inherited from class tachyon.UnderFileSystem

get, get, parse

Methods inherited from class java.lang.Object

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

Method Detail

getClient

public static UnderFileSystemHdfs getClient(String path)

getClient

public static UnderFileSystemHdfs getClient(String path,
                            Object conf)

close

public void close()
           throws IOException

Specified by:

close in class UnderFileSystem

Throws:

IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(String path)
                                               throws IOException

Specified by:

create in class UnderFileSystem

Throws:

IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(String path,
                                             int blockSizeByte)
                                               throws IOException

BlockSize should be a multiple of 512

Specified by:

create in class UnderFileSystem

Throws:

IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(String path,
                                             short replication,
                                             int blockSizeByte)
                                               throws IOException

Specified by:

create in class UnderFileSystem

Throws:

IOException

delete

public boolean delete(String path,
             boolean recursive)
               throws IOException

Specified by:

delete in class UnderFileSystem

Throws:

IOException

exists

public boolean exists(String path)
               throws IOException

Specified by:

exists in class UnderFileSystem

Throws:

IOException

getBlockSizeByte

public long getBlockSizeByte(String path)
                      throws IOException

Specified by:

getBlockSizeByte in class UnderFileSystem

Throws:

IOException

getConf

public Object getConf()

Description copied from class: UnderFileSystem

To get the configuration object for UnderFileSystem.

Specified by:

getConf in class UnderFileSystem

Returns:

configuration object used for concrete ufs instance

getFileLocations

public List<String> getFileLocations(String path)
                              throws IOException

Specified by:

getFileLocations in class UnderFileSystem

Throws:

IOException

getFileLocations

public List<String> getFileLocations(String path,
                            long offset)
                              throws IOException

Specified by:

getFileLocations in class UnderFileSystem

Throws:

IOException

getFileSize

public long getFileSize(String path)
                 throws IOException

Specified by:

getFileSize in class UnderFileSystem

Throws:

IOException

getModificationTimeMs

public long getModificationTimeMs(String path)
                           throws IOException

Specified by:

getModificationTimeMs in class UnderFileSystem

Throws:

IOException

getSpace

public long getSpace(String path,
            UnderFileSystem.SpaceType type)
              throws IOException

Specified by:

getSpace in class UnderFileSystem

Throws:

IOException

isFile

public boolean isFile(String path)
               throws IOException

Specified by:

isFile in class UnderFileSystem

Throws:

IOException

list

public String[] list(String path)
              throws IOException

Description copied from class: UnderFileSystem

Returns an array of strings naming the files and directories in the directory denoted by this abstract pathname.

If this abstract pathname does not denote a directory, then this method returns null. Otherwise an array of strings is returned, one for each file or directory in the directory. Names denoting the directory itself and the directory's parent directory are not included in the result. Each string is a file name rather than a complete path.

There is no guarantee that the name strings in the resulting array will appear in any specific order; they are not, in particular, guaranteed to appear in alphabetical order.

Specified by:

list in class UnderFileSystem

Parameters:

path - the path to list.

Returns:

An array of strings naming the files and directories in the directory denoted by this abstract pathname. The array will be empty if the directory is empty. Returns null if this abstract pathname does not denote a directory, or if an I/O error occurs.

Throws:

IOException

login

public void login(String keytabFileKey,
         String keytabFile,
         String principalKey,
         String principal,
         String hostname)
           throws IOException

Throws:

IOException

mkdirs

public boolean mkdirs(String path,
             boolean createParent)
               throws IOException

Description copied from class: UnderFileSystem

Creates the directory named by this abstract pathname. If the folder already exists, the method returns false.

Specified by:

mkdirs in class UnderFileSystem

Parameters:

path - the folder to create

createParent - If true, the method creates any necessary but nonexistent parent directories. Otherwise, the method does not create nonexistent parent directories.

Returns:

true if and only if the directory was created; false otherwise

Throws:

IOException

open

public org.apache.hadoop.fs.FSDataInputStream open(String path)
                                            throws IOException

Specified by:

open in class UnderFileSystem

Throws:

IOException

rename

public boolean rename(String src,
             String dst)
               throws IOException

Specified by:

rename in class UnderFileSystem

Throws:

IOException

setConf

public void setConf(Object conf)

Description copied from class: UnderFileSystem

To set the configuration object for UnderFileSystem. The conf object is understood by the concrete underfs's implementation.

Specified by:

setConf in class UnderFileSystem

Parameters:

conf - The configuration object accepted by ufs.

setPermission

public void setPermission(String path,
                 String posixPerm)
                   throws IOException

Description copied from class: UnderFileSystem

Change posix file permission

Specified by:

setPermission in class UnderFileSystem

Parameters:

path - path of the file

posixPerm - standard posix permission like "777", "775", etc.

Throws:

IOException