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

LensFileOutputFormat.LensRowWriter(DataOutputStream out)
Instantiates a new lens row writer.

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

Method Summary

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

LensFileOutputFormat.LensRowWriter

public LensFileOutputFormat.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

LensFileOutputFormat.LensRowWriter

public LensFileOutputFormat.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()