我试着用多个过滤器查询机场,参考下面提到的链接.
在上述线程中提出的示例中,使用的aerospike客户端版本为3.0.22,而我在项目中使用的是3.0.0版本。我能够查询数据库并检索所需的数据,更改aerospike网站上提到的示例,但是当我在项目中运行相同的代码时,不会返回任何数据。
版本3.0.0中不支持用于数据检索的lua脚本和聚合函数吗?如果是的话,还有其他方法来查询3.0.0版本的相同内容吗?
Lua脚本
local function map_order(record)
return map {key=record.key, mid=record.mid, orderId=record.orderId, amount=record.amount}
end
function filter_order(stream, mid)
local function filter_mid(record)
return record.mid == mid
end
return stream : filter(filter_mid) : map(map_order)
end数据检索代码
ResultSet resultSet = client.queryAggregate(null, stmt, "profile", "filter_order", Value.get("mid334"));编辑:获取此异常
com.aerospike.client.AerospikeException: Failed to read file: /home/lalit/spring-suite/sts-bundle/sts-3.6.3.RELEASE/udf/profile.lua当文件位于/home/lalit/udf/profile.udf时
注册lua文件的代码
LuaConfig.SourceDirectory = "udf";
udfFile = new File("/home/lalit/udf/profile.lua");
task = client.getAerospikeClient().register(null, udfFile.getPath(), udfFile.getName(), Language.LUA);
task.waitTillComplete();发布于 2015-07-24 14:22:57
设法解决了。
运行QueryAggregateExecutor方法从文件系统加载lua函数,其中使用LuaConfig.SourceDirectory变量定位脚本文件的路径。
我路过udf
LuaConfig.SourceDirectory = "udf"哪个应该是/home/lalit/udf
LuaConfig.SourceDirectory = "/home/lalit/udf"https://stackoverflow.com/questions/31606652
复制相似问题