Package org.apache.hadoop.hbase.test.util.warc

Class WARCOutputFormat.WARCWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,WARCWritable>

org.apache.hadoop.hbase.test.util.warc.WARCOutputFormat.WARCWriter

Enclosing class:

WARCOutputFormat

private class WARCOutputFormat.WARCWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,WARCWritable>

Field Summary

Fields

Modifier and Type	Field	Description
private final WARCFileWriter	writer

Constructor Summary

Constructors

Constructor	Description
WARCWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)

Method Summary

Modifier and Type	Method	Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
void	write(org.apache.hadoop.io.NullWritable key, WARCWritable value)

Methods inherited from class java.lang.Object

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

Field Details

writer

private final WARCFileWriter writer

Constructor Details

WARCWriter

public WARCWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws IOException

Throws:

IOException

Method Details

write

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

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,WARCWritable>

Throws:

IOException

InterruptedException

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws IOException,
InterruptedException

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,WARCWritable>

Throws:

IOException

InterruptedException