Module org.apache.nifi
Package org.apache.nifi.flowanalysis

Interface FlowAnalysisContext

public interface FlowAnalysisContext
Used for accessing flow- or other analysis-related information

  • Method Details

    • getVersionedControllerServiceLookup

      VersionedControllerServiceLookup getVersionedControllerServiceLookup()
      Returns:
      the VersionedControllerServiceLookup which can be used to obtain Versioned Controller Services during flow analysis

    • getMaxTimerDrivenThreadCount

      int getMaxTimerDrivenThreadCount()
      Returns:
      the currently configured maximum number of threads that can be used for executing processors at any given time.

    • isClustered

      boolean isClustered()
      Returns:
      true if this instance of NiFi is configured to be part of a cluster, false if this instance of NiFi is a standalone instance

    • getClusterNodeIdentifier

      Optional<String> getClusterNodeIdentifier()
      Returns:
      an Optional with the ID of this node in the cluster, or empty if either this node is not clustered or the Node Identifier has not yet been established