org.apache.lens.lib.query

Class WrappedFileFormatter

java.lang.Object

org.apache.lens.lib.query.AbstractOutputFormatter

org.apache.lens.lib.query.WrappedFileFormatter

All Implemented Interfaces:

Externalizable, Serializable, QueryOutputFormatter

Direct Known Subclasses:

FilePersistentFormatter, FileSerdeFormatter

public abstract class WrappedFileFormatter
extends AbstractOutputFormatter

Wraps the formatter FileFormatter, which can have implementations like HadoopFileFormatter or ZipFileFormatter.

See Also:

Serialized Form

Field Summary

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

HEADER_TYPE

Constructor Summary

Constructors

Constructor and Description
WrappedFileFormatter()

Method Summary

Modifier and Type	Method and Description
void	close() Close the formatter.
void	commit() Commit the formatting.
String	getEncoding()
Long	getFileSize() Get size of the resultset file.
String	getFinalOutputPath() Get final location where formatted output is available
Integer	getNumRows() Get total number of rows in result.
org.apache.hadoop.fs.Path	getTmpPath()
void	init(QueryContext ctx, LensResultSetMetadata metadata) Initialize the formatter.
void	readExternal(ObjectInput in)
void	writeExternal(ObjectOutput out)
void	writeFooter() Write the footer.
void	writeHeader() Write the header.

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

Constructor Detail

WrappedFileFormatter

public WrappedFileFormatter()

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 AbstractOutputFormatter

Parameters:

ctx - The QueryContext object

metadata - LensResultSetMetadata object

Throws:

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

writeHeader

public void writeHeader()
                 throws IOException

Description copied from interface: QueryOutputFormatter

Write the header.

Throws:

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

writeFooter

public void writeFooter()
                 throws IOException

Description copied from interface: QueryOutputFormatter

Write the footer.

Throws:

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

getNumRows

public Integer getNumRows()

Description copied from interface: QueryOutputFormatter

Get total number of rows in result.

Returns:

Total number of rows, return null, if not known

getFileSize

public Long getFileSize()

Description copied from interface: QueryOutputFormatter

Get size of the resultset file.

Returns:

Total number of rows, return null, if not known

commit

public void commit()
            throws IOException

Description copied from interface: QueryOutputFormatter

Commit the formatting.

This will make the result consumable by user, will be called after all the writes succeed.

Throws:

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

close

public void close()
           throws IOException

Description copied from interface: QueryOutputFormatter

Close the formatter. Cleanup any resources.

Throws:

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

getFinalOutputPath

public String getFinalOutputPath()

Description copied from interface: QueryOutputFormatter

Get final location where formatted output is available

Returns:

getTmpPath

public org.apache.hadoop.fs.Path getTmpPath()

getEncoding

public String getEncoding()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException