WALSplitter.EntryBuffers (Apache HBase 1.2.12 API)

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- org.apache.hadoop.hbase.wal.WALSplitter.EntryBuffers

Enclosing class:

WALSplitter
```
public static class WALSplitter.EntryBuffers
extends Object
```
Class which accumulates edits and separates them into a buffer per region while simultaneously accounting RAM usage. Blocks if the RAM usage crosses a predefined threshold. Writer threads then pull region-specific buffers from this class.

Field Summary

Fields
Modifier and Type	Field and Description
`(package private) Map<byte[],WALSplitter.RegionEntryBuffer>`	`buffers`
`(package private) WALSplitter.PipelineController`	`controller`
`(package private) Set<byte[]>`	`currentlyWriting`
`(package private) long`	`maxHeapUsage`
`(package private) long`	`totalBuffered`

Constructor Summary

Constructors
Constructor and Description

WALSplitter.EntryBuffers(WALSplitter.PipelineController controller, long maxHeapUsage)

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`appendEntry(WAL.Entry entry)` Append a log entry into the corresponding region buffer.
`(package private) void`	`doneWriting(WALSplitter.RegionEntryBuffer buffer)`
`(package private) WALSplitter.RegionEntryBuffer`	`getChunkToWrite()`
`(package private) boolean`	`isRegionCurrentlyWriting(byte[] region)`
`void`	`waitUntilDrained()`

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

Field Detail

controller

WALSplitter.PipelineController controller

buffers

Map<byte[],WALSplitter.RegionEntryBuffer> buffers

currentlyWriting
```
Set<byte[]> currentlyWriting
```

totalBuffered
```
long totalBuffered
```

maxHeapUsage
```
long maxHeapUsage
```

Constructor Detail

WALSplitter.EntryBuffers

public WALSplitter.EntryBuffers(WALSplitter.PipelineController controller,
                        long maxHeapUsage)

Method Detail

appendEntry
```
public void appendEntry(WAL.Entry entry)
                 throws InterruptedException,
                        IOException
```
Append a log entry into the corresponding region buffer. Blocks if the total heap usage has crossed the specified threshold.

Throws:

InterruptedException

IOException

getChunkToWrite
```
WALSplitter.RegionEntryBuffer getChunkToWrite()
```
Returns:
RegionEntryBuffer a buffer of edits to be written or replayed.

doneWriting

void doneWriting(WALSplitter.RegionEntryBuffer buffer)

isRegionCurrentlyWriting

boolean isRegionCurrentlyWriting(byte[] region)

waitUntilDrained
```
public void waitUntilDrained()
```

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

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