From 96e24e01b78dd241e2085fcf79d8d9fc9031be4b Mon Sep 17 00:00:00 2001 From: Pratham Date: Thu, 18 Jul 2024 21:37:45 -0400 Subject: [PATCH] Add function in static hive registry (#519) --- .../hive/hive2rel/functions/StaticHiveFunctionRegistry.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/coral-hive/src/main/java/com/linkedin/coral/hive/hive2rel/functions/StaticHiveFunctionRegistry.java b/coral-hive/src/main/java/com/linkedin/coral/hive/hive2rel/functions/StaticHiveFunctionRegistry.java index 95eeceed5..c7029f035 100644 --- a/coral-hive/src/main/java/com/linkedin/coral/hive/hive2rel/functions/StaticHiveFunctionRegistry.java +++ b/coral-hive/src/main/java/com/linkedin/coral/hive/hive2rel/functions/StaticHiveFunctionRegistry.java @@ -679,6 +679,8 @@ public boolean isOptional(int i) { family(SqlTypeFamily.BOOLEAN, SqlTypeFamily.ANY, SqlTypeFamily.STRING, SqlTypeFamily.ANY)); createAddUserDefinedFunction("com.linkedin.groot.runtime.udf.spark.RedactSecondarySchemaFieldIfUDF", ARG1, family( SqlTypeFamily.BOOLEAN, SqlTypeFamily.ANY, SqlTypeFamily.ARRAY, SqlTypeFamily.STRING, SqlTypeFamily.STRING)); + createAddUserDefinedFunction("com.linkedin.groot.runtime.udf.spark.GetMappedValueUDF", FunctionReturnTypes.STRING, + family(SqlTypeFamily.STRING, SqlTypeFamily.STRING)); // UDTFs addFunctionEntry("explode", new CoralSqlUnnestOperator(false));