ReplicationWALReaderManager (Apache HBase 1.2.12 API)

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- org.apache.hadoop.hbase.replication.regionserver.ReplicationWALReaderManager

```
@InterfaceAudience.Private
public class ReplicationWALReaderManager
extends Object
```
Wrapper class around WAL to help manage the implementation details such as compression.

Field Summary

Fields
Modifier and Type	Field and Description
`private org.apache.hadoop.conf.Configuration`	`conf`
`private org.apache.hadoop.fs.FileSystem`	`fs`
`private org.apache.hadoop.fs.Path`	`lastPath`
`private static org.apache.commons.logging.Log`	`LOG`
`private long`	`position`
`private WAL.Reader`	`reader`

Constructor Summary

Constructors
Constructor and Description
`ReplicationWALReaderManager(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf)` Creates the helper but doesn't open any file Use setInitialPosition after using the constructor if some content needs to be skipped

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`closeReader()` Close the current reader
`long`	`currentTrailerSize()`
`(package private) void`	`finishCurrentFile()` Tell the helper to reset internal state
`long`	`getPosition()` Get the position that we stopped reading at
`WAL.Reader`	`openReader(org.apache.hadoop.fs.Path path)` Opens the file at the current position
`WAL.Entry`	`readNextAndSetPosition()` Get the next entry, returned and also added in the array
`void`	`seek()` Advance the reader to the current position
`void`	`setPosition(long pos)`

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

fs

private final org.apache.hadoop.fs.FileSystem fs

conf

private final org.apache.hadoop.conf.Configuration conf

position
```
private long position
```

reader
```
private WAL.Reader reader
```

lastPath

private org.apache.hadoop.fs.Path lastPath

Constructor Detail
- ReplicationWALReaderManager
```
public ReplicationWALReaderManager(org.apache.hadoop.fs.FileSystem fs,
                           org.apache.hadoop.conf.Configuration conf)
```
  Creates the helper but doesn't open any file Use setInitialPosition after using the constructor if some content needs to be skipped
  
  Parameters:
  fs -
  conf -

Method Detail
- openReader
```
public WAL.Reader openReader(org.apache.hadoop.fs.Path path)
                      throws IOException
```
  Opens the file at the current position
  
  Parameters:
  path -
  
  Returns:
  an WAL reader.
  
  Throws:
  
  IOException
- readNextAndSetPosition
```
public WAL.Entry readNextAndSetPosition()
                                 throws IOException
```
  Get the next entry, returned and also added in the array
  
  Returns:
  a new entry or null
  
  Throws:
  
  IOException
- seek
```
public void seek()
          throws IOException
```
  Advance the reader to the current position
  
  Throws:
  
  IOException
- getPosition
```
public long getPosition()
```
  Get the position that we stopped reading at
  
  Returns:
  current position, cannot be negative
- setPosition
```
public void setPosition(long pos)
```
- currentTrailerSize
```
public long currentTrailerSize()
```
- closeReader
```
public void closeReader()
                 throws IOException
```
  Close the current reader
  
  Throws:
  
  IOException
- finishCurrentFile
```
void finishCurrentFile()
```
  Tell the helper to reset internal state

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.