Package io.openlineage.client

Class OpenLineageConfig<T extends OpenLineageConfig>

java.lang.Object

io.openlineage.client.OpenLineageConfig<T>

Type Parameters:

T - generic type extending OpenLineageConfig, used for merging config objects

All Implemented Interfaces:

MergeConfig<T>

public class OpenLineageConfig<T extends OpenLineageConfig>
extends Object
implements MergeConfig<T>

Configuration for OpenLineageClient.

Field Summary

Fields

Modifier and Type	Field	Description
protected CircuitBreakerConfig	circuitBreaker
protected DatasetConfig	datasetConfig
protected FacetsConfig	facetsConfig
protected JobConfig	jobConfig
protected Map<String,Object>	metricsConfig
protected RunConfig	runConfig
protected TransportConfig	transportConfig

Constructor Summary

Constructors

Constructor	Description
OpenLineageConfig()
OpenLineageConfig(TransportConfig transportConfig, FacetsConfig facetsConfig, DatasetConfig datasetConfig, CircuitBreakerConfig circuitBreaker, Map<String,Object> metricsConfig, RunConfig runConfig, JobConfig jobConfig)

Method Summary

Modifier and Type	Method	Description
CircuitBreakerConfig	getCircuitBreaker()
DatasetConfig	getDatasetConfig()
FacetsConfig	getFacetsConfig()
JobConfig	getJobConfig()
Map<String,Object>	getMetricsConfig()
RunConfig	getRunConfig()
TransportConfig	getTransportConfig()
OpenLineageConfig	mergeWithNonNull(OpenLineageConfig other)	Overwrites existing object with properties of other config entries whenever they're present.
void	setCircuitBreaker(CircuitBreakerConfig circuitBreaker)
void	setDatasetConfig(DatasetConfig datasetConfig)
void	setFacetsConfig(FacetsConfig facetsConfig)
void	setJobConfig(JobConfig jobConfig)
void	setMetricsConfig(Map<String,Object> metricsConfig)
void	setRunConfig(RunConfig runConfig)
void	setTransportConfig(TransportConfig transportConfig)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.openlineage.client.MergeConfig

mergePropertyWith, mergePropertyWith, mergeWith, mergeWithDefaultValue

Field Details

transportConfig

protected TransportConfig transportConfig

facetsConfig

protected FacetsConfig facetsConfig

datasetConfig

protected DatasetConfig datasetConfig

circuitBreaker

protected CircuitBreakerConfig circuitBreaker

metricsConfig

protected Map<String,Object> metricsConfig

runConfig

protected RunConfig runConfig

jobConfig

protected JobConfig jobConfig

Constructor Details

OpenLineageConfig

public OpenLineageConfig()

OpenLineageConfig

public OpenLineageConfig(TransportConfig transportConfig,
 FacetsConfig facetsConfig,
 DatasetConfig datasetConfig,
 CircuitBreakerConfig circuitBreaker,
 Map<String,Object> metricsConfig,
 RunConfig runConfig,
 JobConfig jobConfig)

Method Details

mergeWithNonNull

public OpenLineageConfig mergeWithNonNull(OpenLineageConfig other)

Overwrites existing object with properties of other config entries whenever they're present.

Specified by:

mergeWithNonNull in interface MergeConfig<T extends OpenLineageConfig>

Parameters:

other - value to merge

Returns:

merged config entry

getTransportConfig

public TransportConfig getTransportConfig()

getFacetsConfig

public FacetsConfig getFacetsConfig()

getDatasetConfig

public DatasetConfig getDatasetConfig()

getCircuitBreaker

public CircuitBreakerConfig getCircuitBreaker()

getMetricsConfig

public Map<String,Object> getMetricsConfig()

getRunConfig

public RunConfig getRunConfig()

getJobConfig

public JobConfig getJobConfig()

setTransportConfig

public void setTransportConfig(TransportConfig transportConfig)

setFacetsConfig

public void setFacetsConfig(FacetsConfig facetsConfig)

setDatasetConfig

public void setDatasetConfig(DatasetConfig datasetConfig)

setCircuitBreaker

public void setCircuitBreaker(CircuitBreakerConfig circuitBreaker)

setMetricsConfig

public void setMetricsConfig(Map<String,Object> metricsConfig)

setRunConfig

public void setRunConfig(RunConfig runConfig)

setJobConfig

public void setJobConfig(JobConfig jobConfig)