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

Class TransformDef

java.lang.Object

org.apache.flink.cdc.composer.definition.TransformDef

public class TransformDef
extends Object

Definition of a transformation.

A transformation definition contains:

• sourceTable: a regex pattern for matching input table IDs. Required for the definition.
• projection: a string for projecting the row of matched table as output. Optional for the definition.
• filter: a string for filtering the row of matched table as output. Optional for the definition.
• primaryKeys: a string for primary key columns for matching input table IDs, separated by `,`. Optional for the definition.
• partitionKeys: a string for partition key columns for matching input table IDs, separated by `,`. Optional for the definition.
• tableOptions: a string for table options for matching input table IDs, options are separated by `,`, key and value are separated by `=`. Optional for the definition.
• tableOptionsDelimiter: a string for delimiter of table options, default is `,`. Optional for the definition.
• description: description for the transformation. Optional for the definition.

Constructor Summary

Constructors

Constructor	Description
TransformDef(String sourceTable, String projection, String filter, String primaryKeys, String partitionKeys, String tableOptions, String description, String postTransformConverter)
TransformDef(String sourceTable, String projection, String filter, String primaryKeys, String partitionKeys, String tableOptions, String tableOptionsDelimiter, String description, String postTransformConverter)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getDescription()
String	getFilter()
String	getPartitionKeys()
String	getPostTransformConverter()
String	getPrimaryKeys()
String	getProjection()
String	getSourceTable()
String	getTableOptions()
String	getTableOptionsDelimiter()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformDef

public TransformDef(String sourceTable,
                    String projection,
                    String filter,
                    String primaryKeys,
                    String partitionKeys,
                    String tableOptions,
                    String tableOptionsDelimiter,
                    String description,
                    String postTransformConverter)

TransformDef

public TransformDef(String sourceTable,
                    String projection,
                    String filter,
                    String primaryKeys,
                    String partitionKeys,
                    String tableOptions,
                    String description,
                    String postTransformConverter)

Method Detail

getSourceTable

public String getSourceTable()

getProjection

public String getProjection()

getFilter

public String getFilter()

getDescription

public String getDescription()

getPrimaryKeys

public String getPrimaryKeys()

getPartitionKeys

public String getPartitionKeys()

getTableOptions

public String getTableOptions()

getTableOptionsDelimiter

public String getTableOptionsDelimiter()

getPostTransformConverter

public String getPostTransformConverter()

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