Package org.apache.nifi.processors.standard

Class ListFile.MonitorActiveTasks

java.lang.Object
org.apache.nifi.processors.standard.ListFile.MonitorActiveTasks
All Implemented Interfaces:
Runnable
Enclosing class:
ListFile
static class ListFile.MonitorActiveTasks extends Object implements Runnable

  • Field Details

    • performanceTracker

      private final ListFile.PerformanceTracker performanceTracker

    • logger

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

    • maxDiskOperationMillis

      private final long maxDiskOperationMillis

    • maxListingMillis

      private final long maxListingMillis

    • millisToKeepStats

      private final long millisToKeepStats

    • lastPurgeTimestamp

      private long lastPurgeTimestamp

  • Constructor Details

    • MonitorActiveTasks

      public MonitorActiveTasks(ListFile.PerformanceTracker tracker, org.apache.nifi.logging.ComponentLog logger, long maxDiskOperationMillis, long maxListingMillis, long millisToKeepStats)

  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • monitorActiveOperation

      private void monitorActiveOperation()

    • monitorActiveDirectory

      private void monitorActiveDirectory()