Package org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined

Class DownloadStageStatistics

java.lang.Object

org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined.DownloadStageStatistics

public class DownloadStageStatistics
extends Object

Aggregates statistics when downloading from Mongo with two threads

Field Summary

Fields

Modifier and Type	Field	Description
static Logger	LOG

Constructor Summary

Constructors

Constructor	Description
DownloadStageStatistics()

Method Summary

Modifier and Type	Method	Description
String	formatStats(long durationMillis)
long	getDocumentsDownloadedTotal()
long	getDocumentsDownloadedTotalBytes()
long	getTotalEnqueueWaitTimeMillis()
void	incrementDocumentsDownloadedTotal()
void	incrementDocumentsDownloadedTotalBytes(long bytes)
void	incrementTotalEnqueueWaitTimeMillis(long millis)
void	publishStatistics(StatisticsProvider statisticsProvider, IndexingReporter reporter, long durationMillis)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final Logger LOG

Constructor Detail

DownloadStageStatistics

public DownloadStageStatistics()

Method Detail

getTotalEnqueueWaitTimeMillis

public long getTotalEnqueueWaitTimeMillis()

getDocumentsDownloadedTotal

public long getDocumentsDownloadedTotal()

getDocumentsDownloadedTotalBytes

public long getDocumentsDownloadedTotalBytes()

incrementTotalEnqueueWaitTimeMillis

public void incrementTotalEnqueueWaitTimeMillis(long millis)

incrementDocumentsDownloadedTotal

public void incrementDocumentsDownloadedTotal()

incrementDocumentsDownloadedTotalBytes

public void incrementDocumentsDownloadedTotalBytes(long bytes)

toString

public String toString()

Overrides:

toString in class Object

publishStatistics

public void publishStatistics(StatisticsProvider statisticsProvider,
                              IndexingReporter reporter,
                              long durationMillis)

formatStats

public String formatStats(long durationMillis)