Skip to content

Latest commit

 

History

History
44 lines (33 loc) · 1.12 KB

README.md

File metadata and controls

44 lines (33 loc) · 1.12 KB
Raw

Hive UDFs

UDFs

  • Aggregate UDF
Finds MIN, MAX and SUM from array of Struct Objects based on a field.
  • Sort UDF
Returns sorted array of Struct objects for an array of Struct Objects based on a field.
  • Date UDF (for Lookup on Date dimension, Data Warehousing concept)
Returns date key field, e.g. __FUNC__('2014-04-05T01:30:34Z') ISO 8601 format, __FUNC__('2014-04-05 01:30:34') and __FUNC__(UNIX_TIMESTAMP('2014-04-05 01:30:34'))  returns 20140405
  • Time UDF (for Lookup on Time dimension, Data Warehousing concept)
Returns date key field, e.g. __FUNC__('2014-04-05T01:30:34Z') ISO 8601 format, __FUNC__('2014-04-05 01:30:34') and __FUNC__(UNIX_TIMESTAMP('2014-04-05 01:30:34'))  returns 130
  • Contains UDF
__FUNC__(List<String>, String)
returns true or false accordingly.

Usage and execution:

$ mvn package assembly:single
$ hive
hive> ADD JAR /path/to/hiveUDF-1.0-SNAPSHOT-jar-with-dependencies.jar;
hive> CREATE TEMPORARY FUNCTION addHello as 'in.debjyotipaul.udf.HiveUDFSimpleSample';
hive> SELECT addHello(name) from table;