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 and Description
private WARCFileWriter	writer

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

writer

private final WARCFileWriter writer

Constructor Detail

WARCWriter

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

Throws:

IOException

Method Detail

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