Чтобы получить сумму определенного значения из набора результатов в riak

Question

Я работаю над клиентом riak-java. делая Mapreduce, я получил следующий результат. Теперь я хочу получить сумму ticketValue из набора результатов, который я получил. Я хочу получить его, передав идентификатор пользователя.

обновление

Из этого метода я получить Resultset ниже

def fetchTicketValue(userID:String): Boolean = { 
    try{ 
     val result = riakClient.mapReduce("table-ticket","userID:Kim") 
     .addMapPhase(new NamedJSFunction("Riak.mapValuesJson"),true) 
     .execute 
     val o:String = result.getResultRaw 
    }catch{ 
     case e : Exception => 
     e.printStackTrace 
    } 
    true 
    } 

Я забыл упомянуть большой кронштейн [{....}, {....}, { ....}] заблаговременно.

[{"ticketValue":3,"userID":"Kim","Date":"date","ticketID":"98394kjdf","ticketSource":"reg"},{"ticketValue":3,"userID":"Kim","Date":"date","ticketID":"98394kjdf","ticketSource":"reg"},{"ticketValue":3,"userID":"Kim","Date":"date","ticketID":"98394kjdf","ticketSource":"reg"}] 

LIKE: userID:"kim" 

RESULT: ticketValue:9 

Как я могу получить данные? Любая идея будет высоко оценена. Спасибо заранее.

(Riak Версия: 1.3.2 и Riak Java Client: 1.1.4)

Answer 1

Вы дали взглянуть на Jerkson библиотеки (ее отказались, насколько я знаю, но все еще обеспечивает хорошее функциональность), его оболочка scala для библиотеки Jackson для java, использующая библиотеку Play JSON по умолчанию, является хорошей идеей, но с момента ее получения устарел от 2.11. и Джеркссон намного легче.

Использование Jerkson вы могли бы попробовать это, код за себя, я была такая же проблема недавно Link ->

var sum:Int = 0 
val parsedList = parse[List[Ticket]](result.getResultRaw) 
for (e <-parsedList){ 
    sum = sum + e.ticketValue 
} 
println("Final sum: "+sum) 

Answer 2

import scala.util.parsing.json.JSON 

case class Row(ticketValue: Int, userId: String, date: String, ticketId: String, ticketSource: String) 

// I'm sure there's a way to do this more cleanly; using it as an implicit maybe 
def mapToRow(m: Any): Row = { 
    val typedM = m.asInstanceOf[Map[String, Any]] 
    Row(typedM("ticketValue").asInstanceOf[Double].toInt, 
    typedM("userID").toString, 
    typedM("Date").toString, 
    typedM("ticketID").toString, 
    typedM("ticketSource").toString) 
} 

def getSum(result: String, userId: String) = { 
    val rows = JSON.parseFull("[" + result + "]").get.asInstanceOf[Seq[Map[String, Any]]].map(mapToRow) 
    rows.filter(_.userId == userId).map(_.ticketValue).sum 
} 


val result = """{"ticketValue":3,"userID":"Samy","Date":"date","ticketID":"98394kjdf","ticketSource":"reg"},{"ticketValue":3,"userID":"Kim","Date":"date","ticketID":"98394kjdf","ticketSource":"reg"},{"ticketValue":3,"userID":"Kim","Date":"date","ticketID":"98394kjdf","ticketSource":"reg"},{"ticketValue":3,"userID":"Kim","Date":"date","ticketID":"98394kjdf","ticketSource":"reg"}""" 
getSum(result, "Kim")