Skip to content

Commit 32cd225

Browse files
committed
[FLINK-38839][runtime] Add overloaded methods for backward compatibility
Add overloaded addTransform methods without tableOptionsDelimiter parameter to maintain backward compatibility with existing code that uses the old API.
1 parent 3236075 commit 32cd225

2 files changed

Lines changed: 42 additions & 0 deletions

File tree

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorBuilder.java

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,27 @@ public class PostTransformOperatorBuilder {
3535
private final List<Tuple3<String, String, Map<String, String>>> udfFunctions =
3636
new ArrayList<>();
3737

38+
public PostTransformOperatorBuilder addTransform(
39+
String tableInclusions,
40+
@Nullable String projection,
41+
@Nullable String filter,
42+
String primaryKey,
43+
String partitionKey,
44+
String tableOptions,
45+
String postTransformConverter,
46+
SupportedMetadataColumn[] supportedMetadataColumns) {
47+
return addTransform(
48+
tableInclusions,
49+
projection,
50+
filter,
51+
primaryKey,
52+
partitionKey,
53+
tableOptions,
54+
null,
55+
postTransformConverter,
56+
supportedMetadataColumns);
57+
}
58+
3859
public PostTransformOperatorBuilder addTransform(
3960
String tableInclusions,
4061
@Nullable String projection,

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperatorBuilder.java

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,27 @@ public PreTransformOperatorBuilder addTransform(
4949
return this;
5050
}
5151

52+
public PreTransformOperatorBuilder addTransform(
53+
String tableInclusions,
54+
@Nullable String projection,
55+
@Nullable String filter,
56+
String primaryKey,
57+
String partitionKey,
58+
String tableOption,
59+
@Nullable String postTransformConverter,
60+
SupportedMetadataColumn[] supportedMetadataColumns) {
61+
return addTransform(
62+
tableInclusions,
63+
projection,
64+
filter,
65+
primaryKey,
66+
partitionKey,
67+
tableOption,
68+
null,
69+
postTransformConverter,
70+
supportedMetadataColumns);
71+
}
72+
5273
public PreTransformOperatorBuilder addTransform(
5374
String tableInclusions,
5475
@Nullable String projection,

0 commit comments

Comments
 (0)