GitHub user godfreyhe opened a pull request:
https://github.com/apache/flink/pull/3176
[FLINK-5571] [table] add open and close methods for UserDefinedFunction
Currently, a User Defined Function (UDF) in table API & SQL works on zero,
one, or multiple values in custom evaluation method. Many UDFs need more
complex features, e.g. report metrics, get parameters from job configuration,
or get extra data from distribute cache file, etc. Adding open and close
methods in UserDefinedFunction class can solve this problem.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/godfreyhe/flink udf-open-close
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3176.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3176
----
commit 4ac2be7b3ab4dc0e8a18e43c79a031d7a16ee1ea
Author: godfreyhe <[email protected]>
Date: 2017-01-20T06:42:12Z
add open and close methods for UserDefinedFunction
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
