腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
4
回答
如
何在
Scala
中
处理
嵌套
的
Futures
序列
函数
scala
、
future
我想创建一个
函数
,用于返回在成功时已被操纵
的
一系列期货
的
结果。我遇到
的
问题是,返回类型是Unit,并且未来
的
函数
正在完成,而不是等待
嵌套
的
未来
序列
完成。我尝试过不使用onComplete
函数
,而是使用map或flatMap,但都没有成功。
浏览 30
提问于2019-11-14
得票数 0
回答已采纳
3
回答
Scala
未来
序列
和超时
处理
scala
、
timeout
、
future
有一些好
的
提示,如何结合期货。不过,我很好奇如何用未来
序列
sequenceOfFutures来实现这一点。我
的
第一个方法是这样
的
import
scala
.concurrent.duration._ println("Creating fu
浏览 3
提问于2013-07-16
得票数 9
回答已采纳
1
回答
如
何在
Scala
中
组织并发请求
处理
?
scala
、
concurrency
、
client-server
、
actor
假设我在
Scala
中有一个服务器,它
处理
传入
的
客户端请求。我有一个
处理
请求
的
函数
def process(req: Request): Response。现在,我只想并发
处理
K请求,并将M请求放在队列
中
。 在Java
中
,我可能会创建一个包含K线程和大小为M
的
队列
的
ThreadPoolExecutor。现在,我想知道如
何在
Scala
中使用Actors/<em
浏览 0
提问于2013-06-30
得票数 1
回答已采纳
1
回答
将Seq[A]转换为Map[Int,Seq[A]]
scala
、
transformation
如何将SeqA转换为
Scala
中
的
Map[ Int,SeqA],其中Int
的
值是A
的
param (以
函数
方式)?val
futures
: Seq[Future[Seq[A]]] = ???val gathered = Future.collect(
futures
) res => { val myseq:Seq[A] = res.flattenmyseq.map(a => (a.p
浏览 1
提问于2014-07-04
得票数 0
回答已采纳
1
回答
用于理解
的
Scala
上
的
类型不匹配:
scala
.concurrent.Future
scala
、
future
、
type-mismatch
我对
Scala
很陌生,请容忍我。我有一堆期货包裹在一个大数组里。期货公司已经做了艰苦
的
工作,仔细查看了几个TBs
的
数据,在我
的
应用程序
的
末尾,我想总结所有的结果,这样我就可以很好地展示它们。,我
的
意图是这样做,因为我最近发现,选择、尝试、失败和成功可以看作是集合: //
futures</em
浏览 3
提问于2015-07-12
得票数 4
1
回答
Google并发
中
Futures
.addCallBack()和
Futures
.transform()
的
区别
java
、
asynchronous
、
concurrency
、
guava
Futures
.addCallBack()和
Futures
.transform()在
中
的
区别是什么?
如
文档所示: addCallback(ListenableFuture<V> future, FutureCallback<?根据我
的
理解,当异步
处理
完成时,addCallback()将注册成功或失败回调。在这种情况下,我们可以根据成功或失败
的
条件(例如:日志记录、流control..etc)来
处理
输出。我
的
浏览 7
提问于2014-05-19
得票数 7
2
回答
在
scala
中
,如何将期货列表转换为返回第一个成功未来
的
未来?
scala
、
future
所有的未来可能最终都会成功(有些可能会失败),但我们想要第一个成功
的
。并希望将结果表示为未来。如果列表
中
的
所有期货都失败了,这个未来就会失败。
浏览 0
提问于2020-01-24
得票数 4
1
回答
等待未知数量
的
期货
scala
、
future
在
Scala
2.10
中
,什么是正确
的
方法来编写一个返回将来
的
函数
,当列表
中
的
所有期货都完成时它就完成了?经过研究和实验,我在
Scala
工作表
中
开发了下面的代码:import
scala
.concurrent.ExecutionContext.Implicits.globalimport
scala
.concurrent
浏览 3
提问于2014-04-30
得票数 12
回答已采纳
1
回答
为什么"flatMap“使用
Scala
中
的
选项类型
序列
?
scala
、
option-type
、
flatmap
我不知道
Scala
编译器是如何将flatMap与一系列Option一起使用
的
。如果我对
序列
序列
使用flatMap:它将连接所有
嵌套
序列
。如果我将它与Options
的
序列
一起使用,也会发生同样
的
情况: println(Seq(Some(1), None).flatMap(a => a))
浏览 0
提问于2017-10-08
得票数 6
回答已采纳
1
回答
在python中使用URL
中
变量
的
最快并行请求
python
、
api
创建一个for循环,通过
嵌套
的
序列
号列表循环并执行request.get。但这需要很长时间才能完成。
嵌套
列表: ['MAC2', 'Serial2', 'name2'], ['Serial10', &
浏览 2
提问于2020-11-18
得票数 0
1
回答
在
scala
中
以递归方式读取文件
scala
、
apache-spark
、
pyspark
我正在尝试将
嵌套
在多个文件夹
中
的
一组XML文件读入spark
中
的
序列
文件。我可以使用How do I list all files in a subdirectory in
scala
?
中
的
函数
recursiveListFiles读取文件名。= { these ++ these.filter(_.isDirectory).flatMap(recursiveListF
浏览 10
提问于2019-12-06
得票数 0
2
回答
如
何在
Scala
中
编写过程文件并并行写入结果?
file
、
scala
、
parallel-processing
这是对我问题
的
跟进. 假设我并行
处理
我
的
文件。现在,我想将
处理
结果写入一个文件。由于结果不适合在内存
中
,我不能只是等到所有文件
的
处理
完成,然后写结果。我不得不以某种方式并行
处理
和书写。例如:假设我有带有数字
的
文件。文件大小与500M有关。文件
的
数量与200有关。每个文件都是内存
中
的
,但它们都不合适。现在,我想把这些文件
中
的
所有偶数写到另一个文件<
浏览 2
提问于2012-07-21
得票数 2
1
回答
Scala
期货-如
何在
完成时结束?
scala
、
future
、
databricks
我从一个前同事那里继承了一些代码,在那里他开始使用
futures
(在
Scala
中
)来
处理
Databricks
中
的
一些数据。 我将它分成几个块,在类似的时间段内完成。问题是,代码结束运行(不返回输出),但Databricks
中
的
块一直在执行,直到thread.sleep()部分。我是
Scala
和
futures
的
新手,不确定如
何在
所有
futures
结束运行后退出笔记
浏览 12
提问于2021-07-13
得票数 0
回答已采纳
3
回答
游戏2.2 - specs2 -如
何在
游戏2.2
中
测试期货?
unit-testing
、
scala
、
future
、
specs2
、
playframework-2.2
我测试期货
的
方法是使用value1。我迁移到了游戏2.2。我发现,我习惯
的
测试方式已经消失了。@
scala
.deprecated(“使用
scala
.concurrent.Promise代替.”,"2.2")奥利弗
浏览 1
提问于2013-10-02
得票数 9
回答已采纳
1
回答
Scala
重试期货
序列
直到它们全部完成
scala
、
future
、
retry-logic
在
scala
中
,您将如何编写一个
函数
,该
函数
接受一系列
的
期货,运行它们,不断地重试失败
的
任何一个,并返回结果?例如,签名可能是:可配置超时
的
加成点,此时
函数
会失败,被调用者可以
处理
这种情况如果错误案例
处理
程序可以接收失败
的
期货列表,则奖励积分。 谢谢!
浏览 1
提问于2020-01-07
得票数 4
回答已采纳
1
回答
如
何在
Scala
中
轻松定义更复杂
的
PartialFunctions?
scala
、
lift
、
partialfunction
PartialFunctions使用一系列case语句可以轻松定义分部
函数
。上下文 Lift框架在许多地方使用了部分
函数
,例如,定义一个请求是应该由Lift
的
引擎
处理
,还是直接从磁盘上
的
文件提供服务。有时,我发现自己想要编写一条匹配所有输入参数
的
case语句,然后再决定是否返回值。这意味着case
的
初始
序列</em
浏览 1
提问于2011-07-07
得票数 14
回答已采纳
2
回答
Scala
-用于在多个线程内工作
的
最佳API
multithreading
、
scala
、
multiprocessing
在Python
中
,我使用一个名为
futures
的
库,它允许我以简洁和清晰
的
方式使用N个工作进程池进行
处理
工作:for ... in ...:我现在正在寻找在
Scala
中
做同样事情
的
最接近
的
方法。这是否适用于
Scala
和JVM?原则上,我
的
proce
浏览 1
提问于2014-12-12
得票数 0
回答已采纳
1
回答
Python
Futures
并发不能在Flask
中
运行
python
、
python-3.x
、
flask
、
flask-restful
、
concurrent.futures
我在python中使用Python
Futures
Concurrent获取结果
的
方法之一,当我在单独
的
文件上尝试它时,它工作得很好,但是当我将它与Flask Api集成时,结果是未定义
的
,我调试并发现flask api正在返回结果,甚至不需要等待未来完成
处理
结果。如
何在
处理
结果之前停止它。我在由flask api调用
的
函数
中
的
未来代码: with concurrent.
futures</e
浏览 13
提问于2021-05-06
得票数 0
2
回答
scala
.MatchError:在Dataframes
java
、
scala
、
apache-spark
、
spark-streaming
、
apache-spark-sql
在其中,我试图将一个Java bean RDD JavaRDD<Message>转换为Dataframe,它有许多不同数据类型
的
字段(整数、字符串、列表、地图、双数据)。但是当我在执行我
的
代码
的
时候。
scala
.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.
scala
:244) at
scala
.collection.TraversableLike(IndexedSeqOptimized
浏览 6
提问于2015-06-12
得票数 0
回答已采纳
1
回答
如
何在
Kafka Streams中使用期货
scala
、
apache-kafka
、
apache-kafka-streams
在
Scala
中使用org.apache.kafka.streams.KafkaStreams库时,我一直在尝试读入一个inputStream,将该信息传递给一个方法:validateAll(infoToValidatemapValues(infoToValidate => { }) 是否有关于执行此操作
的
文档我研究了filter()和transform(),但仍然不确定如
何在
KStreams
中</em
浏览 9
提问于2020-02-11
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Scala学习笔记02
JVM语言比较研究:Java、Kotlin 和Scala的利与弊
Spark 2.4重磅发布:优化深度学习框架集成,提供更灵活的流式接收器
Apache Spark强势崛起
Python 流程控制全记录
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券