beyond1920 commented on a change in pull request #17761:
URL: https://github.com/apache/flink/pull/17761#discussion_r770184306
##########
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java
##########
@@ -635,6 +636,35 @@ public void testTemporaryFunction() throws Exception {
tableEnv.executeSql("drop temporary function if exists foo");
}
+ @Test
+ public void testTemporaryFunctionUDAF() throws Exception {
+ // create temp function
+ tableEnv.executeSql(
+ String.format(
+ "create temporary function temp_count as '%s'",
+ GenericUDAFCount.class.getName()));
+ String[] functions = tableEnv.listUserDefinedFunctions();
+ assertArrayEquals(new String[] {"temp_count"}, functions);
+ // call the function
+ tableEnv.executeSql("create table src(x int)");
+ tableEnv.executeSql("insert into src values (1),(-1)").await();
+ assertEquals(
+ "[+I[2]]",
+ queryResult(tableEnv.sqlQuery("select temp_count(x) from
src")).toString());
+ // switch DB and the temp function can still be used
+ tableEnv.executeSql("create database db1");
+ tableEnv.useDatabase("db1");
+ assertEquals(
+ "[+I[2]]",
+ queryResult(tableEnv.sqlQuery("select temp_count(x) from
`default`.src"))
+ .toString());
+ // drop the function
+ tableEnv.executeSql("drop temporary function temp_count");
+ functions = tableEnv.listUserDefinedFunctions();
+ assertEquals(0, functions.length);
+ tableEnv.executeSql("drop temporary function if exists foo");
Review comment:
> drop temporary function if exists foo
The line seems to be not necessary.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
