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 connection object for the in topic as defined in the server configuration
        Returns:
        Connection object for the in topic as defined in the server configuration
      • setInTopicConnection

        public void setInTopicConnection​(Connection inTopicConnection)
        Sets Connection override object in the server configuration
        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