-
如何将scala.collection.Set转换为RDD中可序列化的java.util.Set
所属栏目：[安全] 日期：2020-12-16 热度：72
我有一个 scala.collection.Set scalaSet：设置[Long]. 我怎样才能将它转换为带序列化的java.util.Set.我尝试了以下代码,但得到了 ????java.io.notserializableexception：scala.collection.convert.wrappers $setWrapper import scala.collection.JavaConve[详细]
-
scala – combineLatest只在其中一个流发生变化时才会发出
所属栏目：[安全] 日期：2020-12-16 热度：97
我有一个频繁值的流和一个慢的流.我希望将它们组合起来,但只在较慢的一个发出时才发出一个值.所以combineLatest不起作用. 像这样： a1a2b1(a2,b1)a3a4a5b2(a5,b2) 目前我正在这样做,有更清洁的方式吗？ withLatest[A,B](fast : Observable[A],slow : Observa[详细]
-
scala – Enrich-My-Library适用于所有Traversables
所属栏目：[安全] 日期：2020-12-16 热度：176
我试图弄清楚如何编写一个适用于任何Traversable [_]的函数交换函数,给定一个集合和交换索引.我想出了以下内容： def swap[A,CC % Traversable[A]](xs: CC,i: Int,j: Int): Traversable[A] = { xs.slice(0,i) ++ xs.slice(j,j+1) ++ xs.slice(i+1,j) ++ xs.s[详细]
-
开源 – 用于实现市场或应用商店的Opensource或库
所属栏目：[安全] 日期：2020-12-16 热度：130
我将实现一个基于网络的数字内容市场. 不知何故,它的功能类似于应用程序商店,其中销售商品是应用程序,但我的市场目标是数字内容. 在我开始从头开始实施一切之前,我想确保我不会重新发明一些轮子.欢迎任何推荐的工具或个人经验.可伸缩性是我工具采用的主要关[详细]
-
scala – 在抽象构造函数中访问overriden val时出现NullPointerE
所属栏目：[安全] 日期：2020-12-16 热度：139
考虑以下(简化)示例： abstract class Bar[T] { val f: PartialFunction[T,T] val default: PartialFunction[T,T] = { case x = x } val chained = f orElse default}class Foo extends Bar[Int] { val f: PartialFunction[Int,Int] = { case 1 = 2 }} 看着[详细]
-
Typesafe堆栈和Scala 2.10
所属栏目：[安全] 日期：2020-12-16 热度：81
在 scala的2.10下载页面( http://www.scala-lang.org/downloads)上写道： The Scala distribution is also available in a simple,pre-integrated stack from Typesafe. Just download the Typesafe Installer from the Stack Download page 但是当我从http:[详细]
-
使用hprof分析循环的scala
所属栏目：[安全] 日期：2020-12-16 热度：199
街上的字是 scala中的循环比while循环慢. 慢： for (i - 0 until 10000) { f(i)} 快速： var i = 0while (i 10000) { f(i) i += 1} 如何使用hprof来判断for循环是否是我代码中的瓶颈？我正在使用-agentlib来分析我的代码：hprof = cpu = samples,该方法在“C[详细]
-
scala – filterKeys会导致堆栈溢出吗？
所属栏目：[安全] 日期：2020-12-16 热度：188
据我所知,MapLike的方法filterKeys在原始地图上创建了一个包装器.所以,如果我执行下面的代码,m将是一个10K包装器链和原始地图. var m = Map(1 - "one",2 - "two")for(1 - 0 until 10000) {m = m.filterKeys(_%2 == 0)} 现在我认为调用m.contains会导致堆栈溢[详细]
-
混合Scala和Java：如何获得通用类型的构造函数参数吧？
所属栏目：[安全] 日期：2020-12-16 热度：52
我有一些遗留 Java代码,它在我的控制之外的某处定义了一个通用的有效负载变量(即我不能改变它的类型)： // Java codeWrapper? extends SomeBaseType payload = ... 我在我的代码中收到了这样的有效负载值作为方法参数,并希望将其传递给Scala案例类(用作带有a[详细]
-
为什么部分应用函数推迟Scala中的类实例化？
所属栏目：[安全] 日期：2020-12-16 热度：100
想象一下这段代码： class Foo { println("in Foo") def foo(a: Int) = a + 1} 现在,如果我们调用： new Foo().foo _ 正如预期的那样,将创建类Foo的实例： in Foores0: (Int) = Int = function1 但是,如果我们调用它： new Foo().foo(_) Foo的构造函数不会被[详细]
-
scala – Akka警告“太多HashedWheelTimer实例”
所属栏目：[安全] 日期：2020-12-16 热度：54
当我的基于Akka 1.2的应用程序尝试使用超过500个左右的网格节点时,我收到以下警告： Jan 05,2012 1:36:43 PM org.jboss.netty.util.internal.SharedResourceMisuseDetectorWARNING: You are creating too many HashedWheelTimer instances. HashedWheelTimer[详细]
-
Scala trait mixin中方法调用的顺序
所属栏目：[安全] 日期：2020-12-16 热度：76
我的程序结构如下： abstract class IntQueue { def get(): Int def put(x: Int)}trait Doubling extends IntQueue{ abstract override def put(x: Int) { println("In Doubling's put") super.put(2*x) }}trait Incrementing extends IntQueue { abstract o[详细]
-
scala – 混合Akka 2,Play2-mini框架和HTTP
所属栏目：[安全] 日期：2020-12-16 热度：124
随着Akka 2的发布,Akka HTTP modules已被替换为使用 Play2-mini,其中Play2-mini看起来像Play2减去模型视图控制器. 该线在实现REST服务和创建HTTP客户端之间变灰.例如,假设我想在一个服务(即HTTP代理)中创建Web服务(不一定是REST)和HTTP客户端.我使用Akka还是[详细]
-
Scala 2.8 Actor设计文档？ Akka设计文件？
所属栏目：[安全] 日期：2020-12-16 热度：61
是否有针对 Scala 2.8 Actors的设计文档,就像2.7版本一样？ Scala Actors: Unifying Thread-based and Event-based Programming 阿卡有一个吗？ “Scala改进文档库”没有提到Actors. 解决方法 2012年8月更新： Akka documentation已经大大改进,现在有许多关[详细]
-
数组 – Scala类型推断：不能从Array [T]推断出IndexedSeq [T]
所属栏目：[安全] 日期：2020-12-16 热度：194
在 Scala 2.11.2中,以下最小示例仅在Array [String]上使用类型ascription时进行编译： object Foo { def fromList(list: List[String]): Foo = new Foo(list.toArray : Array[String]) }class Foo(source: IndexedSeq[String]) 如果我删除了fromList中的类型[详细]
-
scala – Akka context watch/unwatch发生在之前的关系
所属栏目：[安全] 日期：2020-12-16 热度：186
我对两个actor,父P和子C进行了以下顺序操作： P手表C(背景手表c) P unwatches C(上下文unwatch c) P优雅地停止C(c！PoisonPill) 我想知道的是;我保证P不会收到C的终止事件吗？ 这是一段代码示例 class HappensBefore extends App { class C extends Actor {[详细]
-
scala-redis需要sbt 0.10.1(其他版本不起作用) – 这是正常的吗
所属栏目：[安全] 日期：2020-12-16 热度：137
在尝试 Scala bindings for Redis时,我按照README文件中的说明(克隆repo,cd到它,键入sbt),我得到了这个： $sbtGetting org.scala-tools.sbt sbt_2.9.1 0.10.1 ...:: problems summary :::::: WARNINGS module not found: org.scala-tools.sbt#sbt_2.9.1;0.10[详细]
-
scala – 如何自动化StructType创建以将RDD传递给DataFrame
所属栏目：[安全] 日期：2020-12-16 热度：159
我想将RDD保存为镶木地板文件.为此,我将RDD传递给DataFrame,然后使用结构将DataFrame保存为镶木地板文件： val aStruct = new StructType(Array(StructField("id",StringType,nullable = true),StructField("role",nullable = true))) val newDF = sqlContex[详细]
-
如何使用Scala宏转换和应用部分函数？
所属栏目：[安全] 日期：2020-12-16 热度：59
我想实现一个 Scala宏,它接受一个部分函数,??对函数的模式执行一些转换,然后将它应用于给定的表达式. 为此,我开始使用以下代码： def myMatchImpl[A: c.WeakTypeTag,B: c.WeakTypeTag](c: Context)(expr: c.Expr[A])(patterns: c.Expr[PartialFunction[A,B]][详细]
-
scala – Cats中的效果抽象和并行执行
所属栏目：[安全] 日期：2020-12-16 热度：163
我有下一个使用Cats IO编写的代码,它并行执行多个动作(简化)： import cats.effect._import cats.implicits._import scala.concurrent.ExecutionContext.Implicits.global class ParallelExecIO { def exec: IO[List[String]] = { val foo = IO.shift * IO("[详细]
-
覆盖Scala中的curried函数
所属栏目：[安全] 日期：2020-12-16 热度：83
我的印象就是这个 // short syntaxdef foo(bar: Bar)(baz: Baz): Quux 这是语法糖 // long syntaxdef foo(bar: Bar): (Baz) = Quux 但在继承方面,我似乎无法将两者混为一谈.整个树必须用短语法或长语法定义;从来没有. 例如： case class Contextcase class W[详细]
-
scala – 重用akka-stream流的优雅方式
所属栏目：[安全] 日期：2020-12-16 热度：71
我正在寻找一种轻松重用akka-stream流的方法. 我把Flow打算重新用作函数,所以我想保留它的签名： 流程[输入,输出,未使用] 现在,当我使用此流程时,我希望能够“调用”此流程并将结果保留在一边以便进一步处理. 所以我想从Flow发射[输入]开始,应用我的流程,然[详细]
-
scala – 单例类型中的表面不一致
所属栏目：[安全] 日期：2020-12-16 热度：140
我有几个关于单例类型的问题,但由于它们都非常密切相关,我将它们发布在同一个线程下. Q1.为什么#1不编译但#2呢？ def id(x: Any): x.type = x // #1def id(x: AnyRef): x.type = x // #2 Q2.在String的情况下正确推断出类型,但在我尝试过的其他引用类型的情[详细]
-
Scala – 可以在方法级别应用implicitNotFound注释吗？
所属栏目：[安全] 日期：2020-12-16 热度：55
我有一个方法,它采用带有隐式视图边界的类型参数.使用无效数据类型调用方法时,是否可以使用@implicitNotFound批注来提供更好的编译器错误？ 该方法的文档是无用的,甚至源代码也无济于事,所有在线使用的例子都处于特征或类级别. 解决方法 不,你不能直接这样做[详细]
-
是否可以在Scala中更改基类/特征的方差？
所属栏目：[安全] 日期：2020-12-16 热度：124
我想从 Scala的不可变映射派生出来.它定义如下： trait Map[A,+B] 不幸的是,我的实现需要在B中保持不变.我尝试了以下内容,但没有成功： def +(kv : (A,B)) : MyMap[A,B] = { ... }override def +[B1 : B](kv : (A,B1)) : MyMap[A,B1] = throw new IllegalArg[详细]
