Package io.debezium.pipeline.meters

Class SnapshotMeter

java.lang.Object

io.debezium.pipeline.meters.SnapshotMeter

All Implemented Interfaces:

SchemaMetricsMXBean, SnapshotMetricsMXBean

@ThreadSafe
public class SnapshotMeter
extends Object
implements SnapshotMetricsMXBean

Carries snapshot metrics.

Field Summary

Fields

Modifier and Type	Field	Description
private final Set<String>	capturedTables
private final AtomicReference<Object[]>	chunkFrom
private final AtomicReference<String>	chunkId
private final AtomicReference<Object[]>	chunkTo
private final io.debezium.util.Clock	clock
private static final org.slf4j.Logger	LOGGER
private final AtomicLong	pauseDuration
private final ConcurrentMap<String,String>	remainingTables
private final ConcurrentMap<String,Long>	rowsScanned
private final AtomicBoolean	snapshotAborted
private final AtomicBoolean	snapshotCompleted
private final AtomicBoolean	snapshotPaused
private final AtomicBoolean	snapshotRunning
private final AtomicBoolean	snapshotSkipped
private final AtomicLong	startPauseTime
private final AtomicLong	startTime
private final AtomicLong	stopPauseTime
private final AtomicLong	stopTime
private final ConcurrentMap<String,Long>	tableChunksCompleted
private final ConcurrentMap<String,Long>	tableChunksTotal
private final AtomicReference<Object[]>	tableFrom
private final AtomicReference<Object[]>	tableTo

Constructor Summary

Constructors

Constructor	Description
SnapshotMeter(io.debezium.util.Clock clock)

Method Summary

Modifier and Type	Method	Description
private String	arrayToString(Object[] array)
void	chunkProgress(TableId tableId, long totalChunks, long completedChunks)
void	currentChunk(String chunkId, Object[] chunkFrom, Object[] chunkTo)
void	currentChunk(String chunkId, Object[] chunkFrom, Object[] chunkTo, Object[] tableTo)
void	dataCollectionSnapshotCompleted(io.debezium.spi.schema.DataCollectionId dataCollectionId, long numRows)
String[]	getCapturedTables()
String	getChunkFrom()
String	getChunkId()
String	getChunkTo()
int	getRemainingTableCount()
ConcurrentMap<String,Long>	getRowsScanned()
boolean	getSnapshotAborted()
boolean	getSnapshotCompleted()
long	getSnapshotDurationInSeconds()
boolean	getSnapshotPaused()
long	getSnapshotPausedDurationInSeconds()
boolean	getSnapshotRunning()
boolean	getSnapshotSkipped()
Map<String,Long>	getTableChunkCounts()
Map<String,Long>	getTableChunksCompletedCounts()
String	getTableFrom()
String	getTableTo()
int	getTotalTableCount()
void	monitoredDataCollectionsDetermined(Iterable<? extends io.debezium.spi.schema.DataCollectionId> dataCollectionIds)
void	reset()
void	rowsScanned(TableId tableId, long numRows)
void	snapshotAborted()
void	snapshotCompleted()
void	snapshotPaused()
void	snapshotResumed()
void	snapshotSkipped()
void	snapshotStarted()

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

snapshotRunning

private final AtomicBoolean snapshotRunning

snapshotPaused

private final AtomicBoolean snapshotPaused

snapshotCompleted

private final AtomicBoolean snapshotCompleted

snapshotAborted

private final AtomicBoolean snapshotAborted

snapshotSkipped

private final AtomicBoolean snapshotSkipped

startTime

private final AtomicLong startTime

stopTime

private final AtomicLong stopTime

startPauseTime

private final AtomicLong startPauseTime

stopPauseTime

private final AtomicLong stopPauseTime

pauseDuration

private final AtomicLong pauseDuration

rowsScanned

private final ConcurrentMap<String,Long> rowsScanned

remainingTables

private final ConcurrentMap<String,String> remainingTables

chunkId

private final AtomicReference<String> chunkId

chunkFrom

private final AtomicReference<Object[]> chunkFrom

chunkTo

private final AtomicReference<Object[]> chunkTo

tableFrom

private final AtomicReference<Object[]> tableFrom

tableTo

private final AtomicReference<Object[]> tableTo

capturedTables

private final Set<String> capturedTables

tableChunksTotal

private final ConcurrentMap<String,Long> tableChunksTotal

tableChunksCompleted

private final ConcurrentMap<String,Long> tableChunksCompleted

clock

private final io.debezium.util.Clock clock

Constructor Details

SnapshotMeter

public SnapshotMeter(io.debezium.util.Clock clock)

Method Details

getTotalTableCount

public int getTotalTableCount()

Specified by:

getTotalTableCount in interface SnapshotMetricsMXBean

getRemainingTableCount

public int getRemainingTableCount()

Specified by:

getRemainingTableCount in interface SnapshotMetricsMXBean

getSnapshotRunning

public boolean getSnapshotRunning()

Specified by:

getSnapshotRunning in interface SnapshotMetricsMXBean

getSnapshotPaused

public boolean getSnapshotPaused()

Specified by:

getSnapshotPaused in interface SnapshotMetricsMXBean

getSnapshotCompleted

public boolean getSnapshotCompleted()

Specified by:

getSnapshotCompleted in interface SnapshotMetricsMXBean

getSnapshotAborted

public boolean getSnapshotAborted()

Specified by:

getSnapshotAborted in interface SnapshotMetricsMXBean

getSnapshotSkipped

public boolean getSnapshotSkipped()

Specified by:

getSnapshotSkipped in interface SnapshotMetricsMXBean

getSnapshotDurationInSeconds

public long getSnapshotDurationInSeconds()

Specified by:

getSnapshotDurationInSeconds in interface SnapshotMetricsMXBean

getSnapshotPausedDurationInSeconds

public long getSnapshotPausedDurationInSeconds()

Specified by:

getSnapshotPausedDurationInSeconds in interface SnapshotMetricsMXBean

getCapturedTables

public String[] getCapturedTables()

Specified by:

getCapturedTables in interface SchemaMetricsMXBean

monitoredDataCollectionsDetermined

public void monitoredDataCollectionsDetermined(Iterable<? extends io.debezium.spi.schema.DataCollectionId> dataCollectionIds)

dataCollectionSnapshotCompleted

public void dataCollectionSnapshotCompleted(io.debezium.spi.schema.DataCollectionId dataCollectionId,
 long numRows)

snapshotStarted

public void snapshotStarted()

snapshotPaused

public void snapshotPaused()

snapshotResumed

public void snapshotResumed()

snapshotCompleted

public void snapshotCompleted()

snapshotAborted

public void snapshotAborted()

snapshotSkipped

public void snapshotSkipped()

rowsScanned

public void rowsScanned(TableId tableId,
 long numRows)

getRowsScanned

public ConcurrentMap<String,Long> getRowsScanned()

Specified by:

getRowsScanned in interface SnapshotMetricsMXBean

currentChunk

public void currentChunk(String chunkId,
 Object[] chunkFrom,
 Object[] chunkTo)

currentChunk

public void currentChunk(String chunkId,
 Object[] chunkFrom,
 Object[] chunkTo,
 Object[] tableTo)

getChunkId

public String getChunkId()

Specified by:

getChunkId in interface SnapshotMetricsMXBean

getChunkFrom

public String getChunkFrom()

Specified by:

getChunkFrom in interface SnapshotMetricsMXBean

getChunkTo

public String getChunkTo()

Specified by:

getChunkTo in interface SnapshotMetricsMXBean

getTableFrom

public String getTableFrom()

Specified by:

getTableFrom in interface SnapshotMetricsMXBean

getTableTo

public String getTableTo()

Specified by:

getTableTo in interface SnapshotMetricsMXBean

chunkProgress

public void chunkProgress(TableId tableId,
 long totalChunks,
 long completedChunks)

getTableChunkCounts

public Map<String,Long> getTableChunkCounts()

Specified by:

getTableChunkCounts in interface SnapshotMetricsMXBean

getTableChunksCompletedCounts

public Map<String,Long> getTableChunksCompletedCounts()

Specified by:

getTableChunksCompletedCounts in interface SnapshotMetricsMXBean

arrayToString

private String arrayToString(Object[] array)

reset

public void reset()