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

Class PipelineDef

java.lang.Object

org.apache.flink.cdc.composer.definition.PipelineDef

public class PipelineDef
extends Object

Definition of a pipeline.

A pipeline consists of following components:

• Source: data source of the pipeline. Required in the definition.
• Sink: data destination of the pipeline. Required in the definition.
• Routes: routers specifying the connection between source tables and sink tables. Optional in the definition.
• Transforms: transformations for applying modifications to data change events. Optional in the definition.
• Config: configurations of the pipeline. Optional in the definition.

This class keeps track of the raw pipeline definition made by users via pipeline definition file. A definition will be translated to a PipelineExecution by PipelineComposer before being submitted to the computing engine.

Constructor Summary

Constructors

Constructor	Description
PipelineDef(SourceDef source, SinkDef sink, List<RouteDef> routes, List<TransformDef> transforms, List<UdfDef> udfs, List<ModelDef> models, Configuration config)
PipelineDef(SourceDef source, SinkDef sink, List<RouteDef> routes, List<TransformDef> transforms, List<UdfDef> udfs, Configuration config)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Configuration	getConfig()
List<ModelDef>	getModels()
List<RouteDef>	getRoute()
RouteMode	getRouteMode()
SinkDef	getSink()
SourceDef	getSource()
List<TransformDef>	getTransforms()
List<UdfDef>	getUdfs()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

PipelineDef

public PipelineDef(SourceDef source,
                   SinkDef sink,
                   List<RouteDef> routes,
                   List<TransformDef> transforms,
                   List<UdfDef> udfs,
                   List<ModelDef> models,
                   Configuration config)

PipelineDef

public PipelineDef(SourceDef source,
                   SinkDef sink,
                   List<RouteDef> routes,
                   List<TransformDef> transforms,
                   List<UdfDef> udfs,
                   Configuration config)

Method Detail

getSource

public SourceDef getSource()

getSink

public SinkDef getSink()

getRoute

public List<RouteDef> getRoute()

getRouteMode

public RouteMode getRouteMode()

getTransforms

public List<TransformDef> getTransforms()

getUdfs

public List<UdfDef> getUdfs()

getModels

public List<ModelDef> getModels()

getConfig

public Configuration getConfig()

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