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

java.lang.Object
  extended by org.apache.pig.backend.hadoop.datastorage.HPath
      extended by 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, 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>


Copyright © 2007-2012 The Apache Software Foundation