Package org.apache.bookkeeper.bookie.storage

Interface EntryLogScanner

public interface EntryLogScanner
Scan entries in a entry log file.

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    accept(long ledgerId)
    Tests whether or not the entries belongs to the specified ledger should be processed.
    void
    process(long ledgerId, long offset, io.netty.buffer.ByteBuf entry)
    Process an entry.

  • Method Details

    • accept

      boolean accept(long ledgerId)
      Tests whether or not the entries belongs to the specified ledger should be processed.
      Parameters:
      ledgerId - Ledger ID.
      Returns:
      true if and only the entries of the ledger should be scanned.

    • process

      void process(long ledgerId, long offset, io.netty.buffer.ByteBuf entry) throws IOException
      Process an entry.
      Parameters:
      ledgerId - Ledger ID.
      offset - File offset of this entry.
      entry - Entry ByteBuf
      Throws:
      IOException