Package 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
    Description
    (package private) org.apache.hadoop.conf.Configuration
    conf
     
    (package private) org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>.org.apache.hadoop.mapreduce.Mapper.Context
    context
     
    (package private) IntegrationTestBigLinkedList.Generator.GeneratorMapper.ConcurrentWalker
    walker
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ContinuousConcurrentWalker(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
     

  • Method Summary

    Modifier and Type
    Method
    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