Package org.apache.bookkeeper.bookie

Class EntryMemTableWithParallelFlusher

java.lang.Object

org.apache.bookkeeper.bookie.EntryMemTable

org.apache.bookkeeper.bookie.EntryMemTableWithParallelFlusher

All Implemented Interfaces:

AutoCloseable

class EntryMemTableWithParallelFlusher
extends EntryMemTable

EntryMemTableWithParallelFlusher.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.bookkeeper.bookie.EntryMemTable

EntryMemTable.EntrySkipList

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final OrderedExecutor	flushExecutor

Fields inherited from class org.apache.bookkeeper.bookie.EntryMemTable

allocator, checkpointSource, conf, kvmap, lock, memTableStats, size, skipListSemaphore, skipListSizeLimit, snapshot

Constructor Summary

Constructors

Constructor	Description
EntryMemTableWithParallelFlusher(ServerConfiguration conf, CheckpointSource source, StatsLogger statsLogger)

Method Summary

Modifier and Type	Method	Description
void	close()
(package private) long	flushSnapshot(SkipListFlusher flusher, CheckpointSource.Checkpoint checkpoint)	Functionally this overridden flushSnapshot does the same as EntryMemTable's flushSnapshot, but it uses flushExecutor (OrderedExecutor) to process an entry through flusher.

Methods inherited from class org.apache.bookkeeper.bookie.EntryMemTable

addEntry, clearSnapshot, dump, flush, flush, getEntry, getLastEntry, getListOfEntriesOfLedger, isEmpty, isSizeLimitReached, snapshot, snapshot

Methods inherited from class java.lang.Object

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

Field Details

flushExecutor

final OrderedExecutor flushExecutor

Constructor Details

EntryMemTableWithParallelFlusher

public EntryMemTableWithParallelFlusher(ServerConfiguration conf,
 CheckpointSource source,
 StatsLogger statsLogger)

Method Details

flushSnapshot

long flushSnapshot(SkipListFlusher flusher,
 CheckpointSource.Checkpoint checkpoint)
            throws IOException

Functionally this overridden flushSnapshot does the same as EntryMemTable's flushSnapshot, but it uses flushExecutor (OrderedExecutor) to process an entry through flusher.

SubMaps of the snapshot corresponding to the entries of the ledgers are created and submitted to the flushExecutor with ledgerId as the orderingKey to flush process the entries of a ledger.

Overrides:

flushSnapshot in class EntryMemTable

Throws:

IOException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class EntryMemTable

Throws:

Exception