Поиск TotalSpent для каждого клиента в Scala

Question

Я работаю над простым требованием, чтобы узнать totalSpent каждым клиентом. Если Клиент ничего не тратить, то мне нужно, чтобы отобразить TotalSpent Сумму как 0 ему

custs.txt:

100,Surender 
101,Raja 
102,Vijay 

txns.txt:

100,2015-01-29,20 
100,2015-01-30,18 
101,2015-01-14,30 
101,2015-01-17,20 

Scala код :

import scala.io.Source 

case class Txns(custId: Int, txn_dateString: String, spentAmount: Int) 
object totalamounteachcustomer { 


    def main (args: Array[String])={ 


val myCusts=Source.fromFile("C:\\inputfiles\\custs.txt").getLines().toList; 

val custsTxns=Source.fromFile("C:\\inputfiles\\txns.txt").getLines().toList; 

val TxnsGrped =custsTxns.map { x => { 
            val Array(custId,txn_dateString,spentAmount) = x.split(",") 
            Txns(custId.toInt,txn_dateString,spentAmount.toInt) 

            } 
           }.groupBy { txn => txn.custId } 

     for(i <- myCusts) 
     { 
     val customer= i.split(",")(0).toInt 
     val values =TxnsGrped.get(customer) 

     val TotalSpentAmpunt = values match { 

      case Some(a:List[Txns]) => a.map { x => x.spentAmount }.sum 
      case None => 0 

               } 

     println(customer+" "+TotalSpentAmpunt) 
     } 
} 

} 

Приведенный выше код работает ..

Выход:

100 38 
101 50 
102 0 

ли мы просто присоединиться ключевые слова в Скале? Если нам нужно получить значения на основе общего ключа между двумя файлами, мы не можем использовать что-то вроде Join (internal join, left join) в scala?

Здесь я использую карту коллекции scala и перебираю ее по отношению к каждому клиенту.

Можем ли мы достичь этого же требования с помощью простых строк кода scala?

Answer 1

Реализации присоединиться карты кусок пирога в Scala:

def join[K, A, B](a: Map[K, A], b: Map[K, B]): Map[K, (A,B)] = 
    for((k,va) <- a; vb <- b.get(k)) yield k -> (va, vb) 

Используйте пример:

val customers = Map(
100 -> "Surender", 
101 -> "Raja", 
102 -> "Vijay" 
) 

val purchases = Seq(
(100,"2015-01-29",20), 
(100,"2015-01-30",18), 
(101,"2015-01-14",30), 
(101,"2015-01-17",20) 
) groupBy(_._1) 

join(customers, purchases) mapValues { case (_, l) => l.map(_._3).sum } 

Вы можете сделать из join операции инфикса, окружив его в неявном классе:

implicit class C[K, A](a: Map[K, A]) { 

    def join[B](b: Map[K, B]): Map[K, (A,B)] = 
     for((k,va) <- a; vb <- b.get(k)) yield k -> (va, vb) 

} 

customers join purchases 

Обратите внимание, что эта реализация объединения (внутреннее соединение) легко модифицируется для b ehave как левый присоединиться:

implicit class C[K, A](a: Map[K, A]) { 

    def join[B](b: Map[K, B]): Map[K, (A,B)] = 
     for((k,va) <- a; vb <- b.get(k)) yield k -> (va, vb) 

    def leftJoin[B](b: Map[K, B], default: B): Map[K, (A,B)] = 
     for((k,va) <- a; vb = b.getOrElse(k, default)) yield k -> (va, vb) 

} 

И затем использовать его с данными, чтобы получить именно результат вы ищете:

customers leftJoin(purchases, Seq()) mapValues { 
    case (_, l) => l.map(_._3).sum 
} 

> res: scala.collection.immutable.Map[Int,Int] = Map(100 -> 38, 101 -> 50, 102 -> 0) 

Answer 2

Давайте рассмотрим основы. Внутренние и внешние соединения являются частью SQL для баз данных. Если у вас есть база данных SQL, вы можете использовать Scala для ее запроса, и вы можете выполнять операции объединения. Если у вас есть данные в виде коллекции csv-файлов, вам нужен движок, который превращает его в SQL-поддержку RDBMS, а затем может выполнять объединения.

Другими словами, в Scala, как и в Java, C# или на любом другом языке, база данных представляет собой деталь реализации, которая разрабатывается во время разработки. Ни один другой язык не может напрямую присоединяться к файлам, сначала используя какой-то обертку AFAIK.

Если бы мне пришлось делать то, что вы здесь показываете, я бы импортировал файлы csv в базу данных SQL, от SQLite до Oracle, SQL-сервера, Mysql, take-your-pick, а затем запросил эту базу данных в худшем случае сценария через JDBC.