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

Class WALCellCodec.BaosAndCompressor

java.lang.Object

java.io.OutputStream

java.io.ByteArrayOutputStream

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

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, WALCellCodec.ByteStringCompressor

Enclosing class:

WALCellCodec

static class WALCellCodec.BaosAndCompressor
extends ByteArrayOutputStream
implements WALCellCodec.ByteStringCompressor

Field Summary

Fields

Modifier and Type	Field	Description
private CompressionContext	compressionContext

Fields inherited from class java.io.ByteArrayOutputStream

buf, count

Constructor Summary

Constructors

Constructor	Description
BaosAndCompressor(CompressionContext compressionContext)

Method Summary

Modifier and Type	Method	Description
org.apache.hbase.thirdparty.com.google.protobuf.ByteString	compress(byte[] data, Enum dictIndex)
org.apache.hbase.thirdparty.com.google.protobuf.ByteString	toByteString()
private void	writeCompressed(byte[] data, Enum dictIndex)

Methods inherited from class java.io.ByteArrayOutputStream

close, reset, size, toByteArray, toString, toString, toString, write, write, writeTo

Methods inherited from class java.io.OutputStream

flush, write

Methods inherited from class java.lang.Object

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

Field Details

compressionContext

private CompressionContext compressionContext

Constructor Details

BaosAndCompressor

public BaosAndCompressor(CompressionContext compressionContext)

Method Details

toByteString

public org.apache.hbase.thirdparty.com.google.protobuf.ByteString toByteString()

compress

public org.apache.hbase.thirdparty.com.google.protobuf.ByteString compress(byte[] data,
 Enum dictIndex)
                                                                    throws IOException

Specified by:

compress in interface WALCellCodec.ByteStringCompressor

Throws:

IOException

writeCompressed

private void writeCompressed(byte[] data,
 Enum dictIndex)
                      throws IOException

Throws:

IOException