leonardBang commented on code in PR #3468:
URL: https://github.com/apache/flink-cdc/pull/3468#discussion_r1679191168
##########
docs/content.zh/docs/core-concept/transform.md:
##########
@@ -47,11 +47,12 @@ Multiple rules can be declared in one single pipeline YAML
file.
## Fields definition
There are some hidden columns used to access metadata information. They will
only take effect when explicitly referenced in the transform rules.
-| Field | Data Type | Description
|
+| Field | Data Type | Description
|
|--------------------|-----------|----------------------------------------------|
| __namespace_name__ | String | Name of the namespace that contains the
row. |
| __schema_name__ | String | Name of the schema that contains the row.
|
| __table_name__ | String | Name of the table that contains the row.
|
+| __row_kind__ | String | Operation type of data change event.
|
Review Comment:
how about about `__data_event_type__` because `Event` is a user-facing
concept ?
We may extend `__schema_event_type__` in the future
##########
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java:
##########
@@ -77,6 +77,7 @@ public class TransformParser {
public static final String DEFAULT_NAMESPACE_NAME = "__namespace_name__";
public static final String DEFAULT_SCHEMA_NAME = "__schema_name__";
public static final String DEFAULT_TABLE_NAME = "__table_name__";
+ public static final String DEFAULT_ROW_KIND = "__row_kind__";
Review Comment:
```suggestion
public static final String DEFAULT_DATA_EVENT_TYPE =
"__data_event_type__";
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
