Package org.apache.flink.cdc.composer.definition

Class SinkDef

java.lang.Object

org.apache.flink.cdc.composer.definition.SinkDef

public class SinkDef
extends Object

Definition of a data sink.

A sink definition contains:

• type: connector type of the sink, which will be used for discovering sink implementation. Required in the definition.
• name: name of the sink. Optional in the definition.
• config: configuration of the sink

Constructor Summary

Constructors

Constructor	Description
SinkDef(String type, String name, Configuration config)
SinkDef(String type, String name, Configuration config, Set<SchemaChangeEventType> includedSchemaEvolutionTypes)
SinkDef(String type, String name, Configuration config, Set<SchemaChangeEventType> includedSchemaEvolutionTypes, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Configuration	getConfig()
ExistingTableSchemaExpansionMode	getExistingTableSchemaExpansionMode()
Set<SchemaChangeEventType>	getIncludedSchemaEvolutionTypes()
Optional<String>	getName()
String	getType()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SinkDef

public SinkDef(String type,
               @Nullable
               String name,
               Configuration config)

SinkDef

public SinkDef(String type,
               @Nullable
               String name,
               Configuration config,
               Set<SchemaChangeEventType> includedSchemaEvolutionTypes)

SinkDef

public SinkDef(String type,
               @Nullable
               String name,
               Configuration config,
               Set<SchemaChangeEventType> includedSchemaEvolutionTypes,
               ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode)

Method Detail

getType

public String getType()

getName

public Optional<String> getName()

getConfig

public Configuration getConfig()

getIncludedSchemaEvolutionTypes

public Set<SchemaChangeEventType> getIncludedSchemaEvolutionTypes()

getExistingTableSchemaExpansionMode

public ExistingTableSchemaExpansionMode getExistingTableSchemaExpansionMode()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object