Class TestBucketWriterThread

java.lang.Object
org.apache.hadoop.hbase.io.hfile.bucket.TestBucketWriterThread

public class TestBucketWriterThread extends Object
  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    private static class 
    A BucketCache that does not start its writer threads.
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private org.apache.hadoop.hbase.io.hfile.bucket.BucketCache
     
    static final HBaseClassTestRule
     
    private org.apache.hadoop.hbase.io.hfile.Cacheable
     
    private org.apache.hadoop.hbase.io.hfile.BlockCacheKey
     
    private BlockingQueue<org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry>
     
    private org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread
     
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    private static void
    doDrainOfOneEntry(org.apache.hadoop.hbase.io.hfile.bucket.BucketCache bc, org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread wt, BlockingQueue<org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.RAMQueueEntry> q)
     
    void
    Set up variables and get BucketCache and WriterThread into state where tests can manually control the running of WriterThread and BucketCache is empty.
    void
     
    void
    Do Cache full exception
    void
    Do IOE.
    void
    Test non-error case just works.
    void
    Pass through a too big entry and ensure it is cleared from queues and ramCache.

    Methods inherited from class java.lang.Object

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