Package org.apache.nifi.util

Class SharedSessionState

java.lang.Object
org.apache.nifi.util.SharedSessionState
public class SharedSessionState extends Object

  • Field Details

    • flowFileQueue

      private final MockFlowFileQueue flowFileQueue

    • provenanceReporter

      private final org.apache.nifi.provenance.ProvenanceReporter provenanceReporter

    • processor

      private final org.apache.nifi.processor.Processor processor

    • flowFileIdGenerator

      private final AtomicLong flowFileIdGenerator

    • counterMap

      private final ConcurrentMap<String,AtomicLong> counterMap

    • events

      private final List<org.apache.nifi.provenance.ProvenanceEventRecord> events

  • Constructor Details

    • SharedSessionState

      public SharedSessionState(org.apache.nifi.processor.Processor processor, AtomicLong flowFileIdGenerator)

  • Method Details

    • addProvenanceEvents

      void addProvenanceEvents(Collection<org.apache.nifi.provenance.ProvenanceEventRecord> events)

    • clearProvenanceEvents

      void clearProvenanceEvents()

    • getProvenanceEvents

      public List<org.apache.nifi.provenance.ProvenanceEventRecord> getProvenanceEvents()

    • getFlowFileQueue

      public MockFlowFileQueue getFlowFileQueue()

    • getProvenanceReporter

      public org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()

    • nextFlowFileId

      public long nextFlowFileId()

    • adjustCounter

      public void adjustCounter(String name, long delta)

    • getCounterValue

      public Long getCounterValue(String name)