Package org.jumpmind.symmetric.statistic

Class StatisticManager

java.lang.Object

org.jumpmind.symmetric.statistic.StatisticManager

All Implemented Interfaces:

IStatisticManager

public class StatisticManager
extends Object
implements IStatisticManager

See Also:

• IStatisticManager

Field Summary

Fields

Modifier and Type	Field	Description
protected Semaphore	channelStatsLock
protected IClusterService	clusterService
protected IConfigurationService	configurationService
protected Semaphore	hostStatsLock
protected Semaphore	jobStatsLock
protected org.slf4j.Logger	log
protected INodeService	nodeService
protected IParameterService	parameterService
protected Map<ProcessInfoKey,ProcessInfo>	processInfos
protected Map<ProcessInfoKey,ProcessInfo>	processInfosThatHaveDoneWork
protected IStatisticService	statisticService
protected Semaphore	tableStatsLock

Constructor Summary

Constructors

Constructor	Description
StatisticManager(IParameterService parameterService, INodeService nodeService, IConfigurationService configurationService, IStatisticService statisticsService, IClusterService clusterService)

Method Summary

Modifier and Type	Method	Description
void	addJobStats(String targetNodeId, int targetNodeCount, String jobName, long startTime, long endTime, long processedCount)
void	addJobStats(String jobName, long startTime, long endTime, long processedCount)
void	addJobStats(String jobName, long startTime, long endTime, long processedCount, Exception e)
void	addJobStats(String jobName, long startTime, long endTime, long processedCount, String errorMessage)
void	addRouterStats(long startDataId, long endDataId, long dataReadCount, long peekAheadFillCount, List<DataGap> dataGaps, Set<String> transactions, Collection<OutgoingBatch> batches)
void	flush()
protected ChannelStats	getChannelStats(String channelId)
protected HostStats	getHostStats()
String	getMostRecentActiveTableSynced()
TreeMap<Date,Map<String,ChannelStats>>	getNodeStatsForPeriod(Date start, Date end, String nodeId, int periodSizeInMinutes)
Set<String>	getNodesWithProcessesInError()
List<ProcessInfo>	getProcessInfos()
List<ProcessInfo>	getProcessInfosThatHaveDoneWork()
RouterStats	getRouterStatsByBatch(Long batchId)
Map<Integer,Date>	getTotalLoadedRows()
Map<String,ChannelStats>	getWorkingChannelStats()
HostStats	getWorkingHostStats()
List<JobStats>	getWorkingJobStats()
void	incrementDataBytesExtracted(String channelId, long count)
void	incrementDataBytesLoaded(String channelId, long count)
void	incrementDataBytesLoadedOutgoing(String channelId, long count)
void	incrementDataBytesSent(String channelId, long count)
void	incrementDataEventInserted(String channelId, long count)
void	incrementDataExtracted(String channelId, long count)
void	incrementDataExtractedErrors(String channelId, long count)
void	incrementDataLoaded(String channelId, long count)
void	incrementDataLoadedErrors(String channelId, long count)
void	incrementDataLoadedOutgoing(String channelId, long count)
void	incrementDataLoadedOutgoingErrors(String channelId, long count)
void	incrementDataRouted(String channelId, long count)
void	incrementDataSent(String channelId, long count)
void	incrementDataSentErrors(String channelId, long count)
void	incrementNodesDisabled(long count)
void	incrementNodesLoaded(long count)
void	incrementNodesPulled(long count)
void	incrementNodesPushed(long count)
void	incrementNodesRegistered(long count)
void	incrementNodesRejected(long count)
void	incrementPurgedBatchIncomingRows(long count)
void	incrementPurgedBatchOutgoingRows(long count)
void	incrementPurgedDataEventRows(long count)
void	incrementPurgedDataRows(long count)
void	incrementPurgedExpiredDataRows(long count)
void	incrementPurgedStrandedDataEventRows(long count)
void	incrementPurgedStrandedDataRows(long count)
void	incrementRestart()
void	incrementTableRows(Map<String,Map<String,Long>> tableCounts, boolean loaded)
void	incrementTotalNodesPulledTime(long count)
void	incrementTotalNodesPushedTime(long count)
void	incrementTriggersCreatedCount(long count)
void	incrementTriggersRebuiltCount(long count)
void	incrementTriggersRemovedCount(long count)
protected void	init()
ProcessInfo	newProcessInfo(ProcessInfoKey key)
void	removeRouterStatsByBatch(Long batchId)
protected void	resetChannelStats(boolean force)
protected void	saveAdditionalStats(Date endTime, ChannelStats stats)
void	setDataUnRouted(String channelId, long count)

Methods inherited from class java.lang.Object

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

Field Details

log

protected org.slf4j.Logger log

nodeService

protected INodeService nodeService

statisticService

protected IStatisticService statisticService

parameterService

protected IParameterService parameterService

configurationService

protected IConfigurationService configurationService

clusterService

protected IClusterService clusterService

channelStatsLock

protected Semaphore channelStatsLock

hostStatsLock

protected Semaphore hostStatsLock

jobStatsLock

protected Semaphore jobStatsLock

tableStatsLock

protected Semaphore tableStatsLock

processInfos

protected Map<ProcessInfoKey,ProcessInfo> processInfos

processInfosThatHaveDoneWork

protected Map<ProcessInfoKey,ProcessInfo> processInfosThatHaveDoneWork

Constructor Details

StatisticManager

public StatisticManager(IParameterService parameterService,
 INodeService nodeService,
 IConfigurationService configurationService,
 IStatisticService statisticsService,
 IClusterService clusterService)

Method Details

init

protected void init()

newProcessInfo

public ProcessInfo newProcessInfo(ProcessInfoKey key)

Specified by:

newProcessInfo in interface IStatisticManager

getNodesWithProcessesInError

public Set<String> getNodesWithProcessesInError()

Specified by:

getNodesWithProcessesInError in interface IStatisticManager

getProcessInfos

public List<ProcessInfo> getProcessInfos()

Specified by:

getProcessInfos in interface IStatisticManager

getProcessInfosThatHaveDoneWork

public List<ProcessInfo> getProcessInfosThatHaveDoneWork()

Specified by:

getProcessInfosThatHaveDoneWork in interface IStatisticManager

addJobStats

public void addJobStats(String jobName,
 long startTime,
 long endTime,
 long processedCount)

Specified by:

addJobStats in interface IStatisticManager

addJobStats

public void addJobStats(String jobName,
 long startTime,
 long endTime,
 long processedCount,
 String errorMessage)

Specified by:

addJobStats in interface IStatisticManager

addJobStats

public void addJobStats(String jobName,
 long startTime,
 long endTime,
 long processedCount,
 Exception e)

Specified by:

addJobStats in interface IStatisticManager

addJobStats

public void addJobStats(String targetNodeId,
 int targetNodeCount,
 String jobName,
 long startTime,
 long endTime,
 long processedCount)

Specified by:

addJobStats in interface IStatisticManager

getRouterStatsByBatch

public RouterStats getRouterStatsByBatch(Long batchId)

Specified by:

getRouterStatsByBatch in interface IStatisticManager

addRouterStats

public void addRouterStats(long startDataId,
 long endDataId,
 long dataReadCount,
 long peekAheadFillCount,
 List<DataGap> dataGaps,
 Set<String> transactions,
 Collection<OutgoingBatch> batches)

Specified by:

addRouterStats in interface IStatisticManager

removeRouterStatsByBatch

public void removeRouterStatsByBatch(Long batchId)

Specified by:

removeRouterStatsByBatch in interface IStatisticManager

incrementDataRouted

public void incrementDataRouted(String channelId,
 long count)

Specified by:

incrementDataRouted in interface IStatisticManager

setDataUnRouted

public void setDataUnRouted(String channelId,
 long count)

Specified by:

setDataUnRouted in interface IStatisticManager

incrementDataExtracted

public void incrementDataExtracted(String channelId,
 long count)

Specified by:

incrementDataExtracted in interface IStatisticManager

incrementDataBytesExtracted

public void incrementDataBytesExtracted(String channelId,
 long count)

Specified by:

incrementDataBytesExtracted in interface IStatisticManager

incrementDataExtractedErrors

public void incrementDataExtractedErrors(String channelId,
 long count)

Specified by:

incrementDataExtractedErrors in interface IStatisticManager

incrementDataEventInserted

public void incrementDataEventInserted(String channelId,
 long count)

Specified by:

incrementDataEventInserted in interface IStatisticManager

incrementDataSent

public void incrementDataSent(String channelId,
 long count)

Specified by:

incrementDataSent in interface IStatisticManager

incrementDataBytesSent

public void incrementDataBytesSent(String channelId,
 long count)

Specified by:

incrementDataBytesSent in interface IStatisticManager

incrementDataSentErrors

public void incrementDataSentErrors(String channelId,
 long count)

Specified by:

incrementDataSentErrors in interface IStatisticManager

incrementDataLoaded

public void incrementDataLoaded(String channelId,
 long count)

Specified by:

incrementDataLoaded in interface IStatisticManager

incrementDataBytesLoaded

public void incrementDataBytesLoaded(String channelId,
 long count)

Specified by:

incrementDataBytesLoaded in interface IStatisticManager

incrementDataLoadedErrors

public void incrementDataLoadedErrors(String channelId,
 long count)

Specified by:

incrementDataLoadedErrors in interface IStatisticManager

incrementDataLoadedOutgoing

public void incrementDataLoadedOutgoing(String channelId,
 long count)

Specified by:

incrementDataLoadedOutgoing in interface IStatisticManager

incrementDataBytesLoadedOutgoing

public void incrementDataBytesLoadedOutgoing(String channelId,
 long count)

Specified by:

incrementDataBytesLoadedOutgoing in interface IStatisticManager

incrementDataLoadedOutgoingErrors

public void incrementDataLoadedOutgoingErrors(String channelId,
 long count)

Specified by:

incrementDataLoadedOutgoingErrors in interface IStatisticManager

incrementRestart

public void incrementRestart()

Specified by:

incrementRestart in interface IStatisticManager

incrementNodesPulled

public void incrementNodesPulled(long count)

Specified by:

incrementNodesPulled in interface IStatisticManager

incrementNodesPushed

public void incrementNodesPushed(long count)

Specified by:

incrementNodesPushed in interface IStatisticManager

incrementTotalNodesPulledTime

public void incrementTotalNodesPulledTime(long count)

Specified by:

incrementTotalNodesPulledTime in interface IStatisticManager

incrementTotalNodesPushedTime

public void incrementTotalNodesPushedTime(long count)

Specified by:

incrementTotalNodesPushedTime in interface IStatisticManager

incrementNodesRejected

public void incrementNodesRejected(long count)

Specified by:

incrementNodesRejected in interface IStatisticManager

incrementNodesRegistered

public void incrementNodesRegistered(long count)

Specified by:

incrementNodesRegistered in interface IStatisticManager

incrementNodesLoaded

public void incrementNodesLoaded(long count)

Specified by:

incrementNodesLoaded in interface IStatisticManager

incrementNodesDisabled

public void incrementNodesDisabled(long count)

Specified by:

incrementNodesDisabled in interface IStatisticManager

incrementPurgedBatchIncomingRows

public void incrementPurgedBatchIncomingRows(long count)

Specified by:

incrementPurgedBatchIncomingRows in interface IStatisticManager

incrementPurgedBatchOutgoingRows

public void incrementPurgedBatchOutgoingRows(long count)

Specified by:

incrementPurgedBatchOutgoingRows in interface IStatisticManager

incrementPurgedDataRows

public void incrementPurgedDataRows(long count)

Specified by:

incrementPurgedDataRows in interface IStatisticManager

incrementPurgedDataEventRows

public void incrementPurgedDataEventRows(long count)

Specified by:

incrementPurgedDataEventRows in interface IStatisticManager

incrementPurgedStrandedDataRows

public void incrementPurgedStrandedDataRows(long count)

Specified by:

incrementPurgedStrandedDataRows in interface IStatisticManager

incrementPurgedStrandedDataEventRows

public void incrementPurgedStrandedDataEventRows(long count)

Specified by:

incrementPurgedStrandedDataEventRows in interface IStatisticManager

incrementPurgedExpiredDataRows

public void incrementPurgedExpiredDataRows(long count)

Specified by:

incrementPurgedExpiredDataRows in interface IStatisticManager

incrementTriggersRemovedCount

public void incrementTriggersRemovedCount(long count)

Specified by:

incrementTriggersRemovedCount in interface IStatisticManager

incrementTriggersRebuiltCount

public void incrementTriggersRebuiltCount(long count)

Specified by:

incrementTriggersRebuiltCount in interface IStatisticManager

incrementTriggersCreatedCount

public void incrementTriggersCreatedCount(long count)

Specified by:

incrementTriggersCreatedCount in interface IStatisticManager

saveAdditionalStats

protected void saveAdditionalStats(Date endTime,
 ChannelStats stats)

flush

public void flush()

Specified by:

flush in interface IStatisticManager

getNodeStatsForPeriod

public TreeMap<Date,Map<String,ChannelStats>> getNodeStatsForPeriod(Date start,
 Date end,
 String nodeId,
 int periodSizeInMinutes)

Specified by:

getNodeStatsForPeriod in interface IStatisticManager

getWorkingChannelStats

public Map<String,ChannelStats> getWorkingChannelStats()

Specified by:

getWorkingChannelStats in interface IStatisticManager

getWorkingJobStats

public List<JobStats> getWorkingJobStats()

Specified by:

getWorkingJobStats in interface IStatisticManager

getWorkingHostStats

public HostStats getWorkingHostStats()

Specified by:

getWorkingHostStats in interface IStatisticManager

resetChannelStats

protected void resetChannelStats(boolean force)

getChannelStats

protected ChannelStats getChannelStats(String channelId)

getHostStats

protected HostStats getHostStats()

incrementTableRows

public void incrementTableRows(Map<String,Map<String,Long>> tableCounts,
 boolean loaded)

Specified by:

incrementTableRows in interface IStatisticManager

getMostRecentActiveTableSynced

public String getMostRecentActiveTableSynced()

Specified by:

getMostRecentActiveTableSynced in interface IStatisticManager

getTotalLoadedRows

public Map<Integer,Date> getTotalLoadedRows()

Specified by:

getTotalLoadedRows in interface IStatisticManager