org.apache.pig.backend.datastorage

Interface ElementDescriptor

All Superinterfaces:

java.lang.Comparable<ElementDescriptor>

All Known Subinterfaces:

ContainerDescriptor

All Known Implementing Classes:

HDirectory, HFile, HPath

public interface ElementDescriptor
extends java.lang.Comparable<ElementDescriptor>

DataStorageElementDescriptor provides methods necessary to manage an element in a DataStorage.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BLOCK_REPLICATION_KEY Available from getConfiguration as a String and getStatistics as a Short.
static java.lang.String	BLOCK_SIZE_KEY Available from getConfiguration as a String and getStatistics as a Long.
static java.lang.String	LENGTH_KEY Available from getStatistics as a Long.
static java.lang.String	MODIFICATION_TIME_KEY Available from getStatistics as a Long.

Method Summary

Modifier and Type	Method and Description
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()
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	exists() Checks whether the entity exists or not
java.util.Properties	getConfiguration() Retrieve configuration information for entity
DataStorage	getDataStorage()
java.util.Map<java.lang.String,java.lang.Object>	getStatistics() List entity statistics
java.io.InputStream	open()
java.io.InputStream	open(java.util.Properties configuration) Open for read a given entity
void	rename(ElementDescriptor newName) Changes the name of an entity in the Data Storage
SeekableInputStream	sopen()
SeekableInputStream	sopen(java.util.Properties configuration) Open an element in the Data Storage with support for random access (seek operations).
boolean	systemElement() Defines whether the element is visible to users or contains system's metadata
void	updateConfiguration(java.util.Properties newConfig) Update configuration information for this entity

Methods inherited from interface java.lang.Comparable

compareTo

Field Detail

BLOCK_SIZE_KEY

static final java.lang.String BLOCK_SIZE_KEY

Available from getConfiguration as a String and getStatistics as a Long.

See Also:

Constant Field Values

BLOCK_REPLICATION_KEY

static final java.lang.String BLOCK_REPLICATION_KEY

Available from getConfiguration as a String and getStatistics as a Short.

See Also:

Constant Field Values

LENGTH_KEY

static final java.lang.String LENGTH_KEY

Available from getStatistics as a Long.

See Also:

Constant Field Values

MODIFICATION_TIME_KEY

static final java.lang.String MODIFICATION_TIME_KEY

Available from getStatistics as a Long.

See Also:

Constant Field Values

Method Detail

getDataStorage

DataStorage getDataStorage()

create

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

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

Parameters:

configuration - information at the object level

Returns:

stream where to write

Throws:

DataStorageException

java.io.IOException

create

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

Throws:

java.io.IOException

copy

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

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

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

copy

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

Throws:

java.io.IOException

open

java.io.InputStream open(java.util.Properties configuration)
                  throws java.io.IOException

Open for read a given entity

Parameters:

configuration -

Returns:

entity to read from

Throws:

DataStorageExecption - e.g. entity does not exist...

java.io.IOException

open

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

Throws:

java.io.IOException

sopen

SeekableInputStream sopen(java.util.Properties configuration)
                   throws java.io.IOException

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

Parameters:

configuration -

Returns:

a seekable input stream

Throws:

DataStorageException

java.io.IOException

sopen

SeekableInputStream sopen()
                   throws java.io.IOException

Throws:

java.io.IOException

exists

boolean exists()
        throws java.io.IOException

Checks whether the entity exists or not

Returns:

true if entity exists, false otherwise.

Throws:

java.io.IOException

rename

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

Changes the name of an entity in the Data Storage

Parameters:

newName - new name of entity

Throws:

DataStorageException

java.io.IOException

delete

void delete()
     throws java.io.IOException

Remove entity from the Data Storage.

Throws:

DataStorageException

java.io.IOException

getConfiguration

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

Retrieve configuration information for entity

Returns:

configuration

Throws:

java.io.IOException

updateConfiguration

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

Update configuration information for this entity

Parameters:

newConfig - configuration

Throws:

DataStorageException

java.io.IOException

systemElement

boolean systemElement()

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

Returns:

true if this is system file; false otherwise

getStatistics

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

List entity statistics

Returns:

DataStorageProperties

Throws:

java.io.IOException