Package org.apache.nifi.util

Class MockProvenanceReporter

java.lang.Object
org.apache.nifi.util.MockProvenanceReporter
All Implemented Interfaces:
org.apache.nifi.provenance.ProvenanceReporter
public class MockProvenanceReporter extends Object implements org.apache.nifi.provenance.ProvenanceReporter

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final Set<org.apache.nifi.provenance.ProvenanceEventRecord>
    events
     
    private static final org.slf4j.Logger
    logger
     
    private final String
    processorId
     
    private final String
    processorType
     
    private final MockProcessSession
    session
     
    private final SharedSessionState
    sharedSessionState
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    MockProvenanceReporter(MockProcessSession session, SharedSessionState sharedState, String processorId, String processorType)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    associate(org.apache.nifi.flowfile.FlowFile flowFile, String alternateIdentifierNamespace, String alternateIdentifier)
     
    (package private) org.apache.nifi.provenance.ProvenanceEventBuilder
    build(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.provenance.ProvenanceEventType eventType)
     
    (package private) void
    clear()
     
    void
    clone(org.apache.nifi.flowfile.FlowFile parent, org.apache.nifi.flowfile.FlowFile child)
     
    void
    create(org.apache.nifi.flowfile.FlowFile flowFile)
     
    void
    create(org.apache.nifi.flowfile.FlowFile flowFile, String details)
     
    (package private) org.apache.nifi.provenance.ProvenanceEventRecord
    drop(org.apache.nifi.flowfile.FlowFile flowFile, String reason)
     
    void
    fetch(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri)
     
    void
    fetch(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, long transmissionMillis)
     
    void
    fetch(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, long transmissionMillis)
     
    void
    fork(org.apache.nifi.flowfile.FlowFile parent, Collection<org.apache.nifi.flowfile.FlowFile> children)
     
    void
    fork(org.apache.nifi.flowfile.FlowFile parent, Collection<org.apache.nifi.flowfile.FlowFile> children, long forkDuration)
     
    void
    fork(org.apache.nifi.flowfile.FlowFile parent, Collection<org.apache.nifi.flowfile.FlowFile> children, String details)
     
    void
    fork(org.apache.nifi.flowfile.FlowFile parent, Collection<org.apache.nifi.flowfile.FlowFile> children, String details, long forkDuration)
     
    long
    getBytesFetched()
     
    long
    getBytesReceived()
     
    long
    getBytesSent()
     
    (package private) Set<org.apache.nifi.provenance.ProvenanceEventRecord>
    getEvents()
     
    int
    getFlowFilesFetched()
     
    int
    getFlowFilesReceived()
     
    int
    getFlowFilesSent()
     
    void
    invokeRemoteProcess(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri)
     
    void
    invokeRemoteProcess(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details)
     
    void
    join(Collection<org.apache.nifi.flowfile.FlowFile> parents, org.apache.nifi.flowfile.FlowFile child)
     
    void
    join(Collection<org.apache.nifi.flowfile.FlowFile> parents, org.apache.nifi.flowfile.FlowFile child, long joinDuration)
     
    void
    join(Collection<org.apache.nifi.flowfile.FlowFile> parents, org.apache.nifi.flowfile.FlowFile child, String details)
     
    void
    join(Collection<org.apache.nifi.flowfile.FlowFile> parents, org.apache.nifi.flowfile.FlowFile child, String details, long joinDuration)
     
    (package private) void
    migrate(MockProvenanceReporter newOwner, Set<String> flowFileIds)
     
    void
    modifyAttributes(org.apache.nifi.flowfile.FlowFile flowFile)
     
    void
    modifyAttributes(org.apache.nifi.flowfile.FlowFile flowFile, String details)
     
    void
    modifyContent(org.apache.nifi.flowfile.FlowFile flowFile)
     
    void
    modifyContent(org.apache.nifi.flowfile.FlowFile flowFile, long processingMillis)
     
    void
    modifyContent(org.apache.nifi.flowfile.FlowFile flowFile, String details)
     
    void
    modifyContent(org.apache.nifi.flowfile.FlowFile flowFile, String details, long processingMillis)
     
    void
    receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri)
     
    void
    receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, long transmissionMillis)
     
    void
    receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String sourceSystemFlowFileIdentifier)
     
    void
    receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, long transmissionMillis)
     
    void
    receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String sourceSystemFlowFileIdentifier, String details, long transmissionMillis)
     
    void
    route(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship relationship)
     
    void
    route(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship relationship, long processingDuration)
     
    void
    route(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship relationship, String details)
     
    void
    route(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship relationship, String details, long processingDuration)
     
    void
    send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri)
     
    void
    send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, boolean force)
     
    void
    send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, long transmissionMillis)
     
    void
    send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, long transmissionMillis, boolean force)
     
    void
    send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details)
     
    void
    send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, boolean force)
     
    void
    send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, long transmissionMillis)
     
    void
    send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, long transmissionMillis, boolean force)
     
    void
    upload(org.apache.nifi.flowfile.FlowFile flowFile, long size, String transitUri)
     
    void
    upload(org.apache.nifi.flowfile.FlowFile flowFile, long size, String transitUri, String details, long transmissionMillis, boolean force)
     
    private void
    verifyFlowFileKnown(org.apache.nifi.flowfile.FlowFile flowFile)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • logger

      private static final org.slf4j.Logger logger

    • session

      private final MockProcessSession session

    • processorId

      private final String processorId

    • processorType

      private final String processorType

    • sharedSessionState

      private final SharedSessionState sharedSessionState

    • events

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

  • Constructor Details

  • Method Details

    • verifyFlowFileKnown

      private void verifyFlowFileKnown(org.apache.nifi.flowfile.FlowFile flowFile)

    • getEvents

      Set<org.apache.nifi.provenance.ProvenanceEventRecord> getEvents()

    • clear

      void clear()

    • migrate

      void migrate(MockProvenanceReporter newOwner, Set<String> flowFileIds)

    • receive

      public void receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri)
      Specified by:
      receive in interface org.apache.nifi.provenance.ProvenanceReporter

    • receive

      public void receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String sourceSystemFlowFileIdentifier)
      Specified by:
      receive in interface org.apache.nifi.provenance.ProvenanceReporter

    • receive

      public void receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, long transmissionMillis)
      Specified by:
      receive in interface org.apache.nifi.provenance.ProvenanceReporter

    • receive

      public void receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, long transmissionMillis)
      Specified by:
      receive in interface org.apache.nifi.provenance.ProvenanceReporter

    • receive

      public void receive(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String sourceSystemFlowFileIdentifier, String details, long transmissionMillis)
      Specified by:
      receive in interface org.apache.nifi.provenance.ProvenanceReporter

    • fetch

      public void fetch(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri)
      Specified by:
      fetch in interface org.apache.nifi.provenance.ProvenanceReporter

    • fetch

      public void fetch(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, long transmissionMillis)
      Specified by:
      fetch in interface org.apache.nifi.provenance.ProvenanceReporter

    • fetch

      public void fetch(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, long transmissionMillis)
      Specified by:
      fetch in interface org.apache.nifi.provenance.ProvenanceReporter

    • send

      public void send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, long transmissionMillis)
      Specified by:
      send in interface org.apache.nifi.provenance.ProvenanceReporter

    • send

      public void send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri)
      Specified by:
      send in interface org.apache.nifi.provenance.ProvenanceReporter

    • send

      public void send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details)
      Specified by:
      send in interface org.apache.nifi.provenance.ProvenanceReporter

    • send

      public void send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, long transmissionMillis, boolean force)
      Specified by:
      send in interface org.apache.nifi.provenance.ProvenanceReporter

    • send

      public void send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, boolean force)
      Specified by:
      send in interface org.apache.nifi.provenance.ProvenanceReporter

    • send

      public void send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, long transmissionMillis)
      Specified by:
      send in interface org.apache.nifi.provenance.ProvenanceReporter

    • send

      public void send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details, long transmissionMillis, boolean force)
      Specified by:
      send in interface org.apache.nifi.provenance.ProvenanceReporter

    • upload

      public void upload(org.apache.nifi.flowfile.FlowFile flowFile, long size, String transitUri)
      Specified by:
      upload in interface org.apache.nifi.provenance.ProvenanceReporter

    • upload

      public void upload(org.apache.nifi.flowfile.FlowFile flowFile, long size, String transitUri, String details, long transmissionMillis, boolean force)
      Specified by:
      upload in interface org.apache.nifi.provenance.ProvenanceReporter

    • send

      public void send(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, boolean force)
      Specified by:
      send in interface org.apache.nifi.provenance.ProvenanceReporter

    • invokeRemoteProcess

      public void invokeRemoteProcess(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri)
      Specified by:
      invokeRemoteProcess in interface org.apache.nifi.provenance.ProvenanceReporter

    • invokeRemoteProcess

      public void invokeRemoteProcess(org.apache.nifi.flowfile.FlowFile flowFile, String transitUri, String details)
      Specified by:
      invokeRemoteProcess in interface org.apache.nifi.provenance.ProvenanceReporter

    • associate

      public void associate(org.apache.nifi.flowfile.FlowFile flowFile, String alternateIdentifierNamespace, String alternateIdentifier)
      Specified by:
      associate in interface org.apache.nifi.provenance.ProvenanceReporter

    • drop

      org.apache.nifi.provenance.ProvenanceEventRecord drop(org.apache.nifi.flowfile.FlowFile flowFile, String reason)

    • fork

      public void fork(org.apache.nifi.flowfile.FlowFile parent, Collection<org.apache.nifi.flowfile.FlowFile> children)
      Specified by:
      fork in interface org.apache.nifi.provenance.ProvenanceReporter

    • fork

      public void fork(org.apache.nifi.flowfile.FlowFile parent, Collection<org.apache.nifi.flowfile.FlowFile> children, long forkDuration)
      Specified by:
      fork in interface org.apache.nifi.provenance.ProvenanceReporter

    • fork

      public void fork(org.apache.nifi.flowfile.FlowFile parent, Collection<org.apache.nifi.flowfile.FlowFile> children, String details)
      Specified by:
      fork in interface org.apache.nifi.provenance.ProvenanceReporter

    • fork

      public void fork(org.apache.nifi.flowfile.FlowFile parent, Collection<org.apache.nifi.flowfile.FlowFile> children, String details, long forkDuration)
      Specified by:
      fork in interface org.apache.nifi.provenance.ProvenanceReporter

    • join

      public void join(Collection<org.apache.nifi.flowfile.FlowFile> parents, org.apache.nifi.flowfile.FlowFile child)
      Specified by:
      join in interface org.apache.nifi.provenance.ProvenanceReporter

    • join

      public void join(Collection<org.apache.nifi.flowfile.FlowFile> parents, org.apache.nifi.flowfile.FlowFile child, long joinDuration)
      Specified by:
      join in interface org.apache.nifi.provenance.ProvenanceReporter

    • join

      public void join(Collection<org.apache.nifi.flowfile.FlowFile> parents, org.apache.nifi.flowfile.FlowFile child, String details)
      Specified by:
      join in interface org.apache.nifi.provenance.ProvenanceReporter

    • join

      public void join(Collection<org.apache.nifi.flowfile.FlowFile> parents, org.apache.nifi.flowfile.FlowFile child, String details, long joinDuration)
      Specified by:
      join in interface org.apache.nifi.provenance.ProvenanceReporter

    • clone

      public void clone(org.apache.nifi.flowfile.FlowFile parent, org.apache.nifi.flowfile.FlowFile child)
      Specified by:
      clone in interface org.apache.nifi.provenance.ProvenanceReporter

    • modifyContent

      public void modifyContent(org.apache.nifi.flowfile.FlowFile flowFile)
      Specified by:
      modifyContent in interface org.apache.nifi.provenance.ProvenanceReporter

    • modifyContent

      public void modifyContent(org.apache.nifi.flowfile.FlowFile flowFile, String details)
      Specified by:
      modifyContent in interface org.apache.nifi.provenance.ProvenanceReporter

    • modifyContent

      public void modifyContent(org.apache.nifi.flowfile.FlowFile flowFile, long processingMillis)
      Specified by:
      modifyContent in interface org.apache.nifi.provenance.ProvenanceReporter

    • modifyContent

      public void modifyContent(org.apache.nifi.flowfile.FlowFile flowFile, String details, long processingMillis)
      Specified by:
      modifyContent in interface org.apache.nifi.provenance.ProvenanceReporter

    • modifyAttributes

      public void modifyAttributes(org.apache.nifi.flowfile.FlowFile flowFile)
      Specified by:
      modifyAttributes in interface org.apache.nifi.provenance.ProvenanceReporter

    • modifyAttributes

      public void modifyAttributes(org.apache.nifi.flowfile.FlowFile flowFile, String details)
      Specified by:
      modifyAttributes in interface org.apache.nifi.provenance.ProvenanceReporter

    • route

      public void route(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship relationship)
      Specified by:
      route in interface org.apache.nifi.provenance.ProvenanceReporter

    • route

      public void route(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship relationship, long processingDuration)
      Specified by:
      route in interface org.apache.nifi.provenance.ProvenanceReporter

    • route

      public void route(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship relationship, String details)
      Specified by:
      route in interface org.apache.nifi.provenance.ProvenanceReporter

    • route

      public void route(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship relationship, String details, long processingDuration)
      Specified by:
      route in interface org.apache.nifi.provenance.ProvenanceReporter

    • create

      public void create(org.apache.nifi.flowfile.FlowFile flowFile)
      Specified by:
      create in interface org.apache.nifi.provenance.ProvenanceReporter

    • create

      public void create(org.apache.nifi.flowfile.FlowFile flowFile, String details)
      Specified by:
      create in interface org.apache.nifi.provenance.ProvenanceReporter

    • getFlowFilesReceived

      public int getFlowFilesReceived()
      Specified by:
      getFlowFilesReceived in interface org.apache.nifi.provenance.ProvenanceReporter

    • getBytesReceived

      public long getBytesReceived()
      Specified by:
      getBytesReceived in interface org.apache.nifi.provenance.ProvenanceReporter

    • getFlowFilesFetched

      public int getFlowFilesFetched()
      Specified by:
      getFlowFilesFetched in interface org.apache.nifi.provenance.ProvenanceReporter

    • getBytesFetched

      public long getBytesFetched()
      Specified by:
      getBytesFetched in interface org.apache.nifi.provenance.ProvenanceReporter

    • getFlowFilesSent

      public int getFlowFilesSent()
      Specified by:
      getFlowFilesSent in interface org.apache.nifi.provenance.ProvenanceReporter

    • getBytesSent

      public long getBytesSent()
      Specified by:
      getBytesSent in interface org.apache.nifi.provenance.ProvenanceReporter

    • build

      org.apache.nifi.provenance.ProvenanceEventBuilder build(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.provenance.ProvenanceEventType eventType)