org.apache.pig.backend.hadoop.datastorage

Class HFile

java.lang.Object

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

org.apache.pig.backend.hadoop.datastorage.HFile

All Implemented Interfaces:

Comparable<ElementDescriptor>, ElementDescriptor

public class HFile
extends HPath

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

Constructors

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

Method Summary

Modifier and Type	Method and Description
OutputStream	create(Properties configuration) Opens a stream onto which an entity can be written to.
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

Constructor Detail

HFile

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

HFile

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

HFile

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

HFile

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

HFile

public HFile(HDataStorage fs,
             String pathString)

HFile

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

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

open

public InputStream open(Properties configuration)
                 throws IOException

Description copied from interface: ElementDescriptor

Open for read a given entity

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).

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