rhive.aggregate {RHive} | R Documentation |
R Distributed aggregate function using HQL
rhive.aggregate(tableName, hiveFUN, ..., groups=NULL, forcedRef=TRUE)
tableName |
hive table name. |
hiveFUN |
the hive buit-in function name to be applied. |
... |
optional arguments to 'hiveFUN'. |
groups |
aggregated key list. it is vector type |
forcedRef |
the option which forces to create temp-table for result. |
## try to connect hive server ## Not run: rhive.connect("hive-server-ip") ## invoke napply for numeric return type ## Not run: rhive.aggregate('emp', 'sum', 'sal', c('ename')) ## close connection ## Not run: rhive.close()