Class SourceDef
- java.lang.Object
-
- org.apache.flink.cdc.composer.definition.SourceDef
-
public class SourceDef extends Object
Definition of a data source.A source definition contains:
- type: connector type of the source, which will be used for discovering source implementation. Required in the definition.
- name: name of the source. Optional in the definition.
- config: configuration of the source
-
-
Constructor Summary
Constructors Constructor Description SourceDef(String type, String name, Configuration config)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)ConfigurationgetConfig()Optional<String>getName()StringgetType()inthashCode()StringtoString()
-
-
-
Constructor Detail
-
SourceDef
public SourceDef(String type, @Nullable String name, Configuration config)
-
-
Method Detail
-
getType
public String getType()
-
getConfig
public Configuration getConfig()
-
-