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 java.lang.Object
implements TransportConfig, MergeConfig<KinesisConfig>

Constructor Summary

Constructors

Constructor	Description
KinesisConfig()
KinesisConfig(java.lang.String streamName, java.lang.String region, java.lang.String roleArn, java.util.Properties properties)

Method Summary

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

KinesisConfig

public KinesisConfig()

KinesisConfig

public KinesisConfig(java.lang.String streamName,
                     java.lang.String region,
                     java.lang.String roleArn,
                     java.util.Properties properties)

Method Detail

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 java.lang.String toString()

Overrides:

toString in class java.lang.Object

getStreamName

public java.lang.String getStreamName()

setStreamName

public void setStreamName(java.lang.String streamName)

getRegion

public java.lang.String getRegion()

setRegion

public void setRegion(java.lang.String region)

getRoleArn

public java.lang.String getRoleArn()

setRoleArn

public void setRoleArn(java.lang.String roleArn)

getProperties

public java.util.Properties getProperties()

setProperties

public void setProperties(java.util.Properties properties)