-
scala当中的类型参数
所属栏目：[安全] 日期：2020-12-16 热度：164
类型参数主要就是研究scala当中的类或者scala当中的方法的泛型 1、scala当中的类的泛型 ????????object Demo8 { ???????? def main(args: Array[String]): Unit = { ???????? val result1 = new MyClass( "hello" ,50) ???????? val result2 = new MyClass[A[详细]
-
Scala模式匹配和样例类
所属栏目：[安全] 日期：2020-12-16 热度：89
Scala有一个十分强大的模式匹配机制，可以应用到很多场合：如switch语句、类型检查等。并且Scala还提供了样例类，对模式匹配进行了优化，可以快速进行匹配。 1、字符匹配 ????def main(args: Array[String]): Unit = { ??????val charStr = ‘6‘ ??????char[详细]
-
scala集合与数据结构
所属栏目：[安全] 日期：2020-12-16 热度：163
1、数据结构特点 Scala同时支持可变集合和不可变集合，不可变集合从不可变，可以安全的并发访问。 两个主要的包 ： 不可变集合：scala.collection.immutable 可变集合： scala.collection.mutable Scala优先采用不可变集合，对于几乎所有的集合类，Scala都同[详细]
-
Scala高阶函数
所属栏目：[安全] 日期：2020-12-16 热度：83
1、作为参数的函数 函数可以作为一个参数传入到一个方法当中去 def main(args: Array[String]): Unit = { val myFunc1 =(x:Int) ={ x * x } val myArray = Array(1,3,5,7,9).map(myFunc1) println(myArray.mkString( "," )) } 2、匿名函数 没有名字的函数即[详细]
-
scala当中的文件操作和网络请求
所属栏目：[安全] 日期：2020-12-16 热度：153
1、读取文件当中每一行的数据 def main(args: Array[String]): Unit = { // 注意文件的编码格式，如果编码格式不对，那么读取报错 val file: BufferedSource = Source.fromFile( "F: files file.txt" , "GBK" ); val lines: Iterator[String] = file.g[详细]
-
使用Scala在Spark DataFrame中重用JSON中的Schema
所属栏目：[安全] 日期：2020-12-16 热度：176
我有一些像这样的 JSON数据： {"gid":"111","createHour":"2014-10-20 01:00:00.0","revisions":[{"revId":"2","modDate":"2014-11-20 01:40:37.0"},{"revId":"4","modDate":"2014-11-20 01:40:40.0"}],"comments":[],"replies":[]}{"gid":"222","createHour[详细]
-
scala – 无法使用Slick更新记录
所属栏目：[安全] 日期：2020-12-16 热度：121
类和表定义如下所示： case class Group( id: Long = -1,id_parent: Long = -1,label: String = "",description: String = "") object Groups extends Table[Group]("GROUPS") { def id = column[Long]("ID",O.PrimaryKey,O.AutoInc) def id_parent = column[详细]
-
scala – 播放2.5迁移错误：使用BodyParser自定义操作：找不到参
所属栏目：[安全] 日期：2020-12-16 热度：187
我有一个Play Framework应用程序,版本2.4迁移到2.5,一切都完成了！但在使用BodyParser的自定义操作中抛出错误, def isAuthenticatedAsync[A](parser: BodyParser[A])(f: = Long = Request[A] = Future[Result]) = {Security.Authenticated(userId,onUnauthor[详细]
-
scala – 创建RDD以收集迭代计算的结果
所属栏目：[安全] 日期：2020-12-16 热度：148
我想创建一个RDD来收集迭代计算的结果. 如何使用循环(或任何替代方法)替换以下代码： import org.apache.spark.mllib.random.RandomRDDs._ val n = 10 val step1 = normalRDD(sc,n,seed = 1 ) val step2 = normalRDD(sc,seed = (step1.max).toLong ) val res[详细]
-
在scala中使用java.time API
所属栏目：[安全] 日期：2020-12-16 热度：79
我正在使用 Scala REPL尝试 Java 8 Date Time Api java.time.刚遇到下面的问题： 我知道关键字with在scala中保留,但它也在API中使用.有关如何减轻限制的任何想法？ 解决方法 尝试使用刻度标记包装with,如下所示： val nextWed = today.`with`(java.time.temp[详细]
-
Scala中带接收器的函数类型
所属栏目：[安全] 日期：2020-12-16 热度：122
我正在调查这个Kotlin的例子： class HTML { fun body() { ... }}fun html(init: HTML.() - Unit): HTML { val html = HTML() // create the receiver object html.init() // pass the receiver object to the lambda return html}html { // lambda with rec[详细]
-
scala – Apache Spark：驱动程序(而不仅仅是执行程序)尝试连接
所属栏目：[安全] 日期：2020-12-16 热度：72
我想我还没有完全理解Spark是如何工作的. 这是我的设置： 我在独立模式下运行Spark集群.我正在使用4台机器：一台是大师,另外三台是工人. 我编写了一个从Cassandra集群读取数据的应用程序(参见https://github.com/journeymonitor/analyze/blob/master/spark/s[详细]
-
scala – 获取连接到Apache Spark GraphX中节点的所有节点
所属栏目：[安全] 日期：2020-12-16 热度：88
假设我们在Apache GraphX中获得了以下输入： 顶点RDD： val vertexArray = Array( (1L,"Alice"),(2L,"Bob"),(3L,"Charlie"),(4L,"David"),(5L,"Ed"),(6L,"Fran")) Edge RDD： val edgeArray = Array( Edge(1L,2L,1),Edge(2L,3L,Edge(3L,4L,Edge(5L,6L,1)) 我[详细]
-
scala – EC2上的Spark Streaming：线程“main”java.lang.Excep
所属栏目：[安全] 日期：2020-12-16 热度：58
我试图在我创建的jar文件上运行spark-submit.当我在我的机器上本地运行它时它可以正常工作但是当部署到Amazon EC2上时它会返回以下错误. root@ip-172-31-47-217 bin]$./spark-submit --master local[2] --class main.java.Streamer ~/streaming-project-1.0-[详细]
-
scala – 如何在Phantom for Cassandra中使用和查询动态列族？
所属栏目：[安全] 日期：2020-12-16 热度：187
我最近开始处理繁重的大量数据,这些数据也需要经过常规交易. 选择Cassandra,我的数据模型使用动态列.我知道使用CQL可以改变表并插入或查询列以获取所需的数据. 但是,我正在使用Phantom客户端和Scala for Cassandra并阅读文档,我找不到写入或查询动态列族的方[详细]
-
scala – 如何从RDD创建RDD集合？
所属栏目：[安全] 日期：2020-12-16 热度：99
我有一个RDD [String],wordRDD.我还有一个从字符串/单词创建RDD [String]的函数.我想为wordRDD中的每个字符串创建一个新的RDD.以下是我的尝试： 1)失败,因为Spark不支持嵌套的RDD： var newRDD = wordRDD.map( word = { // execute myFunction() (new MyClas[详细]
-
如何获取Scala函数的参数/返回类型？
所属栏目：[安全] 日期：2020-12-16 热度：145
我有一个函数,并希望获取其参数类型和返回类型以供在 Scala宏中使用. scala val fn = (a: String,b: Double) = 123fn: (String,Double) = Int = function2scala fn.getClassres1: Class[_ : (String,Double) = Int] = class $anonfun$1 在上面的例子中,参数[详细]
-
scala – 我可以用Shapeless解决它吗？
所属栏目：[安全] 日期：2020-12-16 热度：159
假设我有一些功能： val f1: Int = Stringval f2: (Int,Int) = Stringval f3: (Int,Int,Int) = Stringdef fromList1(f: Int = String): List[Int] = Option[String] = _ match {case x::_ = Some(f(x)); case _ = None}def fromList2(f: (Int,Int) = String)[详细]
-
scala – 订购RDD [String]
所属栏目：[安全] 日期：2020-12-16 热度：172
考虑 val animals = List("penguin","ferret","cat").toSeqval rdd = sc.makeRDD(animals,1) 我想订购这个RDD.我是Scala的新手,对于如何做到这一点感到有些困惑. 解决方法 可以在 here找到RDD文档.查看sortBy： sortBy[K]( f: (T) ? K,ascending: Boolean =[详细]
-
使用新线条在Scala Play20中使用BodyParser解析文件
所属栏目：[安全] 日期：2020-12-16 热度：112
请原谅这个问题的缺点,但我有一个Web应用程序,我想将一个可能很大的文件发送到服务器并让它解析格式.我正在使用Play20框架,而且我是 Scala的新手. 例如,如果我有一个csv,我想用“,”分隔每一行,最后用每个字段创建一个List [List [String]]. 目前,我认为最好[详细]
-
scala – 为什么`Future#toString`返回`“List()”`？
所属栏目：[安全] 日期：2020-12-16 热度：164
在未等待compless的情况下调用.toString会导致不确定的结果.我的问题是为什么在未完成的期货上调用.toString会在 scala 2.10.x和2.11.x中返回“List()”？ The implementation似乎并不明确. 可以从REPL中观察到此行为： scala import scala.concurrent.Futur[详细]
-
斯卡拉 – 不同版本之间的Akka遥控器
所属栏目：[安全] 日期：2020-12-16 热度：83
我试图在不同的akka??版本之间使用远程处理.我有一个在 scala 2.10.2上运行akka 2.2.1的应用程序和在scala 2.9.2上运行akka 2.0.5的应用程序.第二个应用程序使用scala 2.10.2不可用的库,所以我不能简单地更新应用程序,也不能降级另一个应用程序.我收到一条消[详细]
-
在Scala中解析和操纵json
所属栏目：[安全] 日期：2020-12-16 热度：148
我有一个从我正在使用的REST服务返回的 JSON. { "id": "6804","signatories": [ { "id": "12125","fields": [ { "type": "standard","name": "fstname","value": "John" },{ "type": "standard","name": "sndname","value": "Doe" },"name": "email","value"[详细]
-
scala – 播放/记录/打印响应正文/运行枚举器/缓冲正文
所属栏目：[安全] 日期：2020-12-16 热度：112
我正在寻找一种在Play框架中打印响应体的方法,我有这样的代码： object AccessLoggingAction extends ActionBuilder[Request] { def invokeBlock[A](request: Request[A],block: (Request[A]) = Future[Result]) = { Logger.info(s"""Request: id=${request.[详细]
-
Scala IDE是否具有* .sbt语法突出显示支持？
所属栏目：[安全] 日期：2020-12-16 热度：72
我正在使用 Scala Ide 4.0.0-rc3,对于新的Play Framework应用程序,我似乎无法为* .sbt文件启用语法高亮显示.我们在 Eclipse中是否支持它？ 解决方法 如 @Mirko Stocker所述,目前不支持此功能.但是,我发现将* .sbt与JavaScript编辑器相关联可以产生不错的突出[详细]
