Package org.odpi.openmetadata.governanceservers.openlineage.scheduler

Class AssetLineageUpdateJobConfiguration

java.lang.Object

org.odpi.openmetadata.governanceservers.openlineage.scheduler.JobConfiguration

org.odpi.openmetadata.governanceservers.openlineage.scheduler.AssetLineageUpdateJobConfiguration

public class AssetLineageUpdateJobConfiguration
extends JobConfiguration

Using the JobConfiguration as parent, this class adds more elements to the data map of the job: the asset lineage client and the server where it runs, the local user ID.

Constructor Summary

Constructors

Constructor	Description
AssetLineageUpdateJobConfiguration(OpenLineageGraphConnector openLineageGraphConnector, String jobName, Class<? extends org.quartz.Job> jobClass, int jobInterval, String configAssetLineageUpdateTime, AssetLineage assetLineageClient, String serverName, String localServerUserId)	Instantiates a new Asset lineage update job configuration.

Method Summary

Methods inherited from class org.odpi.openmetadata.governanceservers.openlineage.scheduler.JobConfiguration

schedule, stop

Methods inherited from class java.lang.Object

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

Constructor Details

AssetLineageUpdateJobConfiguration

public AssetLineageUpdateJobConfiguration(OpenLineageGraphConnector openLineageGraphConnector,
 String jobName,
 Class<? extends org.quartz.Job> jobClass,
 int jobInterval,
 String configAssetLineageUpdateTime,
 AssetLineage assetLineageClient,
 String serverName,
 String localServerUserId)

Instantiates a new Asset lineage update job configuration.

Parameters:

openLineageGraphConnector - the lineage graph used to store the job's last run time

jobName - the job name

jobClass - the job class

jobInterval - the job interval

assetLineageClient - the Asset Lineage client

serverName - the server name where Asset Lineage OMAS runs

localServerUserId - the local server user ID