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>

Constructor Summary

Constructors

Constructor	Description
KinesisConfig()
KinesisConfig(String streamName, String region, String roleArn, Properties properties)

Method Summary

Modifier and Type	Method	Description
Properties	getProperties()
String	getRegion()
String	getRoleArn()
String	getStreamName()
KinesisConfig	mergeWithNonNull(KinesisConfig other)	Method to create new config class based on current instance and non-null argument value.
void	setProperties(Properties properties)
void	setRegion(String region)
void	setRoleArn(String roleArn)
void	setStreamName(String streamName)
String	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

Constructor Details

KinesisConfig

public KinesisConfig()

KinesisConfig

public KinesisConfig(String streamName,
 String region,
 String roleArn,
 Properties properties)

Method Details

mergeWithNonNull

public KinesisConfig mergeWithNonNull(KinesisConfig other)

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 interface MergeConfig<KinesisConfig>

Parameters:

other - overwrite value

Returns:

merged config entry

toString

public String toString()

Overrides:

toString in class Object

getStreamName

public String getStreamName()

setStreamName

public void setStreamName(String streamName)

getRegion

public String getRegion()

setRegion

public void setRegion(String region)

getRoleArn

public String getRoleArn()

setRoleArn

public void setRoleArn(String roleArn)

getProperties

public Properties getProperties()

setProperties

public void setProperties(Properties properties)