Package org.apache.bookkeeper.bookie

Class TransactionalEntryLogCompactor.UpdateIndexPhase

java.lang.Object

org.apache.bookkeeper.bookie.TransactionalEntryLogCompactor.CompactionPhase

org.apache.bookkeeper.bookie.TransactionalEntryLogCompactor.UpdateIndexPhase

Enclosing class:

TransactionalEntryLogCompactor

class TransactionalEntryLogCompactor.UpdateIndexPhase
extends TransactionalEntryLogCompactor.CompactionPhase

Assume we're compacting log 1 to log 3. This phase is to update the entry locations and flush the index. When the phase start, there should be a compacted file like "3.log.1.compacted", where 3 is the new compaction logId and 1 is the old entry logId. After the index the flushed successfully, a hardlink "3.log" file should be created, and 3.log.1.compacted file should be deleted to indicate the phase is succeed.

This phase can also used to recover partially flushed index when we pass isInRecovery=true

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
UpdateIndexPhase(CompactionEntryLog compactionLog)
UpdateIndexPhase(CompactionEntryLog compactionLog, boolean isInRecovery)

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

UpdateIndexPhase

public UpdateIndexPhase(CompactionEntryLog compactionLog)

UpdateIndexPhase

public UpdateIndexPhase(CompactionEntryLog compactionLog,
 boolean isInRecovery)

Method Details

start

void start()
    throws IOException

Specified by:

start in class TransactionalEntryLogCompactor.CompactionPhase

Throws:

IOException

complete

boolean complete()

Specified by:

complete in class TransactionalEntryLogCompactor.CompactionPhase

abort

void abort()

Specified by:

abort in class TransactionalEntryLogCompactor.CompactionPhase