raminqaf commented on code in PR #27901:
URL: https://github.com/apache/flink/pull/27901#discussion_r3071339699
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java:
##########
Review Comment:
Reduced the scope of the interface and now we have a method named
`getArgumentValue` in `ChangelogContext` similar to `CallContext`
```java
/**
* Returns the value of a scalar argument at the given position.
*
* @param pos the argument position
* @param clazz the expected class of the argument value
* @return the argument value, or empty if the argument is null or
not available
*/
<T> Optional<T> getArgumentValue(int pos, Class<T> clazz);
```
--
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]
