Package org.apache.bookkeeper.bookie

Class TransactionalEntryLogCompactor.FlushCompactionLogPhase

java.lang.Object

org.apache.bookkeeper.bookie.TransactionalEntryLogCompactor.CompactionPhase

org.apache.bookkeeper.bookie.TransactionalEntryLogCompactor.FlushCompactionLogPhase

Enclosing class:

TransactionalEntryLogCompactor

class TransactionalEntryLogCompactor.FlushCompactionLogPhase
extends TransactionalEntryLogCompactor.CompactionPhase

Assume we're compacting log 1 to log 3. This phase is to flush the compaction log. When this phase starts, there should be a compaction log file like "3.log.compacting" When compaction log is flushed, in order to indicate this phase is completed, a hardlink file "3.log.1.compacted" should be created, and "3.log.compacting" should be deleted.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final CompactionEntryLog	compactionLog

Constructor Summary

Constructors

Constructor	Description
FlushCompactionLogPhase(CompactionEntryLog compactionLog)

Method Summary

Modifier and Type	Method	Description
(package private) void	abort()
(package private) boolean	complete()
(package private) void	start()

Methods inherited from class org.apache.bookkeeper.bookie.TransactionalEntryLogCompactor.CompactionPhase

run

Methods inherited from class java.lang.Object

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

Field Details

compactionLog

final CompactionEntryLog compactionLog

Constructor Details

FlushCompactionLogPhase

FlushCompactionLogPhase(CompactionEntryLog compactionLog)

Method Details

start

void start()
    throws IOException

Specified by:

start in class TransactionalEntryLogCompactor.CompactionPhase

Throws:

IOException

complete

boolean complete()
          throws IOException

Specified by:

complete in class TransactionalEntryLogCompactor.CompactionPhase

Throws:

IOException

abort

void abort()

Specified by:

abort in class TransactionalEntryLogCompactor.CompactionPhase