org.apache.hadoop.hbase.regionserver.wal

Class WriterBase

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.WriterBase

All Implemented Interfaces:

HLog.Writer

Direct Known Subclasses:

ProtobufLogWriter

@InterfaceAudience.Private
public abstract class WriterBase
extends Object
implements HLog.Writer

Context used by our wal dictionary compressor. Null if we're not to do our custom dictionary compression.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.hbase.regionserver.wal.CompressionContext	compressionContext
protected org.apache.hadoop.conf.Configuration	conf

Constructor Summary

Constructors

Constructor and Description
WriterBase()

Method Summary

Methods

Modifier and Type	Method and Description
void	init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf, boolean overwritable)
boolean	initializeCompressionContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.regionserver.wal.HLog.Writer

append, close, getLength, setWALTrailer, sync

Field Detail

compressionContext

protected org.apache.hadoop.hbase.regionserver.wal.CompressionContext compressionContext

conf

protected org.apache.hadoop.conf.Configuration conf

Constructor Detail

WriterBase

public WriterBase()

Method Detail

init

public void init(org.apache.hadoop.fs.FileSystem fs,
        org.apache.hadoop.fs.Path path,
        org.apache.hadoop.conf.Configuration conf,
        boolean overwritable)
          throws IOException

Specified by:

init in interface HLog.Writer

Throws:

IOException

initializeCompressionContext

public boolean initializeCompressionContext(org.apache.hadoop.conf.Configuration conf,
                                   org.apache.hadoop.fs.Path path)
                                     throws IOException

Throws:

IOException