scala> val a = ArrayBuffer[Int](1, 2,3, 5, -1, 2, -3
//獲取任意多個目錄下所有文件 def getFiles(inputs: File*): Seq[File] = { inputs.filter(_.isFile) ++ inpu
4.給定一個整數(shù)數(shù)組,產(chǎn)生一個新的數(shù)組,包含原數(shù)組中的所有正值,按原有順序排序 之后的元素是所有的零或者負(fù)值,按原有順序排序 scala> val arr = Array(1, 2, 3, 4
經(jīng)常在marathon源碼和spark源碼中看見Option[A]的身影,那它到底是用來干什么的呢?其實,Option 就像是一個容器,一個箱子;Option[A
運(yùn)行Spark任務(wù),報錯java.lang.NoSuchMethodError: scala.Product.$init$……選擇File -> Project StrutureGlobal L
上周的工作中遇到了一個停止運(yùn)行任務(wù)時的問題,就是在一個任務(wù)運(yùn)行到一半時需要停止的問題。正常的需求是一按停止按鈕,就要立即停止,但現(xiàn)在都要等程序運(yùn)行完才能停止,現(xiàn)在是一個bug
今天在看同事的代碼時看到如下代碼:package object msg { sealed trait Task
電商大數(shù)據(jù)項目-推薦系統(tǒng)實戰(zhàn)(一)環(huán)境搭建以及日志,人口,商品分析https://blog.51cto.com/6989066/2325073電商大數(shù)據(jù)項目-推薦系統(tǒng)實戰(zhàn)之推薦算法https://bl
使用版本:spring boot 1.5.21問題:在scala中配置對jackson的 `com.fasterxml.jackson.databind.Module` 進(jìn)行配置但是始終無法將實體正確
記載我的spark源碼閱讀火花知識點(diǎn):1、seq:列表,適合存有序重復(fù)數(shù)據(jù),進(jìn)行快速插入/刪除元素等場景,Set是集合,適合存無序非重復(fù)數(shù)據(jù),進(jìn)行快速查找海量元素等場景memoryKeys