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 inherited from class java.io.ByteArrayOutputStream

buf, count

Constructor Summary

Constructors

Constructor and Description
BaosAndCompressor()

Method Summary

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

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

Constructor Detail

BaosAndCompressor

BaosAndCompressor()

Method Detail

toByteString

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

compress

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

Specified by:

compress in interface WALCellCodec.ByteStringCompressor

Throws:

IOException

writeCompressed

private void writeCompressed(byte[] data,
                             Dictionary dict)
                      throws IOException

Throws:

IOException