用于Cassandra的Python UDF

Question

我似乎在网上找不到任何例子。Cassandra 3.0支持可以用Java、Python或其他语言编写的UDF和UDA。

如何设置Python中定义的UDF或UDA（我指的是Python函数，而不是通过Python驱动程序在Java或Javascript中定义的函数）？

Answer 1

您的问题并不清楚您是想使用类似python驱动程序的东西来定义UDF、UDA，还是想用python语言定义UDF，但这可能会引导您朝着正确的方向前进。

我在这里的python-driver的test_metadata.py中发现了以下示例。

https://github.com/datastax/python-driver/blob/master/tests/integration/standard/test_metadata.py#L448

javascript中的UDF示例

session.execute("""CREATE FUNCTION {0}.sum_int(key int, val int)
                            RETURNS NULL ON NULL INPUT
                            RETURNS int
                            LANGUAGE javascript AS 'key + val';""".format(keyspace_name))

我相信您可以通过更改上面的语言参数来切换函数实际写入的语言。

这里是Java中函数声明的一个例子。

session.execute("""CREATE OR REPLACE FUNCTION update_map(s map<int, int>, i int)
                               RETURNS NULL ON NULL INPUT
                               RETURNS map<int, int>
                               LANGUAGE java AS 's.put(new Integer(i), new Integer(i)); return s;';""")

UDA示例

session.execute("""CREATE AGGREGATE {0}.sum_agg(int)
                             SFUNC sum_int
                             STYPE int
                             INITCOND 0"""
                             .format(self.keyspace_name))

这里还有一篇博客文章可以参考。http://www.datastax.com/dev/blog/cassandra-user-defined-functions-python-driver