Cassandra：具有复杂用户定义类型的聚合函数INITCOND

Question

对于Cassandra中的用户定义聚合函数，什么可以作为INITCOND？我只见过具有简单类型（例如元组）的示例。

我为聚合函数中的状态对象提供了以下类型：

create type avg_type_1 (
    accum tuple<text,int,double>,   // source, count, sum
    avg_map map<text,double>        // source, average
);

当我省略INITCOND时，我得到一个JavaNullPointerException。

Answer 1

问题中UDT的以下工作：

INITCOND ((null, 0, 0.0), null)

累计字段（元组）：第一个元素（source，String）设置为null，第二个元素（count，int）设置为0（零），第三个也是最后一个元素（sum，double）设置为0.0（零）。

avg_map字段（map）：设置为null（还没有map）。

字段也可以按名称引用，如下所示（来自描述…）显示。

INITCOND {accum: (null, 0, 0.0), avg_map: null};

对于命名字段，使用花括号“{}”（因为它们表示为映射）。

最后，这里是一个初始化贴图的示例。

INITCOND {accum: (null, 0, 0.0), avg_map: {'i1': 23.5, 'i2': 1.2}};