org.apache.pig.backend.hadoop.datastorage
Class HDirectory

java.lang.Object
  org.apache.pig.backend.hadoop.datastorage.HPath
      org.apache.pig.backend.hadoop.datastorage.HDirectory

All Implemented Interfaces:

Comparable<ElementDescriptor>, Iterable<ElementDescriptor>, ContainerDescriptor, ElementDescriptor

public class HDirectory
extends HPath
implements ContainerDescriptor

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.datastorage.HPath

fs, path

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

BLOCK_REPLICATION_KEY, BLOCK_SIZE_KEY, LENGTH_KEY, MODIFICATION_TIME_KEY

Constructor Summary

HDirectory(HDataStorage fs, org.apache.hadoop.fs.Path path)

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

HDirectory(HDataStorage fs, org.apache.hadoop.fs.Path parent, String child)

HDirectory(HDataStorage fs, String pathString)

HDirectory(HDataStorage fs, String parent, org.apache.hadoop.fs.Path child)

HDirectory(HDataStorage fs, String parent, String child)

Method Summary

void	copy(ContainerDescriptor dstName, Properties dstConfiguration, boolean removeSrc)
OutputStream	create(Properties configuration) Opens a stream onto which an entity can be written to.
Iterator<ElementDescriptor>	iterator()
InputStream	open()
InputStream	open(Properties configuration) Open for read a given entity
SeekableInputStream	sopen()
SeekableInputStream	sopen(Properties configuration) Open an element in the Data Storage with support for random access (seek operations).

Methods inherited from class org.apache.pig.backend.hadoop.datastorage.HPath

compareTo, copy, copy, create, delete, equals, exists, getConfiguration, getDataStorage, getHFS, getPath, getStatistics, hashCode, rename, setPermission, systemElement, toString, updateConfiguration

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

copy, copy, create, delete, exists, getConfiguration, getDataStorage, getStatistics, rename, systemElement, updateConfiguration

Methods inherited from interface java.lang.Comparable

compareTo

Constructor Detail

HDirectory

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

HDirectory

public HDirectory(HDataStorage fs,
                  String parent,
                  String child)

HDirectory

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

HDirectory

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

HDirectory

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

HDirectory

public HDirectory(HDataStorage fs,
                  String pathString)

Method Detail

create

public OutputStream create(Properties configuration)
                    throws IOException

Description copied from interface: ElementDescriptor

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

Specified by:

create in interface ElementDescriptor

Specified by:

create in class HPath

Parameters:

configuration - information at the object level

Returns:

stream where to write

Throws:

DataStorageException

IOException

copy

public void copy(ContainerDescriptor dstName,
                 Properties dstConfiguration,
                 boolean removeSrc)
          throws IOException

Throws:

IOException

open

public InputStream open(Properties configuration)
                 throws IOException

Description copied from interface: ElementDescriptor

Open for read a given entity

Specified by:

open in interface ElementDescriptor

Returns:

entity to read from

Throws:

IOException

open

public InputStream open()
                 throws IOException

Specified by:

open in interface ElementDescriptor

Specified by:

open in class HPath

Throws:

IOException

sopen

public SeekableInputStream sopen(Properties configuration)
                          throws IOException

Description copied from interface: ElementDescriptor

Open an element in the Data Storage with support for random access (seek operations).

Specified by:

sopen in interface ElementDescriptor

Returns:

a seekable input stream

Throws:

DataStorageException

IOException

sopen

public SeekableInputStream sopen()
                          throws IOException

Specified by:

sopen in interface ElementDescriptor

Specified by:

sopen in class HPath

Throws:

IOException

iterator

public Iterator<ElementDescriptor> iterator()

Specified by:

iterator in interface Iterable<ElementDescriptor>