Java源代码编译失败-Cassandra函数

Question

我是Cassandra的新手，我正在尝试创建一个用户定义的聚合，但一直停留在函数创建上。

表中数据为-

count| host
-----+-----------
 102 | test_host1
 100 | test_host2
 101 | test_host2
 101 | test_host3
 104 | test_host3
 101 | test_host1
 100 | test_host3
 103 | test_host3
 102 | test_host3
 100 | test_host1

我正在编写的函数将计算特定主机的表中有多少行。如果我为聚合提供test_host1，理想的结果将是3。

在下面找到函数的代码-

    CREATE FUNCTION countSessions(dataMap map<text,int>,host text)  
    RETURNS NULL ON NULL INPUT  
    RETURNS map<text, int>  
    LANGUAGE java as  
    ' 
    Integer countValue = dataMap.get(host); 
    if(countValue == null) { 
    countValue = 1; 
    } else { 
    countValue++; 
    } 
    dataMap.put(host,countValue); 
    return dataMap; 
    ';

在cqlsh上执行此操作时，我得到以下错误-

InvalidRequest:code=2200[无效查询]message=“无法从Java源代码org.apache.cassandra.exceptions.InvalidRequest UESTEException:Java源代码编译失败：第2行：无法解析dataMap第7行：无法解析dataMap第8行：无法将dataMap解析为变量”

我无法理解我的函数代码出了什么问题。请帮助。

另外，是否有人可以向我推荐任何链接/站点（datastax除外），使用这些链接/站点我可以正确理解UDF和UDA。

感谢和问候，

维巴夫

附言——如果有人选择否决这个问题，请在评论中提及原因。

Answer 1

这不起作用，因为dataMap在初始声明中被转换为小写。您可以这样做：

CREATE FUNCTION countSessions("dataMap" map<text,int>,host text)  
RETURNS NULL ON NULL INPUT  
RETURNS map<text, int>  
LANGUAGE java as  
' 
Integer countValue = dataMap.get(host); 
if(countValue == null) { 
countValue = 1; 
} else { 
countValue++; 
} 
dataMap.put(host,countValue); 
return dataMap; 
';

或

CREATE FUNCTION countSessions(datamap map<text,int>,host text)  
RETURNS NULL ON NULL INPUT  
RETURNS map<text, int>  
LANGUAGE java as  
' 
Integer countValue = datamap.get(host); 
if(countValue == null) { 
countValue = 1; 
} else { 
countValue++; 
} 
datamap.put(host,countValue); 
return datamap; 
';

让这个工作。