2015-07-24 6 views
0

Я пытаюсь запросить aerospike с помощью нескольких фильтров, принимая ссылку из указанной ниже ссылке ...Aerospike - Запрос с несколькими фильтрами

https://www.aerospike.com/community/labs/query_multiple_filters.html

В примере, предложенном в вышеуказанном потоке, aerospike-клиент используемая версия 3.0.22, и я использую версию 3.0.0 в своем проекте. Я могу запросить базу данных и получить нужные данные, изменяющие упомянутый пример на аэрокосмическом сайте, но когда я запускаю тот же код в своем проекте, данные не возвращаются.

Являются ли сценарии lua и агрегатные функции для поиска данных не поддерживаемыми в версии 3.0.0? Если они есть, есть ли другой способ запросить то же самое с версией 3.0.0?

Lua Script

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")); 

Edit: Получение этого Exception

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(); 

ответ

2

Удаленный пользователь.

запустить метод QueryAggregateExecutor загружает Lua функции из файловой системы, в которой он использует LuaConfig.SourceDirectory переменную, чтобы найти путь к файлу сценария.

Я проходил UDF

LuaConfig.SourceDirectory = "udf" 

, который должен был /дома/Лалита/UDF

LuaConfig.SourceDirectory = "/home/lalit/udf" 
Смежные вопросы