Package org.apache.nifi.provenance

Class MockProvenanceEvent

java.lang.Object
org.apache.nifi.provenance.MockProvenanceEvent
All Implemented Interfaces:
org.apache.nifi.provenance.ProvenanceEventRecord
public class MockProvenanceEvent extends Object implements org.apache.nifi.provenance.ProvenanceEventRecord

  • Field Details

    • eventTime

      private final long eventTime

    • entryDate

      private final long entryDate

    • eventType

      private final org.apache.nifi.provenance.ProvenanceEventType eventType

    • lineageStartDate

      private final long lineageStartDate

    • componentId

      private final String componentId

    • componentType

      private final String componentType

    • transitUri

      private final String transitUri

    • sourceSystemFlowFileIdentifier

      private final String sourceSystemFlowFileIdentifier

    • uuid

      private final String uuid

    • parentUuids

      private final List<String> parentUuids

    • childrenUuids

      private final List<String> childrenUuids

    • alternateIdentifierUri

      private final String alternateIdentifierUri

    • details

      private final String details

    • relationship

      private final String relationship

    • eventDuration

      private final long eventDuration

    • contentClaimSection

      private final String contentClaimSection

    • contentClaimContainer

      private final String contentClaimContainer

    • contentClaimIdentifier

      private final String contentClaimIdentifier

    • contentClaimOffset

      private final Long contentClaimOffset

    • contentSize

      private final long contentSize

    • previousClaimSection

      private final String previousClaimSection

    • previousClaimContainer

      private final String previousClaimContainer

    • previousClaimIdentifier

      private final String previousClaimIdentifier

    • previousClaimOffset

      private final Long previousClaimOffset

    • previousSize

      private final Long previousSize

    • sourceQueueIdentifier

      private final String sourceQueueIdentifier

    • previousAttributes

      private final Map<String,String> previousAttributes

    • updatedAttributes

      private final Map<String,String> updatedAttributes

    • eventId

      private volatile long eventId

  • Constructor Details

  • Method Details

    • setEventId

      void setEventId(long eventId)

    • getEventId

      public long getEventId()
      Specified by:
      getEventId in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getEventTime

      public long getEventTime()
      Specified by:
      getEventTime in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getLineageStartDate

      public long getLineageStartDate()
      Specified by:
      getLineageStartDate in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getFileSize

      public long getFileSize()
      Specified by:
      getFileSize in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getPreviousFileSize

      public Long getPreviousFileSize()
      Specified by:
      getPreviousFileSize in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getEventType

      public org.apache.nifi.provenance.ProvenanceEventType getEventType()
      Specified by:
      getEventType in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getAttributes

      public Map<String,String> getAttributes()
      Specified by:
      getAttributes in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getAttribute

      public String getAttribute(String attributeName)
      Specified by:
      getAttribute in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getComponentId

      public String getComponentId()
      Specified by:
      getComponentId in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getComponentType

      public String getComponentType()
      Specified by:
      getComponentType in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getTransitUri

      public String getTransitUri()
      Specified by:
      getTransitUri in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getSourceSystemFlowFileIdentifier

      public String getSourceSystemFlowFileIdentifier()
      Specified by:
      getSourceSystemFlowFileIdentifier in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getFlowFileUuid

      public String getFlowFileUuid()
      Specified by:
      getFlowFileUuid in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getParentUuids

      public List<String> getParentUuids()
      Specified by:
      getParentUuids in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getChildUuids

      public List<String> getChildUuids()
      Specified by:
      getChildUuids in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getAlternateIdentifierUri

      public String getAlternateIdentifierUri()
      Specified by:
      getAlternateIdentifierUri in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getEventDuration

      public long getEventDuration()
      Specified by:
      getEventDuration in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getDetails

      public String getDetails()
      Specified by:
      getDetails in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getRelationship

      public String getRelationship()
      Specified by:
      getRelationship in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getFlowFileEntryDate

      public long getFlowFileEntryDate()
      Specified by:
      getFlowFileEntryDate in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getContentClaimSection

      public String getContentClaimSection()
      Specified by:
      getContentClaimSection in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getContentClaimContainer

      public String getContentClaimContainer()
      Specified by:
      getContentClaimContainer in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getContentClaimIdentifier

      public String getContentClaimIdentifier()
      Specified by:
      getContentClaimIdentifier in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getContentClaimOffset

      public Long getContentClaimOffset()
      Specified by:
      getContentClaimOffset in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getSourceQueueIdentifier

      public String getSourceQueueIdentifier()
      Specified by:
      getSourceQueueIdentifier in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getPreviousAttributes

      public Map<String,String> getPreviousAttributes()
      Specified by:
      getPreviousAttributes in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getPreviousContentClaimContainer

      public String getPreviousContentClaimContainer()
      Specified by:
      getPreviousContentClaimContainer in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getPreviousContentClaimIdentifier

      public String getPreviousContentClaimIdentifier()
      Specified by:
      getPreviousContentClaimIdentifier in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getPreviousContentClaimOffset

      public Long getPreviousContentClaimOffset()
      Specified by:
      getPreviousContentClaimOffset in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getPreviousContentClaimSection

      public String getPreviousContentClaimSection()
      Specified by:
      getPreviousContentClaimSection in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • getUpdatedAttributes

      public Map<String,String> getUpdatedAttributes()
      Specified by:
      getUpdatedAttributes in interface org.apache.nifi.provenance.ProvenanceEventRecord

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object

    • different

      private boolean different(Object a, Object b)

    • different

      private boolean different(List<String> a, List<String> b)

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • getBestEventIdentifier

      public String getBestEventIdentifier()
      Returns a unique identifier for the record. By default, it uses ProvenanceEventRecord.getEventId() but if it has not been persisted to the repository, this is -1, so it constructs a String of the format <event type>_on_<flowfile UUID>_by_<component UUID>_at_<event time>.
      Specified by:
      getBestEventIdentifier in interface org.apache.nifi.provenance.ProvenanceEventRecord
      Returns:
      a String identifying the record for later analysis