org.apache.hadoop.hbase.replication.regionserver

Class WALEntryStreamTestBase.WALEntryStreamWithRetries

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.WALEntryStreamTestBase.WALEntryStreamWithRetries

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

WALEntryStreamTestBase

protected static class WALEntryStreamTestBase.WALEntryStreamWithRetries
extends Object

Test helper that waits until a non-null entry is available in the stream next or times out. A WALEntryStream provides a streaming access to a queue of log files. Since the stream can be consumed as the file is being written, callers relying on WALEntryStream.next() may need to retry multiple times before an entry appended to the WAL is visible to the stream consumers. One such cause of delay is the close() of writer writing these log files. While the closure is in progress, the stream does not switch to the next log in the queue and next() may return null entries. This utility wraps these retries into a single next call and that makes the test code simpler.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.wal.WAL.Entry	result

Constructor Summary

Constructors

Constructor and Description

WALEntryStreamWithRetries(org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceLogQueue logQueue, org.apache.hadoop.conf.Configuration conf, long startPosition, org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider walFileLengthProvider, org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics, String walGroupId)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.fs.Path	getCurrentPath()
long	getPosition()
boolean	hasNext()
org.apache.hadoop.hbase.wal.WAL.Entry	next()
org.apache.hadoop.hbase.wal.WAL.Entry	peek()
void	reset()

Methods inherited from class java.lang.Object

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

Field Detail

result

private org.apache.hadoop.hbase.wal.WAL.Entry result

Constructor Detail

WALEntryStreamWithRetries

public WALEntryStreamWithRetries(org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceLogQueue logQueue,
                                 org.apache.hadoop.conf.Configuration conf,
                                 long startPosition,
                                 org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider walFileLengthProvider,
                                 org.apache.hadoop.hbase.ServerName serverName,
                                 org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics,
                                 String walGroupId)
                          throws IOException

Throws:

IOException

Method Detail

next

public org.apache.hadoop.hbase.wal.WAL.Entry next()

hasNext

public boolean hasNext()
                throws IOException

Throws:

IOException

peek

public org.apache.hadoop.hbase.wal.WAL.Entry peek()
                                           throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getPosition

public long getPosition()

getCurrentPath

public org.apache.hadoop.fs.Path getCurrentPath()

reset

public void reset()
           throws IOException

Throws:

IOException