New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-3097] [table] Add support for custom functions in Table API #2265
Conversation
Do we have any google docs or FLIP talking about this design ? I think the |
No, there is no FLIP about it. I think a discussion in JIRA or in this PR should be enough. That's why I haven't documented it yet, still open for changes. I was inspired by your document. You are right, |
Yes, you are right. I'm just a little concerned about the class name of In addition, Java Table API should be |
Yes, @wuchong's suggestion for the Java Table API seems more extensible. |
I was also thinking a lot about the names, because we have currently many If you have a look into the tests you will see that the Java API supports both: postfix and infix notation. So you can also call functions |
Ah ok, thats perfect! (about infix and postfix) |
Yes, I see. That's great! |
Merging... |
Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the How To Contribute guide.
In addition to going through the list, please provide a meaningful description of your changes.
mvn clean verify
has been executed successfully locally or a Travis build has passedThis PR introduces user-defined scalar functions for the Table and SQL API.
I will add documentation soon, but this is the general syntax so far:
In Java:
In Scala: