org.apache.pig.backend.hadoop.datastorage

Class HPath

java.lang.Object

org.apache.pig.backend.hadoop.datastorage.HPath

All Implemented Interfaces:

java.lang.Comparable<ElementDescriptor>, ElementDescriptor

Direct Known Subclasses:

HDirectory, HFile

public abstract class HPath
extends java.lang.Object
implements ElementDescriptor

Field Summary

Fields

Modifier and Type	Field and Description
protected HDataStorage	fs
protected org.apache.hadoop.fs.Path	path

Fields inherited from interface org.apache.pig.backend.datastorage.ElementDescriptor

BLOCK_REPLICATION_KEY, BLOCK_SIZE_KEY, LENGTH_KEY, MODIFICATION_TIME_KEY

Constructor Summary

Constructors

Constructor and Description
HPath(HDataStorage fs, org.apache.hadoop.fs.Path path)
HPath(HDataStorage fs, org.apache.hadoop.fs.Path parent, org.apache.hadoop.fs.Path child)
HPath(HDataStorage fs, org.apache.hadoop.fs.Path parent, java.lang.String child)
HPath(HDataStorage fs, java.lang.String pathString)
HPath(HDataStorage fs, java.lang.String parent, org.apache.hadoop.fs.Path child)
HPath(HDataStorage fs, java.lang.String parent, java.lang.String child)

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(ElementDescriptor other)
void	copy(ElementDescriptor dstName, boolean removeSrc)
void	copy(ElementDescriptor dstName, java.util.Properties dstConfiguration, boolean removeSrc) Copy entity from an existing one, possibly residing in a different Data Storage.
java.io.OutputStream	create()
abstract java.io.OutputStream	create(java.util.Properties configuration) Opens a stream onto which an entity can be written to.
void	delete() Remove entity from the Data Storage.
boolean	equals(java.lang.Object obj)
boolean	exists() Checks whether the entity exists or not
java.util.Properties	getConfiguration() Retrieve configuration information for entity
DataStorage	getDataStorage()
org.apache.hadoop.fs.FileSystem	getHFS()
org.apache.hadoop.fs.Path	getPath()
java.util.Map<java.lang.String,java.lang.Object>	getStatistics() List entity statistics
int	hashCode()
abstract java.io.InputStream	open()
void	rename(ElementDescriptor newName) Changes the name of an entity in the Data Storage
void	setPermission(org.apache.hadoop.fs.permission.FsPermission permission)
abstract SeekableInputStream	sopen()
boolean	systemElement() Defines whether the element is visible to users or contains system's metadata
java.lang.String	toString()
void	updateConfiguration(java.util.Properties newConfig) Update configuration information for this entity

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.pig.backend.datastorage.ElementDescriptor

open, sopen

Field Detail

path

protected org.apache.hadoop.fs.Path path

fs

protected HDataStorage fs

Constructor Detail

HPath

public HPath(HDataStorage fs,
     org.apache.hadoop.fs.Path parent,
     org.apache.hadoop.fs.Path child)

HPath

public HPath(HDataStorage fs,
     java.lang.String parent,
     java.lang.String child)

HPath

public HPath(HDataStorage fs,
     org.apache.hadoop.fs.Path parent,
     java.lang.String child)

HPath

public HPath(HDataStorage fs,
     java.lang.String parent,
     org.apache.hadoop.fs.Path child)

HPath

public HPath(HDataStorage fs,
     java.lang.String pathString)

HPath

public HPath(HDataStorage fs,
     org.apache.hadoop.fs.Path path)

Method Detail

getDataStorage

public DataStorage getDataStorage()

Specified by:

getDataStorage in interface ElementDescriptor

create

public abstract java.io.OutputStream create(java.util.Properties configuration)
                                     throws java.io.IOException

Description copied from interface: ElementDescriptor

Opens a stream onto which an entity can be written to.

Specified by:

create in interface ElementDescriptor

Parameters:

configuration - information at the object level

Returns:

stream where to write

Throws:

DataStorageException

java.io.IOException

copy

public void copy(ElementDescriptor dstName,
        java.util.Properties dstConfiguration,
        boolean removeSrc)
          throws java.io.IOException

Description copied from interface: ElementDescriptor

Copy entity from an existing one, possibly residing in a different Data Storage.

Specified by:

copy in interface ElementDescriptor

Parameters:

dstName - name of entity to create

dstConfiguration - configuration for the new entity

removeSrc - if src entity needs to be removed after copying it

Throws:

DataStorageException - for instance, configuration information for new entity is not compatible with configuration information at the Data Storage level, user does not have privileges to read from source entity or write to destination storage...

java.io.IOException

open

public abstract java.io.InputStream open()
                                  throws java.io.IOException

Specified by:

open in interface ElementDescriptor

Throws:

java.io.IOException

sopen

public abstract SeekableInputStream sopen()
                                   throws java.io.IOException

Specified by:

sopen in interface ElementDescriptor

Throws:

java.io.IOException

exists

public boolean exists()
               throws java.io.IOException

Description copied from interface: ElementDescriptor

Checks whether the entity exists or not

Specified by:

exists in interface ElementDescriptor

Returns:

true if entity exists, false otherwise.

Throws:

java.io.IOException

rename

public void rename(ElementDescriptor newName)
            throws java.io.IOException

Description copied from interface: ElementDescriptor

Changes the name of an entity in the Data Storage

Specified by:

rename in interface ElementDescriptor

Parameters:

newName - new name of entity

Throws:

DataStorageException

java.io.IOException

delete

public void delete()
            throws java.io.IOException

Description copied from interface: ElementDescriptor

Remove entity from the Data Storage.

Specified by:

delete in interface ElementDescriptor

Throws:

DataStorageException

java.io.IOException

setPermission

public void setPermission(org.apache.hadoop.fs.permission.FsPermission permission)
                   throws java.io.IOException

Throws:

java.io.IOException

getConfiguration

public java.util.Properties getConfiguration()
                                      throws java.io.IOException

Description copied from interface: ElementDescriptor

Retrieve configuration information for entity

Specified by:

getConfiguration in interface ElementDescriptor

Returns:

configuration

Throws:

java.io.IOException

updateConfiguration

public void updateConfiguration(java.util.Properties newConfig)
                         throws java.io.IOException

Description copied from interface: ElementDescriptor

Update configuration information for this entity

Specified by:

updateConfiguration in interface ElementDescriptor

Parameters:

newConfig - configuration

Throws:

DataStorageException

java.io.IOException

getStatistics

public java.util.Map<java.lang.String,java.lang.Object> getStatistics()
                                                               throws java.io.IOException

Description copied from interface: ElementDescriptor

List entity statistics

Specified by:

getStatistics in interface ElementDescriptor

Returns:

DataStorageProperties

Throws:

java.io.IOException

create

public java.io.OutputStream create()
                            throws java.io.IOException

Specified by:

create in interface ElementDescriptor

Throws:

java.io.IOException

copy

public void copy(ElementDescriptor dstName,
        boolean removeSrc)
          throws java.io.IOException

Specified by:

copy in interface ElementDescriptor

Throws:

java.io.IOException

getPath

public org.apache.hadoop.fs.Path getPath()

getHFS

public org.apache.hadoop.fs.FileSystem getHFS()

systemElement

public boolean systemElement()

Description copied from interface: ElementDescriptor

Defines whether the element is visible to users or contains system's metadata

Specified by:

systemElement in interface ElementDescriptor

Returns:

true if this is system file; false otherwise

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

compareTo

public int compareTo(ElementDescriptor other)

Specified by:

compareTo in interface java.lang.Comparable<ElementDescriptor>

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object