org.apache.lens.lib.query

Class LensFileOutputFormat.LensRowWriter

java.lang.Object

org.apache.lens.lib.query.LensFileOutputFormat.LensRowWriter

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>

Enclosing class:

LensFileOutputFormat

public static class LensFileOutputFormat.LensRowWriter
extends Object
implements org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>

The Class LensRowWriter.

Constructor Summary

Constructors

Constructor and Description
LensRowWriter(DataOutputStream out) Instantiates a new lens row writer.
LensRowWriter(DataOutputStream out, String encoding, org.apache.hadoop.fs.Path tmpPath, String extn) Instantiates a new lens row writer.

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapred.Reporter reporter)
String	getEncoding()
String	getExtn()
org.apache.hadoop.fs.Path	getTmpPath()
void	write(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.io.Text value)

Methods inherited from class java.lang.Object

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

Constructor Detail

LensRowWriter

public LensRowWriter(DataOutputStream out,
                     String encoding,
                     org.apache.hadoop.fs.Path tmpPath,
                     String extn)

Instantiates a new lens row writer.

Parameters:

out - the out

encoding - the encoding

tmpPath - the tmp path

extn - the extn

LensRowWriter

public LensRowWriter(DataOutputStream out)

Instantiates a new lens row writer.

Parameters:

out - the out

Method Detail

write

public void write(org.apache.hadoop.io.NullWritable key,
                  org.apache.hadoop.io.Text value)
           throws IOException

Specified by:

write in interface org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>

Throws:

IOException

close

public void close(org.apache.hadoop.mapred.Reporter reporter)
           throws IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>

Throws:

IOException

getTmpPath

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

getExtn

public String getExtn()

getEncoding

public String getEncoding()