[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891782#comment-15891782 ]
ASF GitHub Bot commented on FLINK-5832: --------------------------------------- GitHub user clarkyzl opened a pull request: https://github.com/apache/flink/pull/3456 [FLINK-5832] [table] Support for simple hive UDF Type: New Feature Priority: Major Components: table, udf, hive Problem definition: Make Flink call Hive User-Defined Functions, support for simple hive UDFs. Design: 1. This patch is based on FLINK-5881, we need variable arguments to call hive udfs. 2. Added a HiveFunctionWrapper to create Hive simple UDFs. 3. Added a ScalarFunction called HiveSimpleUDF to call Hive Simple UDFs. Use primitive java object inspectors for the simple UDFs. 4. A few modification of type comparation, make type of Object equal any types. 5. Added a new method in TableEnvironment to rigister hive UDFs. Impact Analysis: A new feature, had few impacts on exsting features, except for the comparation of types. Test: `mvn clean verify` is done on local. You can merge this pull request into a Git repository by running: $ git pull https://github.com/clarkyzl/flink udf Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3456.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 #3456 ---- commit 60b68fdd66f8021f6f090e7372987d43362d5ef3 Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-02-22T10:53:34Z [FLINK-5881] [table] ScalarFunction(UDF) should support variable types and variable arguments commit fe81a7d87d2620d19e5dd0fa569f139569b6c2aa Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-02-23T11:29:37Z [FLINK-5881] [table] Modification as reviews commit 21f8a4ec40a12828e59ff959b56d92c2c2629afd Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-02-20T06:04:12Z [FLINK-5832] [table] Support for simple hive UDF commit d734867874169ffd23f084fbdd7f8605208f2b37 Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-02-27T05:24:33Z [FLINK-5832] [table] Delete test code commit 3b345f7d19054b7cbb961498d3f817fcaae128b5 Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-02-28T07:54:39Z [FLINK-5832] [table] Use scala to implement HiveSimpleUDF commit 8838965d0add8ae1e47d216909e20ccd3d7fcd17 Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-02-28T07:56:36Z [FLINK-5832] [table] Remove unlicensed files commit 260bf3b302e5753845ed30fe89b1516121bc3562 Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-02-28T09:22:01Z [FLINK-5832] [table] match the signature, varargs commit fcda8546509cb755e101ef21a12b905f97cadf72 Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-03-01T07:30:15Z [FLINK-5881] [table] Modification as Jark's two comments commit 1eca2a511de8eeb734f029887f2e0831f9092a7b Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-03-01T08:13:40Z Merge branch 'flink-5881' into udf commit 13b2039fcc8785b3b27a3d1537daec1c69aec944 Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-03-01T10:40:58Z [FLINK-5832] [table] still needs some ois commit 80123fe9f82c989f74ec1d5194bc1609cfd207aa Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-03-02T03:28:38Z [FLINK-5832] [table] Use FunctionRegistry to call HiveSimpleUDFs commit b1cb548aa9f89f1ceef896bd8583a65054190795 Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com> Date: 2017-03-02T08:00:31Z [FLINK-5832] [table] Use PrimitiveObjectInspectors and add some unit tests ---- > Support for simple hive UDF > --------------------------- > > Key: FLINK-5832 > URL: https://issues.apache.org/jira/browse/FLINK-5832 > Project: Flink > Issue Type: Sub-task > Components: Table API & SQL > Reporter: Zhuoluo Yang > Assignee: Zhuoluo Yang > > The first step of FLINK-5802 is to support simple Hive UDF. -- This message was sent by Atlassian JIRA (v6.3.15#6346)