Package io.openlineage.client.transports
Class CompositeConfig
java.lang.Object
io.openlineage.client.transports.CompositeConfig
- All Implemented Interfaces:
MergeConfig<CompositeConfig>
,TransportConfig
public final class CompositeConfig
extends Object
implements TransportConfig, MergeConfig<CompositeConfig>
CompositeConfig is a configuration class for CompositeTransport, implementing TransportConfig.
-
Field Summary
Fields inherited from interface io.openlineage.client.transports.TransportConfig
nameRegistry
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic CompositeConfig
createFromTransportConfigs
(List<TransportConfig> transports, boolean continueOnFailure) boolean
mergeWithNonNull
(CompositeConfig other) Method to create new config class based on current instance and non-null argument value.void
setContinueOnFailure
(boolean continueOnFailure) void
setTransports
(List<TransportConfig> transports) toString()
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface io.openlineage.client.MergeConfig
mergePropertyWith, mergePropertyWith, mergeWith, mergeWithDefaultValue
Methods inherited from interface io.openlineage.client.transports.TransportConfig
getName, setName
-
Constructor Details
-
CompositeConfig
-
CompositeConfig
public CompositeConfig()
-
-
Method Details
-
createFromTransportConfigs
public static CompositeConfig createFromTransportConfigs(List<TransportConfig> transports, boolean continueOnFailure) -
mergeWithNonNull
Description copied from interface:MergeConfig
Method to create new config class based on current instance and non-null argument value. In most cases, implementation needs to create a new instance of T, while merging all the properties.- Specified by:
mergeWithNonNull
in interfaceMergeConfig<CompositeConfig>
- Parameters:
other
- overwrite value- Returns:
- merged config entry
-
toString
-
getTransports
-
setTransports
-
isContinueOnFailure
public boolean isContinueOnFailure() -
setContinueOnFailure
public void setContinueOnFailure(boolean continueOnFailure)
-