Package org.apache.cassandra.utils.binlog

Class DeletingArchiver

java.lang.Object
org.apache.cassandra.utils.binlog.DeletingArchiver
All Implemented Interfaces:
net.openhft.chronicle.queue.impl.StoreFileListener, BinLogArchiver
public class DeletingArchiver extends Object implements BinLogArchiver

  • Field Summary

    Fields inherited from interface net.openhft.chronicle.queue.impl.StoreFileListener

    NO_OP

  • Constructor Summary

    Constructors
    Constructor
    Description
    DeletingArchiver(long maxLogSize)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onReleased(int cycle, File file)
    Track store files as they are added and their storage impact.
    void
    stop()
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface net.openhft.chronicle.queue.impl.StoreFileListener

    isActive, onAcquired

  • Constructor Details

    • DeletingArchiver

      public DeletingArchiver(long maxLogSize)

  • Method Details

    • onReleased

      public void onReleased(int cycle, File file)
      Track store files as they are added and their storage impact. Delete them if over storage limit.
      Specified by:
      onReleased in interface BinLogArchiver
      Specified by:
      onReleased in interface net.openhft.chronicle.queue.impl.StoreFileListener
      Parameters:
      cycle -
      file -

    • stop

      public void stop()
      Specified by:
      stop in interface BinLogArchiver