org.apache.hadoop.hbase.test

Class IntegrationTestBigLinkedList.Generator.GeneratorMapper.ContinuousConcurrentWalker

java.lang.Object

org.apache.hadoop.hbase.test.IntegrationTestBigLinkedList.Generator.GeneratorMapper.ContinuousConcurrentWalker

All Implemented Interfaces:

Runnable

Enclosing class:

IntegrationTestBigLinkedList.Generator.GeneratorMapper

public class IntegrationTestBigLinkedList.Generator.GeneratorMapper.ContinuousConcurrentWalker
extends Object
implements Runnable

Randomly selects and walks a random flushed loop concurrently with the Generator Mapper by spawning ConcurrentWalker's with specified StartNodes. These ConcurrentWalker's are configured to only log erroneous nodes.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hadoop.conf.Configuration	conf
(package private) org.apache.hadoop.mapreduce.Mapper.Context	context
(package private) IntegrationTestBigLinkedList.Generator.GeneratorMapper.ConcurrentWalker	walker

Constructor Summary

Constructors

Constructor and Description
ContinuousConcurrentWalker(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.Mapper.Context context)

Method Summary

Modifier and Type	Method and Description
void	run()
private long	selectLoop()
private void	walkLoop(long node)

Methods inherited from class java.lang.Object

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

Field Detail

walker

IntegrationTestBigLinkedList.Generator.GeneratorMapper.ConcurrentWalker walker

conf

org.apache.hadoop.conf.Configuration conf

context

org.apache.hadoop.mapreduce.Mapper.Context context

Constructor Detail

ContinuousConcurrentWalker

public ContinuousConcurrentWalker(org.apache.hadoop.conf.Configuration conf,
                                  org.apache.hadoop.mapreduce.Mapper.Context context)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

walkLoop

private void walkLoop(long node)
               throws IOException

Throws:

IOException

selectLoop

private long selectLoop()
                 throws InterruptedException

Throws:

InterruptedException