ProtobufLogWriter (Apache HBase 1.2.12 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`
`private static org.apache.commons.logging.Log`	`LOG`
`protected org.apache.hadoop.fs.FSDataOutputStream`	`output`
`private org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALTrailer`	`trailer`
`private int`	`trailerWarnSize`
`private boolean`	`trailerWritten`

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)`
`(package private) org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALTrailer`	`buildWALTrailer(org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALTrailer.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)`
`(package private) void`	`setWALTrailer(org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALTrailer walTrailer)`
`void`	`sync()`
`private void`	`writeWALTrailer()`

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

LOG

private static final org.apache.commons.logging.Log LOG

output

protected org.apache.hadoop.fs.FSDataOutputStream output

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

compressor

protected WALCellCodec.ByteStringCompressor compressor

trailerWritten
```
private boolean trailerWritten
```

trailer

private org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALTrailer trailer

trailerWarnSize
```
private int trailerWarnSize
```

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

buildWALTrailer

org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALTrailer buildWALTrailer(org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALTrailer.Builder builder)

writeWALTrailer
```
private void writeWALTrailer()
```

sync

public void sync()
          throws IOException

Throws:: IOException

getLength

public long getLength()
               throws IOException

Throws:: IOException

getStream

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

setWALTrailer

void setWALTrailer(org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALTrailer walTrailer)

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

LOG

output

cellEncoder

compressor

trailerWritten

trailer

trailerWarnSize

Constructor Detail

ProtobufLogWriter

Method Detail

getCodec

buildWALHeader

init

initAfterHeader

append

close

buildWALTrailer

writeWALTrailer

sync

getLength

getStream

setWALTrailer