Package org.apache.hadoop.hbase.regionserver.wal

Class WALCellCodec.CompressedKvEncoder

java.lang.Object

org.apache.hadoop.hbase.codec.BaseEncoder

org.apache.hadoop.hbase.regionserver.wal.WALCellCodec.CompressedKvEncoder

All Implemented Interfaces:

Codec.Encoder, CellOutputStream

Enclosing class:

WALCellCodec

static class WALCellCodec.CompressedKvEncoder
extends BaseEncoder

Field Summary

Fields

Modifier and Type	Field	Description
private final CompressionContext	compression
private final boolean	hasTagCompression
private final boolean	hasValueCompression

Fields inherited from class org.apache.hadoop.hbase.codec.BaseEncoder

flushed, out

Constructor Summary

Constructors

Constructor	Description
CompressedKvEncoder(OutputStream out, CompressionContext compression)

Method Summary

Modifier and Type	Method	Description
void	write(ExtendedCell cell)	Implementation must copy the entire state of the Cell.
private void	writeCompressedValue(OutputStream out, Cell cell)

Methods inherited from class org.apache.hadoop.hbase.codec.BaseEncoder

checkFlushed, flush, getOuputStream

Methods inherited from class java.lang.Object

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

Field Details

compression

private final CompressionContext compression

hasValueCompression

private final boolean hasValueCompression

hasTagCompression

private final boolean hasTagCompression

Constructor Details

CompressedKvEncoder

public CompressedKvEncoder(OutputStream out,
 CompressionContext compression)

Method Details

write

public void write(ExtendedCell cell)
           throws IOException

Description copied from interface: CellOutputStream

Implementation must copy the entire state of the Cell. If the written Cell is modified immediately after the write method returns, the modifications must have absolutely no effect on the copy of the Cell that was added in the write.

Specified by:

write in interface CellOutputStream

Specified by:

write in class BaseEncoder

Parameters:

cell - Cell to write out

Throws:

IOException

writeCompressedValue

private void writeCompressedValue(OutputStream out,
 Cell cell)
                           throws IOException

Throws:

IOException