ProtobufLogWriter (Apache HBase 1.4.11 API)

java.lang.Object
- org.apache.hadoop.hbase.regionserver.wal.WriterBase
- - org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter

All Implemented Interfaces:

Closeable, AutoCloseable, DefaultWALProvider.Writer, WALProvider.Writer

Direct Known Subclasses:

SecureProtobufLogWriter
```
@InterfaceAudience.LimitedPrivate(value="Configuration")
public class ProtobufLogWriter
extends WriterBase
```
Writer for protobuf-based WAL.

Field Summary

Fields
Modifier and Type	Field and Description
`protected Codec.Encoder`	`cellEncoder`
`protected WALCellCodec.ByteStringCompressor`	`compressor`
`protected org.apache.hadoop.fs.FSDataOutputStream`	`output`

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.WriterBase
compressionContext, conf

Constructor Summary

Constructors
Constructor and Description

ProtobufLogWriter()

Constructors
Constructor and Description
`ProtobufLogWriter()`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`append(WAL.Entry entry)`
`protected org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALHeader`	`buildWALHeader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALHeader.Builder builder)`
`void`	`close()`
`protected WALCellCodec`	`getCodec(org.apache.hadoop.conf.Configuration conf, CompressionContext compressionContext)`
`long`	`getLength()`
`org.apache.hadoop.fs.FSDataOutputStream`	`getStream()`
`void`	`init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf, boolean overwritable)`
`protected void`	`initAfterHeader(boolean doCompress)`
`void`	`sync()`

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.WriterBase
initializeCompressionContext

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

output

protected org.apache.hadoop.fs.FSDataOutputStream output

cellEncoder
```
protected Codec.Encoder cellEncoder
```

compressor

protected WALCellCodec.ByteStringCompressor compressor

Constructor Detail
- ProtobufLogWriter
```
public ProtobufLogWriter()
```

Method Detail

getCodec

protected WALCellCodec getCodec(org.apache.hadoop.conf.Configuration conf,
                    CompressionContext compressionContext)
                         throws IOException

Throws:: IOException

buildWALHeader

protected org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALHeader buildWALHeader(org.apache.hadoop.conf.Configuration conf,
                                                                            org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALHeader.Builder builder)
                                                                                 throws IOException

Throws:: IOException

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 DefaultWALProvider.Writer
Overrides:: init in class WriterBase
Throws:: IOException

initAfterHeader

protected void initAfterHeader(boolean doCompress)
                        throws IOException

Throws:: IOException

append

public void append(WAL.Entry entry)
            throws IOException

Throws:: IOException

close

public void close()
           throws IOException

Throws:: IOException

sync

public void sync()
          throws IOException

Throws:: IOException

getLength

public long getLength()
               throws IOException

Throws:: IOException

getStream

public org.apache.hadoop.fs.FSDataOutputStream getStream()

Class ProtobufLogWriter

Field Summary

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.WriterBase

Constructor Summary

Method Summary

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.WriterBase

Methods inherited from class java.lang.Object

Field Detail

output

cellEncoder

compressor

Constructor Detail

ProtobufLogWriter

Method Detail

getCodec

buildWALHeader

init

initAfterHeader

append

close

sync

getLength

getStream