如何编写用于范围查询的Aerospike流UDF
2016-11-29 0:39:0
收藏:0
阅读:80
评论:2
我编写了一个用于范围查询的Stream UDF,但它无法正常工作。你有没有想法如何用lua设置多个过滤器?
查询语句:
SELECT id1,id2,link_type,visibility,data,time,version FROM linktable
WHERE id1 = <id1> AND
link_type = <link_type> AND
time >= <minTime> AND
time <= <maxTimestamp> AND
visibility = VISIBILITY_DEFAULT
ORDER BY time DESC LIMIT <offset>,<limit>;
调用此lua函数的Java代码:
stmt = new Statement();
stmt.setNamespace(dbid);
stmt.setSetName("links");
stmt.setIndexName("time");
stmt.setFilters(Filter.range("time",minTimestamp,maxTimestamp));
stmt.setAggregateFunction("linkbench","check_id1",Value.get(id1));
stmt.setAggregateFunction("linkbench","check_linktype",Value.get(link_type));
resultSet = client.queryAggregate(null,stmt,"linkbench","check_visibility",Value.get(VISIBILITY_DEFAULT));
Lua脚本:
local function map_links(record)
-- 添加用户和密码到返回的map中。
-- 还可以在此处添加其他记录bins。
return record.id2
end
function check_id1(stream,id1)
local function filter_id1(record)
return record.id1 == id1
end
return stream : filter(filter_id1) : map(map_links)
end
function check_linktype(stream,link_type)
local function filter_linktype(record)
return record.link_type == link_type
end
return stream : filter(filter_linktype) : map(map_links)
end
function check_visibility(stream,visibility)
local function filter_visibility(record)
return record.visibility == visibility
end
return stream : filter(filter_visibility) : map(map_links)
end
有没有想法如何编写所有查询限制的过滤器?
谢谢!
点赞
评论区的留言会收到邮件通知哦~
推荐文章
- Lua 虚拟机加密load(string.dump(function)) 后执行失败问题如何解决
- 我想创建一个 Nginx 规则,禁止访问
- 如何将两个不同的lua文件合成一个 东西有点长 大佬请耐心看完 我是小白研究几天了都没搞定
- 如何在roblox studio中1:1导入真实世界的地形?
- 求解,lua_resume的第二次调用继续执行协程问题。
- 【上海普陀区】内向猫网络招募【Skynet游戏框架Lua后端程序员】
- SF爱好求教:如何用lua实现游戏内调用数据库函数实现账号密码注册?
- Lua实现网站后台开发
- LUA错误显式返回,社区常见的规约是怎么样的
- lua5.3下载库失败
- 请问如何实现文本框内容和某个网页搜索框内容连接,并把网页输出来的结果反馈到另外一个文本框上
- lua lanes多线程使用
- 一个kv数据库
- openresty 有没有比较轻量的 docker 镜像
- 想问一下,有大佬用过luacurl吗
- 在Lua执行过程中使用Load函数出现问题
- 为什么 neovim 里没有显示一些特殊字符?
- Lua比较两个表的值(不考虑键的顺序)
- 有个lua简单的项目,外包,有意者加微信 liuheng600456详谈,最好在成都
- 如何在 Visual Studio 2022 中运行 Lua 代码?

多个聚合函数不受支持。必须组合聚合和过滤函数。
function combined_aggregation(stream,id1,link_type,visibility) local function combined_filter(record) return record.id1 == id1 and record.link_type == link_type and record.visibility == visibility end return stream : filter(combined_filter) : map(map_links) end