raminqaf commented on code in PR #27901:
URL: https://github.com/apache/flink/pull/27901#discussion_r3058519380
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java:
##########
@@ -84,7 +86,8 @@ private BuiltInFunctionDefinition(
boolean isDeterministic,
boolean isRuntimeProvided,
String runtimeClass,
- boolean isInternal) {
+ boolean isInternal,
+ @Nullable ChangelogFunction changelogFunction) {
Review Comment:
I have added a new `changelogModeResolver` that takes in a Function with the
`CallContext` and outputs a `ChangelogMode`
```java
/**
* Sets a resolver that dynamically determines the output {@link
ChangelogMode} for this
* built-in PTF. The resolver receives the {@link CallContext} and can
inspect function
* arguments (e.g., op_mapping) to adapt the changelog mode. Only needed for
PTFs that emit
* updates (e.g., FROM_CHANGELOG).
*/
public Builder changelogModeResolver(
Function<CallContext, ChangelogMode> changelogModeResolver) {
this.changelogModeResolver = changelogModeResolver;
return this;
}
```
--
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]
