r - ユーザー定義の集計関数に関する問題

Question

集計関数を定義するときに問題が発生します。再現可能な例を次に示します。

library(MonetDBLite)
library(dplyr)
library(DBI)

dbdir <- tempdir()
con <- dbConnect(MonetDBLite())
dbWriteTable(con, "mtcars", mtcars, overwrite = TRUE)
ms <- src_monetdblite(dbdir)
mt <- tbl(ms, "mtcars")

dbSendUpdate(con, "CREATE AGGREGATE rapi04(val DOUBLE) RETURNS DOUBLE LANGUAGE R {
    aggregate(val, by=list(aggr_group), FUN=median)$x
};")

mt %>% group_by(carb) %>% summarise(rapi04(wt))

このコードを実行すると、次のエラーが発生します。

Error in .local(conn, statement, ...) : 
  Unable to execute statement 'SELECT *
FROM (SELECT "carb", RAPI04("wt")
FROM (SELECT * FROM "mtcars") AS "_W3"
GROUP BY "carb") A...'.
Server says 'SQLException:SQLparser:Errors encountered in query'.

要約ステートメントで MonetDB の中央値関数を使用すると完全に機能しますが、関数を定義すると機能しません。MonetDBLite内で集計関数を定義する正しい方法は何ですか?