Package org.odpi.openmetadata.frameworks.integration.openlineage

Class OpenLineageJobEvent

java.lang.Object
org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageJobEvent
public class OpenLineageJobEvent extends Object
This class represents the content of an OpenLineage job event. A job event describes a job and its inputs and outputs independently of any particular run, for example when a pipeline is deployed. It follows https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/JobEvent. It is used internally in Egeria to pass this information to the integration daemon's integration connectors.

  • Constructor Details

    • OpenLineageJobEvent

      public OpenLineageJobEvent()
      Default constructor

  • Method Details

    • getEventTime

      public String getEventTime()
      Return the time the event occurred at (ISO-8601).
      Returns:
      value

    • setEventTime

      public void setEventTime(String eventTime)
      Set up the time the event occurred at (ISO-8601).
      Parameters:
      eventTime - value

    • getProducer

      public URI getProducer()
      Return the URI identifying the producer of this metadata. For example this could be a git url with a given tag or sha.
      Returns:
      value

    • setProducer

      public void setProducer(URI producer)
      Set up the URI identifying the producer of this metadata. For example this could be a git url with a given tag or sha.
      Parameters:
      producer - value

    • getSchemaURL

      public URI getSchemaURL()
      Return the JSON Pointer (https://tools.ietf.org/html/rfc6901) URL to the corresponding version of the schema definition for this event.
      Returns:
      value

    • setSchemaURL

      public void setSchemaURL(URI schemaURL)
      Set up the JSON Pointer (https://tools.ietf.org/html/rfc6901) URL to the corresponding version of the schema definition for this event.
      Parameters:
      schemaURL - value

    • getJob

      public OpenLineageJob getJob()
      Return the job that the event describes.
      Returns:
      value

    • setJob

      public void setJob(OpenLineageJob job)
      Set up the job that the event describes.
      Parameters:
      job - value

    • getInputs

      public List<OpenLineageInputDataSet> getInputs()
      Return the set of input datasets.
      Returns:
      value

    • setInputs

      public void setInputs(List<OpenLineageInputDataSet> inputs)
      Set up the set of input datasets.
      Parameters:
      inputs - value

    • getOutputs

      public List<OpenLineageOutputDataSet> getOutputs()
      Return the set of output datasets.
      Returns:
      value

    • setOutputs

      public void setOutputs(List<OpenLineageOutputDataSet> outputs)
      Set up the set of output datasets.
      Parameters:
      outputs - value

    • getAdditionalProperties

      public Map<String,Object> getAdditionalProperties()
      Return any properties that are not modelled by the bean. They are serialized as top-level properties alongside the modelled properties.
      Returns:
      map of property name to value

    • setAdditionalProperties

      public void setAdditionalProperties(Map<String,Object> additionalProperties)
      Set up any properties that are not modelled by the bean.
      Parameters:
      additionalProperties - map of property name to value

    • setAdditionalProperty

      public void setAdditionalProperty(String propertyName, Object propertyValue)
      Add a property that is not modelled by the bean. Jackson calls this for each unrecognized property found in the JSON.
      Parameters:
      propertyName - name of the property
      propertyValue - value of the property

    • toString

      public String toString()
      Standard toString method.
      Overrides:
      toString in class Object
      Returns:
      print out of variables in a JSON-style

    • equals

      public boolean equals(Object objectToCompare)
      Compare the values of the supplied object with those stored in the current object.
      Overrides:
      equals in class Object
      Parameters:
      objectToCompare - supplied object
      Returns:
      boolean result of comparison

    • hashCode

      public int hashCode()
      Return hash code based on properties.
      Overrides:
      hashCode in class Object
      Returns:
      int