org.apache.lens.lib.query

Class FilePersistentFormatter

java.lang.Object

org.apache.lens.lib.query.AbstractOutputFormatter

org.apache.lens.lib.query.WrappedFileFormatter

org.apache.lens.lib.query.FilePersistentFormatter

All Implemented Interfaces:

Externalizable, Serializable, PersistedOutputFormatter, QueryOutputFormatter

public class FilePersistentFormatter
extends WrappedFileFormatter
implements PersistedOutputFormatter

File formatter for PersistedOutputFormatter

This is a WrappedFileFormatter which can wrap any FileFormatter.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.lens.lib.query.AbstractOutputFormatter

HEADER_TYPE

Constructor Summary

Constructors

Constructor and Description
FilePersistentFormatter()

Method Summary

Modifier and Type	Method and Description
void	addRowsFromPersistedPath(org.apache.hadoop.fs.Path persistedDir) Add result rows from the persisted path.
void	init(QueryContext ctx, LensResultSetMetadata metadata) Initialize the formatter.

Methods inherited from class org.apache.lens.lib.query.WrappedFileFormatter

close, commit, getEncoding, getFileSize, getFinalOutputPath, getNumRows, getTmpPath, readExternal, writeExternal, writeFooter, writeHeader

Methods inherited from class org.apache.lens.lib.query.AbstractOutputFormatter

getMetadata

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.lens.server.api.query.QueryOutputFormatter

close, commit, getFileSize, getFinalOutputPath, getMetadata, getNumRows, writeFooter, writeHeader

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Constructor Detail

FilePersistentFormatter

public FilePersistentFormatter()

Method Detail

init

public void init(QueryContext ctx,
                 LensResultSetMetadata metadata)
          throws IOException

Description copied from interface: QueryOutputFormatter

Initialize the formatter.

Specified by:

init in interface QueryOutputFormatter

Overrides:

init in class WrappedFileFormatter

Parameters:

ctx - The QueryContext object

metadata - LensResultSetMetadata object

Throws:

IOException - Signals that an I/O exception has occurred.

addRowsFromPersistedPath

public void addRowsFromPersistedPath(org.apache.hadoop.fs.Path persistedDir)
                              throws IOException

Description copied from interface: PersistedOutputFormatter

Add result rows from the persisted path.

Specified by:

addRowsFromPersistedPath in interface PersistedOutputFormatter

Parameters:

persistedDir - the persisted path

Throws:

IOException - Signals that an I/O exception has occurred.