public class StatisticService extends AbstractService implements IStatisticService
IStatisticServicelog, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
StatisticService(IParameterService parameterService,
ISymmetricDialect dialect) |
| Modifier and Type | Method and Description |
|---|---|
java.util.TreeMap<java.util.Date,java.util.Map<java.lang.String,ChannelStats>> |
getChannelStatsForPeriod(java.util.Date start,
java.util.Date end,
java.lang.String nodeId,
int periodSizeInMinutes) |
java.util.TreeMap<java.util.Date,HostStats> |
getHostStatsForPeriod(java.util.Date start,
java.util.Date end,
java.lang.String nodeId,
int periodSizeInMinutes) |
java.util.List<JobStats> |
getJobStatsForPeriod(java.util.Date start,
java.util.Date end,
java.lang.String nodeId) |
java.util.Date |
getMinNodeStats(java.lang.String nodeId) |
java.util.TreeMap<java.util.Date,java.util.Map<java.lang.String,ChannelStats>> |
getNodeStatsForPeriod(java.util.Date start,
java.util.Date end,
java.lang.String nodeId,
int periodSizeInMinutes) |
void |
save(ChannelStats stats) |
void |
save(HostStats stats) |
void |
save(JobStats stats) |
java.util.Date |
truncateToMinutes(java.util.Date date) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdspublic StatisticService(IParameterService parameterService, ISymmetricDialect dialect)
public void save(ChannelStats stats)
save in interface IStatisticServicepublic void save(JobStats stats)
save in interface IStatisticServicepublic java.util.List<JobStats> getJobStatsForPeriod(java.util.Date start, java.util.Date end, java.lang.String nodeId)
getJobStatsForPeriod in interface IStatisticServicepublic java.util.TreeMap<java.util.Date,java.util.Map<java.lang.String,ChannelStats>> getChannelStatsForPeriod(java.util.Date start, java.util.Date end, java.lang.String nodeId, int periodSizeInMinutes)
getChannelStatsForPeriod in interface IStatisticServicepublic java.util.TreeMap<java.util.Date,java.util.Map<java.lang.String,ChannelStats>> getNodeStatsForPeriod(java.util.Date start, java.util.Date end, java.lang.String nodeId, int periodSizeInMinutes)
getNodeStatsForPeriod in interface IStatisticServicepublic java.util.Date getMinNodeStats(java.lang.String nodeId)
getMinNodeStats in interface IStatisticServicepublic void save(HostStats stats)
save in interface IStatisticServicepublic java.util.TreeMap<java.util.Date,HostStats> getHostStatsForPeriod(java.util.Date start, java.util.Date end, java.lang.String nodeId, int periodSizeInMinutes)
getHostStatsForPeriod in interface IStatisticServicepublic java.util.Date truncateToMinutes(java.util.Date date)