Package org.apache.nifi.processors.standard

Class ListFile.TimingInfo

java.lang.Object

org.apache.nifi.processors.standard.ListFile.TimingInfo

Enclosing class:

ListFile

private static class ListFile.TimingInfo
extends Object

Provides a mechanism for timing how long a particular operation takes to complete, logging if it takes longer than the configured threshold.

Field Summary

Fields

Modifier and Type	Field	Description
private final long	creationTimestamp
private final String	directory
private final String	filename
private final org.apache.nifi.logging.ComponentLog	logger
private final long	maxDiskOperationMillis
private final int[]	operationTimes
private final ListFile.PerformanceTracker	tracker

Constructor Summary

Constructors

Constructor	Description
TimingInfo(String directory, String filename, ListFile.PerformanceTracker tracker, org.apache.nifi.logging.ComponentLog logger, long maxDiskOperationMillis)

Method Summary

Modifier and Type	Method	Description
void	accept(ListFile.DiskOperation operation, long duration)
long	getCreationTimestamp()
String	getDirectory()
String	getFilename()
private String	getFullPath()
long	getOperationTime(ListFile.DiskOperation operation)
private void	timeOperation(ListFile.DiskOperation operation, Runnable task)
private <T> T	timeOperation(ListFile.DiskOperation operation, Supplier<T> function)

Methods inherited from class java.lang.Object

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

Field Details

directory

private final String directory

filename

private final String filename

operationTimes

private final int[] operationTimes

tracker

private final ListFile.PerformanceTracker tracker

creationTimestamp

private final long creationTimestamp

logger

private final org.apache.nifi.logging.ComponentLog logger

maxDiskOperationMillis

private final long maxDiskOperationMillis

Constructor Details

TimingInfo

public TimingInfo(String directory,
 String filename,
 ListFile.PerformanceTracker tracker,
 org.apache.nifi.logging.ComponentLog logger,
 long maxDiskOperationMillis)

Method Details

getDirectory

public String getDirectory()

getFilename

public String getFilename()

accept

public void accept(ListFile.DiskOperation operation,
 long duration)

getFullPath

private String getFullPath()

getOperationTime

public long getOperationTime(ListFile.DiskOperation operation)

timeOperation

private <T> T timeOperation(ListFile.DiskOperation operation,
 Supplier<T> function)

timeOperation

private void timeOperation(ListFile.DiskOperation operation,
 Runnable task)

getCreationTimestamp

public long getCreationTimestamp()