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

Class WARCWritable

java.lang.Object

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

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class WARCWritable
extends Object
implements org.apache.hadoop.io.Writable

A mutable wrapper around a WARCRecord implementing the Hadoop Writable interface. This allows WARC records to be used throughout Hadoop (e.g. written to sequence files when shuffling data between mappers and reducers). The record is encoded as a single record in standard WARC/1.0 format.

Field Summary

Fields

Modifier and Type	Field and Description
private WARCRecord	record

Constructor Summary

Constructors

Constructor and Description
WARCWritable() Creates an empty writable (with a null record).
WARCWritable(WARCRecord record) Creates a writable wrapper around a given WARCRecord.

Method Summary

Modifier and Type	Method and Description
WARCRecord	getRecord() Returns the record currently wrapped by this writable.
void	readFields(DataInput in) Parses a WARCRecord out of a DataInput stream, and makes it the writable's current record.
void	setRecord(WARCRecord record) Updates the record held within this writable wrapper.
void	write(DataOutput out) Appends the current record to a DataOutput stream.

Methods inherited from class java.lang.Object

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

Field Detail

record

private WARCRecord record

Constructor Detail

WARCWritable

public WARCWritable()

Creates an empty writable (with a null record).

WARCWritable

public WARCWritable(WARCRecord record)

Creates a writable wrapper around a given WARCRecord.

Method Detail

getRecord

public WARCRecord getRecord()

Returns the record currently wrapped by this writable.

setRecord

public void setRecord(WARCRecord record)

Updates the record held within this writable wrapper.

write

public void write(DataOutput out)
           throws IOException

Appends the current record to a DataOutput stream.

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Parses a WARCRecord out of a DataInput stream, and makes it the writable's current record.

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException