Class TransactionBufferStats

java.lang.Object
org.apache.pulsar.common.policies.data.TransactionBufferStats

public class TransactionBufferStats extends Object
  • Field Details

    • state

      public String state
      The state of this transaction buffer.
    • maxReadPosition

      public String maxReadPosition
      The max read position of this transaction buffer.
    • lastSnapshotTimestamps

      public long lastSnapshotTimestamps
      The last snapshot timestamps of this transaction buffer.
    • lowWaterMarks

      public Map<Long,Long> lowWaterMarks
      (Optional) The lowWaterMark details of the transaction buffer.
    • ongoingTxnSize

      public long ongoingTxnSize
      The total number of ongoing transactions in this transaction buffer.
    • recoverStartTime

      public long recoverStartTime
    • recoverEndTime

      public long recoverEndTime
    • totalAbortedTransactions

      public long totalAbortedTransactions
    • snapshotType

      public String snapshotType
    • segmentsStats

      public SegmentsStats segmentsStats
  • Constructor Details

    • TransactionBufferStats

      public TransactionBufferStats()