GaRepairInstallList.scala 959 Bytes
Newer Older
wang-jinfeng committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36
package mobvista.dmp.test

import mobvista.dmp.common.CommonInstallList
import mobvista.dmp.datasource.mpsdk.InstallInfo

import scala.collection.mutable.ArrayBuffer

class GaRepairInstallList extends CommonInstallList {

  /**
    * 解析天处理结果数据
    * @param array
    * @param date
    * @return
    */
  def processDailyData(array : Array[String], date : String): Array[Tuple2[String, InstallInfo]] = {
    val buffer = new ArrayBuffer[Tuple2[String, InstallInfo]]()
    val device_id = array(0)
    val device_type = array(1)
    var platform = array(2)
    val packageName = array(3)
    val date = array(5)

    if ("adr".equals(platform)) {
      platform = "android"
    }
    buffer += Tuple2(s"$device_id$DATA_SPLIT${device_type}${DATA_SPLIT}${platform}", new InstallInfo(packageName, date))
    buffer.toArray
  }
}

object GaRepairInstallList {
  def main(args: Array[String]): Unit = {
    new GaRepairInstallList().run(args)
  }
}