BucketCache.WriterThread (Apache HBase 1.2.12 API)

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- org.apache.hadoop.hbase.util.HasThread
- - org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.WriterThread

All Implemented Interfaces:

Runnable

Enclosing class:

BucketCache
```
 class BucketCache.WriterThread
extends HasThread
```

Field Summary

Fields
Modifier and Type Field and Description

private BlockingQueue<BucketCache.RAMQueueEntry> inputQueue

private boolean writerEnabled

Constructor Summary

Constructors
Constructor and Description

BucketCache.WriterThread(BlockingQueue<BucketCache.RAMQueueEntry> queue)

Method Summary

Methods
Modifier and Type	Method and Description
`(package private) void`	`disableWriter()`
`(package private) void`	`doDrain(List<BucketCache.RAMQueueEntry> entries)` Flush the entries in ramCache to IOEngine and add bucket entry to backingMap.
`void`	`run()`

Methods inherited from class org.apache.hadoop.hbase.util.HasThread
getName, getThread, interrupt, isAlive, isInterrupted, join, join, join, setDaemon, setName, setPriority, setUncaughtExceptionHandler, start

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - inputQueue
```
private final BlockingQueue<BucketCache.RAMQueueEntry> inputQueue
```
  - writerEnabled
```
private volatile boolean writerEnabled
```
- Constructor Detail
  - BucketCache.WriterThread
```
BucketCache.WriterThread(BlockingQueue<BucketCache.RAMQueueEntry> queue)
```
- Method Detail
  - disableWriter
```
void disableWriter()
```
  - run
```
public void run()
```
    Specified by:
    
    run in interface Runnable
    
    Specified by:
    
    run in class HasThread
  - doDrain
```
void doDrain(List<BucketCache.RAMQueueEntry> entries)
       throws InterruptedException
```
    Flush the entries in ramCache to IOEngine and add bucket entry to backingMap. Process all that are passed in even if failure being sure to remove from ramCache else we'll never undo the references and we'll OOME.
    
    Parameters:
    entries - Presumes list passed in here will be processed by this invocation only. No interference expected.
    
    Throws:
    
    InterruptedException

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

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