Class OpenLineageServerConfig

  • All Implemented Interfaces:
    java.io.Serializable

    public class OpenLineageServerConfig
    extends AdminServicesConfigHeader
    OpenLineageConfig provides the properties for the open-lineage-services.
    See Also:
    Serialized Form
    • Constructor Detail

      • OpenLineageServerConfig

        public OpenLineageServerConfig()
        Default constructor
      • OpenLineageServerConfig

        public OpenLineageServerConfig​(OpenLineageServerConfig template)
        Set up the default values for open lineage
        Parameters:
        template - fixed properties about open lineage
    • Method Detail

      • getOpenLineageId

        public int getOpenLineageId()
        Return the code number (ordinal) for this Open Lineage
        Returns:
        the code number for Open Lineage component
      • setOpenLineageId

        public void setOpenLineageId​(int openLineageId)
        Set up the code number (ordinal) for the Open Lineage
        Parameters:
        openLineageId - int ordinal
      • getOpenLineageName

        public java.lang.String getOpenLineageName()
        Return the name of the Open Lineage Connector
        Returns:
        the name of the open lineage connector
      • setOpenLineageName

        public void setOpenLineageName​(java.lang.String openLineageName)
        Set up the name of the Open Lineage Connector
        Parameters:
        openLineageName - connector name
      • getOpenLineageDescription

        public java.lang.String getOpenLineageDescription()
        Return the short description of the Open Lineage Component. The default value is in English but this can be changed.
        Returns:
        String description
      • setOpenLineageDescription

        public void setOpenLineageDescription​(java.lang.String openLineageDescription)
        Set up the short description of the Open Lineage.
        Parameters:
        openLineageDescription - String description
      • getLineageServerURL

        public java.lang.String getLineageServerURL()
        Return the URL for the Lineage Server used in the Governance Server Connector
        Returns:
        String URL
      • setLineageServerURL

        public void setLineageServerURL​(java.lang.String lineageServerURL)
        Set up the URL for the Lineage Server used in the Governance Server Connector.
        Parameters:
        lineageServerURL - String for Governance Server URL
      • getInTopicConnection

        public Connection getInTopicConnection()
        Return the OCF Connection for the In Topic used to pass requests to this Open Lineage. For example, the output topic of Governance Engine OMAS can be provided (e.g. "open-metadata.access-services.GovernanceEngine.outTopic")
        Returns:
        Connection for In Topic
      • setInTopicConnection

        public void setInTopicConnection​(Connection inTopicConnection)
        Set up the OCF Connection for the Out Topic used to pass requests to this Open Lineage.
        Parameters:
        inTopicConnection - Connection for In Topic
      • getLineageGraphConnection

        public Connection getLineageGraphConnection()
        Return the Connection for LineageGraph that will be used for Open Lineage
        Returns:
        Connection for lineageGraph
      • setLineageGraphConnection

        public void setLineageGraphConnection​(Connection lineageGraphConnection)
        Set up the Open Lineage Graph Connection
        Parameters:
        lineageGraphConnection - Connection for LineageGraph
      • getJobIntervalInSeconds

        public int getJobIntervalInSeconds()
        Returns:
        Interval for Open Lineage Services background processing job
      • setJobIntervalInSeconds

        public void setJobIntervalInSeconds​(int jobIntervalInSeconds)
        Parameters:
        jobIntervalInSeconds - Interval to be used by Open Lineage Services background processing job
      • setAccessServiceConfig

        public void setAccessServiceConfig​(OLSSimplifiedAccessServiceConfig accessServiceConfig)
        Sets access service config.
        Parameters:
        accessServiceConfig - the access service config
      • getBackgroundJobs

        public java.util.List<OLSBackgroundJob> getBackgroundJobs()
        Gets background jobs.
        Returns:
        the background jobs
      • setBackgroundJobs

        public void setBackgroundJobs​(java.util.List<OLSBackgroundJob> backgroundJobs)
        Sets background jobs.
        Parameters:
        backgroundJobs - the background jobs
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object