[
https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895498#comment-15895498
]
ASF GitHub Bot commented on FLINK-5833:
---------------------------------------
GitHub user clarkyzl opened a pull request:
https://github.com/apache/flink/pull/3473
[FLINK-5833] [table] Support for Hive GenericUDF
Type: New Feature
Priority: Major
Components: table, udf
Problem definition: Make Flink call Hive User-Defined Functions, support
for simple hive Generic UDFs.
Design:
1. This patch is based on FLINK-5881 and FLINK-5832, we need variable
arguments to call hive udfs. We also need a HiveFunctionWrapper in FLINK-5832
to create Hive Generic UDFs.
1. Added a ScalarFunction called HiveGenericUDF to call Hive Generic UDFs.
Use primitive java object inspectors for the generic UDFs.
1. Moved the code to flink-hcatalog
Impact Analysis:
A new feature, had few impacts on exsting features. We updated hcatalog
dependencies from 0.12.0 to 0.13.0.
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 flink-5833
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3473.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 #3473
----
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
commit 97968fb86af105f0fc8b68e8083998dd0725deef
Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com>
Date: 2017-03-02T09:16:03Z
[FLINK-5832] [table] remove useless name variable and add more tests
commit 40ed7db039b86a5f39fc157fa36d8b55bf6f2bd4
Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com>
Date: 2017-03-03T08:15:30Z
[FLINK-5832] [table] move all the code to flink-hcatalog
commit 21f4c69e962ea8e4ca9083be4a6837dfa84df1cd
Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com>
Date: 2017-03-03T08:59:05Z
[FLINK-5832] [table] Remove newer version of hive udfs which does not exist
in flink-hcatalog
commit c86effa5cc9b23c7d058f7d01bf8f539c539a116
Author: Zhuoluo Yang <zhuoluo....@alibaba-inc.com>
Date: 2017-03-04T03:55:34Z
[FLINK-5833] [table] Support for Hive GenericUDF
----
> Support for Hive GenericUDF
> ---------------------------
>
> Key: FLINK-5833
> URL: https://issues.apache.org/jira/browse/FLINK-5833
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: Zhuoluo Yang
> Assignee: Zhuoluo Yang
>
> The second step of FLINK-5802 is to support Hive's GenericUDF.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
