org.camunda.bpm.engine.impl.persistence.entity

Class MeterLogManager

java.lang.Object

org.camunda.bpm.engine.impl.persistence.AbstractManager

org.camunda.bpm.engine.impl.persistence.entity.MeterLogManager

All Implemented Interfaces:

Session

public class MeterLogManager
extends AbstractManager

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELETE_ALL_METER
static String	DELETE_ALL_METER_BY_TIMESTAMP_AND_REPORTER
static String	DELETE_TASK_METER_BY_IDS
static String	DELETE_TASK_METER_BY_REMOVAL_TIME
static String	DELETE_TASK_METER_BY_TIMESTAMP
static String	SELECT_METER_INTERVAL
static String	SELECT_METER_SUM
static String	SELECT_TASK_METER_FOR_CLEANUP
static String	SELECT_UNIQUE_TASK_WORKER

Constructor Summary

Constructors

Constructor and Description
MeterLogManager()

Method Summary

Modifier and Type	Method and Description
void	deleteAll()
void	deleteByTimestampAndReporter(Date timestamp, String reporter)
void	deleteTaskMetricsById(List<String> taskMetricIds)
DbOperation	deleteTaskMetricsByRemovalTime(Date currentTimestamp, Integer timeToLive, int minuteFrom, int minuteTo, int batchSize)
void	deleteTaskMetricsByTimestamp(Date timestamp)
List<MetricIntervalValue>	executeSelectInterval(MetricsQueryImpl query)
Long	executeSelectSum(MetricsQueryImpl query)
List<String>	findTaskMetricsForCleanup(int batchSize, Integer timeToLive, int minuteFrom, int minuteTo)
long	findUniqueTaskWorkerCount(Date startTime, Date endTime)
void	insert(MeterLogEntity meterLogEntity)
protected boolean	isEndTimeAfterLastReportInterval(MetricsQueryImpl query)
protected boolean	shouldAddCurrentUnloggedCount(MetricsQueryImpl query)

Methods inherited from class org.camunda.bpm.engine.impl.persistence.AbstractManager

checkAuthorization, close, configureQuery, delete, deleteAuthorizations, deleteAuthorizationsForGroup, deleteAuthorizationsForUser, deleteDefaultAuthorizations, flush, getAttachmentManager, getAuthorizationManager, getBatchManager, getByteArrayManager, getCaseDefinitionManager, getCaseExecutionManager, getCaseInstanceManager, getCommandContext, getCurrentAuthentication, getDbEntityManager, getDbSqlSession, getDecisionDefinitionManager, getDecisionRequirementsDefinitionManager, getDeploymentManager, getEventSubscriptionManager, getHistoricActivityInstanceManager, getHistoricBatchManager, getHistoricCaseActivityInstanceManager, getHistoricCaseInstanceManager, getHistoricDecisionInstanceManager, getHistoricDetailManager, getHistoricExternalTaskLogManager, getHistoricIdentityLinkManager, getHistoricIncidentManager, getHistoricJobLogManager, getHistoricProcessInstanceManager, getHistoricReportManager, getHistoricTaskInstanceManager, getHistoricVariableInstanceManager, getIdentityInfoManager, getIdentityLinkManager, getJobDefinitionManager, getJobManager, getProcessDefinitionManager, getProcessInstanceManager, getResourceAuthorizationProvider, getResourceManager, getSession, getTaskManager, getTaskReportManager, getTenantManager, getUserOperationLogManager, getVariableInstanceManager, insert, isAuthorizationEnabled, saveDefaultAuthorizations

Methods inherited from class java.lang.Object

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

Field Detail

SELECT_METER_INTERVAL

public static final String SELECT_METER_INTERVAL

See Also:

Constant Field Values

SELECT_METER_SUM

public static final String SELECT_METER_SUM

See Also:

Constant Field Values

DELETE_ALL_METER

public static final String DELETE_ALL_METER

See Also:

Constant Field Values

DELETE_ALL_METER_BY_TIMESTAMP_AND_REPORTER

public static final String DELETE_ALL_METER_BY_TIMESTAMP_AND_REPORTER

See Also:

Constant Field Values

SELECT_UNIQUE_TASK_WORKER

public static final String SELECT_UNIQUE_TASK_WORKER

See Also:

Constant Field Values

SELECT_TASK_METER_FOR_CLEANUP

public static final String SELECT_TASK_METER_FOR_CLEANUP

See Also:

Constant Field Values

DELETE_TASK_METER_BY_TIMESTAMP

public static final String DELETE_TASK_METER_BY_TIMESTAMP

See Also:

Constant Field Values

DELETE_TASK_METER_BY_REMOVAL_TIME

public static final String DELETE_TASK_METER_BY_REMOVAL_TIME

See Also:

Constant Field Values

DELETE_TASK_METER_BY_IDS

public static final String DELETE_TASK_METER_BY_IDS

See Also:

Constant Field Values

Constructor Detail

MeterLogManager

public MeterLogManager()

Method Detail

insert

public void insert(MeterLogEntity meterLogEntity)

executeSelectSum

public Long executeSelectSum(MetricsQueryImpl query)

executeSelectInterval

public List<MetricIntervalValue> executeSelectInterval(MetricsQueryImpl query)

isEndTimeAfterLastReportInterval

protected boolean isEndTimeAfterLastReportInterval(MetricsQueryImpl query)

shouldAddCurrentUnloggedCount

protected boolean shouldAddCurrentUnloggedCount(MetricsQueryImpl query)

deleteAll

public void deleteAll()

deleteByTimestampAndReporter

public void deleteByTimestampAndReporter(Date timestamp,
                                         String reporter)

findUniqueTaskWorkerCount

public long findUniqueTaskWorkerCount(Date startTime,
                                      Date endTime)

deleteTaskMetricsByTimestamp

public void deleteTaskMetricsByTimestamp(Date timestamp)

deleteTaskMetricsById

public void deleteTaskMetricsById(List<String> taskMetricIds)

deleteTaskMetricsByRemovalTime

public DbOperation deleteTaskMetricsByRemovalTime(Date currentTimestamp,
                                                  Integer timeToLive,
                                                  int minuteFrom,
                                                  int minuteTo,
                                                  int batchSize)

findTaskMetricsForCleanup

public List<String> findTaskMetricsForCleanup(int batchSize,
                                              Integer timeToLive,
                                              int minuteFrom,
                                              int minuteTo)