Package com.atlassian.confluence.impl.backuprestore.statistics

Class StatisticsCollector

java.lang.Object

com.atlassian.confluence.impl.backuprestore.statistics.StatisticsCollector

All Implemented Interfaces:

JobStatisticsInfo, AutoCloseable

public class StatisticsCollector
extends Object
implements JobStatisticsInfo, AutoCloseable

Responsible for collecting statistics about backup/restore jobs, plus updating the db records (without affecting the performance).

Since:

8.3.0

Constructor Summary

Constructors

Constructor	Description
StatisticsCollector(long jobId, JobScope jobScope, JobOperation jobOperation, com.atlassian.event.api.EventPublisher eventPublisher, BackupRestoreJobDao backupRestoreJobDao, ParallelTasksExecutor parallelTasksExecutor)

Method Summary

Modifier and Type	Method	Description
void	close()
void	createEmptyStatisticsRecord()
void	flush()	Stores statistics to the database synchronously.
long	getPersistedObjectsCount()
long	getProcessedObjectsCounter()
long	getReusedObjectsCount()
long	getSkippedObjectsCount()
long	getStartTime()
long	getTotalNumberOfObjects()
void	onObjectPersisting(Collection<ImportedObjectV2> incomingPersistedObjects)
void	onObjectReusing(Collection<ImportedObjectV2> importedObjects)
void	onObjectsExporting(Collection<EntityObjectReadyForExport> exportedEntities)
void	onObjectSkipping(Collection<ImportedObjectV2> importedObjects, SkippedObjectsReason skippedObjectsReason)
void	onObjectsSkipping(Collection<DbRawObjectData> exportedEntities, SkippedObjectsReason skippedObjectsReason, String errorMessage)
void	setTotalNumberOfObjects(Long totalNumberOfObjects)

Methods inherited from class java.lang.Object

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

Constructor Detail

StatisticsCollector

public StatisticsCollector(long jobId,
                           JobScope jobScope,
                           JobOperation jobOperation,
                           com.atlassian.event.api.EventPublisher eventPublisher,
                           BackupRestoreJobDao backupRestoreJobDao,
                           ParallelTasksExecutor parallelTasksExecutor)

Method Detail

getPersistedObjectsCount

public long getPersistedObjectsCount()

Specified by:

getPersistedObjectsCount in interface JobStatisticsInfo

getSkippedObjectsCount

public long getSkippedObjectsCount()

Specified by:

getSkippedObjectsCount in interface JobStatisticsInfo

getReusedObjectsCount

public long getReusedObjectsCount()

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface JobStatisticsInfo

getTotalNumberOfObjects

public long getTotalNumberOfObjects()

Specified by:

getTotalNumberOfObjects in interface JobStatisticsInfo

getProcessedObjectsCounter

public long getProcessedObjectsCounter()

Specified by:

getProcessedObjectsCounter in interface JobStatisticsInfo

close

public void close()

Specified by:

close in interface AutoCloseable

onObjectPersisting

public void onObjectPersisting(Collection<ImportedObjectV2> incomingPersistedObjects)

onObjectReusing

public void onObjectReusing(Collection<ImportedObjectV2> importedObjects)

onObjectsExporting

public void onObjectsExporting(Collection<EntityObjectReadyForExport> exportedEntities)

onObjectsSkipping

public void onObjectsSkipping(Collection<DbRawObjectData> exportedEntities,
                              SkippedObjectsReason skippedObjectsReason,
                              String errorMessage)

onObjectSkipping

public void onObjectSkipping(Collection<ImportedObjectV2> importedObjects,
                             SkippedObjectsReason skippedObjectsReason)

flush

public void flush()

Stores statistics to the database synchronously.

setTotalNumberOfObjects

public void setTotalNumberOfObjects(Long totalNumberOfObjects)

createEmptyStatisticsRecord

public void createEmptyStatisticsRecord()
                                 throws ExecutionException,
                                        InterruptedException

Throws:

ExecutionException

InterruptedException