Package io.openlineage.client.transports
Class KinesisConfig
java.lang.Object
io.openlineage.client.transports.KinesisConfig
- All Implemented Interfaces:
MergeConfig<KinesisConfig>
,TransportConfig
public final class KinesisConfig
extends Object
implements TransportConfig, MergeConfig<KinesisConfig>
-
Field Summary
Fields inherited from interface io.openlineage.client.transports.TransportConfig
nameRegistry
-
Constructor Summary
ConstructorDescriptionKinesisConfig
(String streamName, String region, String roleArn, Properties properties) -
Method Summary
Modifier and TypeMethodDescriptionmergeWithNonNull
(KinesisConfig other) Method to create new config class based on current instance and non-null argument value.void
setProperties
(Properties properties) void
void
setRoleArn
(String roleArn) void
setStreamName
(String streamName) 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
-
KinesisConfig
public KinesisConfig() -
KinesisConfig
-
-
Method Details
-
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<KinesisConfig>
- Parameters:
other
- overwrite value- Returns:
- merged config entry
-
toString
-
getStreamName
-
setStreamName
-
getRegion
-
setRegion
-
getRoleArn
-
setRoleArn
-
getProperties
-
setProperties
-