Package org.apache.pulsar.common.policies.data

Class TransactionBufferStats

java.lang.Object

org.apache.pulsar.common.policies.data.TransactionBufferStats

public class TransactionBufferStats
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
long	lastSnapshotTimestamps	The last snapshot timestamps of this transaction buffer.
Map<Long,Long>	lowWaterMarks	(Optional) The lowWaterMark details of the transaction buffer.
String	maxReadPosition	The max read position of this transaction buffer.
long	ongoingTxnSize	The total number of ongoing transactions in this transaction buffer.
long	recoverEndTime
long	recoverStartTime
SegmentsStats	segmentsStats
String	snapshotType
String	state	The state of this transaction buffer.
long	totalAbortedTransactions

Constructor Summary

Constructors

Constructor	Description
TransactionBufferStats()

Method Summary

Methods inherited from class java.lang.Object

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

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()