Package org.apache.nifi.processors.standard

Interface ListFile.PerformanceTracker

All Known Implementing Classes:

ListFile.RollingMetricPerformanceTracker, ListFile.UntrackedPerformanceTracker

Enclosing class:

ListFile

static interface ListFile.PerformanceTracker

PerformanceTracker is responsible for providing a mechanism by which any disk operation can be timed and the timing information can both be used to issue warnings as well as be aggregated for some amount of time, in order to understand how long certain disk operations take and which files may be responsible for causing longer-than-usual operations to be performed.

Method Summary

Modifier and Type	Method	Description
void	acceptOperation(ListFile.DiskOperation operation, String directory, String filename, long millis)
ListFile.TimedOperationKey	beginOperation(ListFile.DiskOperation operation, String directory, String filename)
void	completeActiveDirectory()
void	completeActiveOperation()
void	completeOperation(ListFile.TimedOperationKey operationKey)
String	getActiveDirectory()
long	getActiveDirectoryStartTime()
ListFile.TimedOperationKey	getActiveOperation()
long	getEarliestTimestamp()
ListFile.OperationStatistics	getOperationStatistics(ListFile.DiskOperation operation)
ListFile.TimingInfo	getTimingInfo(String directory, String filename)
int	getTrackedFileCount()
void	purgeTimingInfo(long cutoff)
void	setActiveDirectory(String directory)
void	setActiveOperation(ListFile.TimedOperationKey operationKey)

Method Details

beginOperation

ListFile.TimedOperationKey beginOperation(ListFile.DiskOperation operation,
 String directory,
 String filename)

completeOperation

void completeOperation(ListFile.TimedOperationKey operationKey)

acceptOperation

void acceptOperation(ListFile.DiskOperation operation,
 String directory,
 String filename,
 long millis)

getTimingInfo

ListFile.TimingInfo getTimingInfo(String directory,
 String filename)

getOperationStatistics

ListFile.OperationStatistics getOperationStatistics(ListFile.DiskOperation operation)

setActiveOperation

void setActiveOperation(ListFile.TimedOperationKey operationKey)

completeActiveOperation

void completeActiveOperation()

getActiveOperation

ListFile.TimedOperationKey getActiveOperation()

purgeTimingInfo

void purgeTimingInfo(long cutoff)

getEarliestTimestamp

long getEarliestTimestamp()

setActiveDirectory

void setActiveDirectory(String directory)

completeActiveDirectory

void completeActiveDirectory()

getActiveDirectory

String getActiveDirectory()

getActiveDirectoryStartTime

long getActiveDirectoryStartTime()

getTrackedFileCount

int getTrackedFileCount()