Package org.apache.cassandra.db.commitlog

Interface CommitLogMBean

All Known Implementing Classes:
CommitLog
public interface CommitLogMBean

  • Method Details

    • getArchiveCommand

      String getArchiveCommand()
      Command to execute to archive a commitlog segment. Blank to disabled.

    • getRestoreCommand

      String getRestoreCommand()
      Command to execute to make an archived commitlog live again

    • getRestoreDirectories

      String getRestoreDirectories()
      Directory to scan the recovery files in

    • getRestorePointInTime

      long getRestorePointInTime()
      Restore mutations created up to and including this timestamp in GMT There are only three different formats to express three time precisions: Seconds, Milliseconds, and Microseconds. Seconds format: yyyy:MM:dd HH:mm:ss (2012:04:31 20:43:12) Milliseconds format: yyyy:MM:dd HH:mm:ss.SSS (2012:04:31 20:43:12.633) Microseconds format: yyyy:MM:dd HH:mm:ss.SSSSSS (2012:04:31 20:43:12.633222) Recovery will continue through the segment when the first client-supplied timestamp greater than this time is encountered, but only mutations less than or equal to this timestamp will be applied.

    • getRestorePrecision

      String getRestorePrecision()
      get precision of the timestamp used in the restore (MILLISECONDS, MICROSECONDS, ...) to determine if passed the restore point in time.

    • recover

      void recover(String path) throws IOException
      Recover a single file.
      Throws:
      IOException

    • getActiveSegmentNames

      List<String> getActiveSegmentNames()
      Returns:
      file names (not full paths) of active commit log segments (segments containing unflushed data)

    • getArchivingSegmentNames

      List<String> getArchivingSegmentNames()
      Returns:
      Files which are pending for archival attempt. Does NOT include failed archive attempts.

    • getActiveContentSize

      long getActiveContentSize()
      Returns:
      The size of the mutations in all active commit log segments (uncompressed).

    • getActiveOnDiskSize

      long getActiveOnDiskSize()
      Returns:
      The space taken on disk by the commit log (compressed).

    • getActiveSegmentCompressionRatios

      Map<String,Double> getActiveSegmentCompressionRatios()
      Returns:
      A map between active log segments and the compression ratio achieved for each.

    • getCDCBlockWrites

      boolean getCDCBlockWrites()

    • setCDCBlockWrites

      void setCDCBlockWrites(boolean val)

    • isCDCOnRepairEnabled

      boolean isCDCOnRepairEnabled()
      Returns true if internodes streaming of CDC data should go through write path

    • setCDCOnRepairEnabled

      void setCDCOnRepairEnabled(boolean value)
      Set whether enable write path for CDC data during internodes streaming, e.g. repair