CleverInstallList.scala 910 Bytes
package mobvista.dmp.datasource.clever

import mobvista.dmp.common.CommonInstallList
import mobvista.dmp.datasource.mpsdk.InstallInfo
import org.apache.commons.lang.StringUtils

/**
  * 将天数据合并到安装列表全量数据中
  */
class CleverInstallList extends CommonInstallList {

  /**
    * 解析天处理结果数据
    * @param array
    * @param date
    * @return
    */
  def processDailyData(array: Array[String], date: String): Array[Tuple2[String, InstallInfo]] = {
    val key = s"${array(0)}$FIELD_SPLIT${array(1)}$FIELD_SPLIT${array(2)}" //device_id, device_type, platform
    val value = new InstallInfo(array(5), date)                            // package
    val result = new Array[Tuple2[String, InstallInfo]](1)
    result(0) = Tuple2(key, value)
    result
  }
}

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