腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Akka
流
没有
处理
CSV
文件
中
的
所有
行
scala
、
csv
、
akka
、
akka-stream
、
throttling
我正在使用
Akka
stream
处理
一个包含1839
行
的
CSV
文件
。我已经添加了计数器来计算
处理
的
行数。 这是我
的
源代码,我已经确保输入
文件
中
的
每一
行
都少于700个字符。,对应于源
中
的
每一
行
,输出
中
应该有一个已
处理
的
行
。如果删除.to(Si
浏览 13
提问于2021-07-17
得票数 1
回答已采纳
1
回答
FileTailSource抛出空指针异常
scala
、
akka-stream
、
alpakka
我编写了下面的Alpakka代码val resource = getClass.getResource("countrycapital.
csv
"countrycapital.
csv
“
的
文件
。我
的
目标是为该
文件
构建一个
Akka
流
源,并
处理
该
文件
的
所有
记录。 当我运行这段代码时。列表
行</em
浏览 3
提问于2017-10-01
得票数 0
回答已采纳
1
回答
Akka
:如何在一个图形阶段提取一个值并在下一个阶段使用它
scala
、
akka
、
akka-stream
、
alpakka
我正在使用Alpakka和
Akka
来
处理
CSV
文件
。由于我有许多
CSV
文件
必须添加到相同
的
流
中
,所以我想添加一个字段,其中包含来自
文件
名或请求
的
信息。目前我有这样
的
事情: .via(CsvParsing.lineScanner()
浏览 0
提问于2018-03-26
得票数 0
回答已采纳
1
回答
通过
Akka
或Play从S3以压缩方式下载多个
文件
amazon-web-services
、
playframework
、
akka-stream
、
akka-http
、
alpakka
我有一个S3结构,它是火花作业
的
结果,它编写分区
的
CSV
文件
,如下所示。bucketA cleaned-data1 part001....
csv
part002....
csv
我需要
的
是能够有一个
Akka
端点,它指向输出
文件
名,将
所有
部分下载为zip
文件
:https://.
浏览 0
提问于2019-06-30
得票数 0
2
回答
如何在
Akka
HTTP
中
以
CSV
值
的
形式完成数字
流
?
scala
、
akka
、
akka-stream
、
akka-http
我有一个
Akka
源作为一个数字
流
实现如下:我正在尝试利用
Akka
中
的
Akka
流
支持,以逗号分隔值
的
形式返回流响应。我在简单
的
csv
源流上遵循了,得到了以下实现: Marshalling.WithFixedC
浏览 2
提问于2021-07-20
得票数 2
回答已采纳
1
回答
Akka
流
文件
处理
和终止
scala
、
akka-stream
下面的代码段读取
CSV
文件
,并将某些内容打印到控制台: import
akka
.stream.scaladsl._ import
akka
.stream.ActorMaterializer import java.security.MessageDigest/file.
csv
&qu
浏览 0
提问于2018-01-26
得票数 1
回答已采纳
3
回答
Akka
流
:验证正在
流
的
元素
scala
、
akka
、
akka-stream
我是
Akka
流
的
新手,我想知道如何实现某种中间
流
验证。我假设此场景非常常见,因此必须有一个预先定义
的
功能来动态验证
流
。然而,我没能找到任何关于它
的
东西。我是不是站在了错误
的
轨道上,在
Akka
流
中
,验证是不应该这样做
的
?在我
的
特定场景
中
,我将逐行
处理
文件
。如果只有一
行
无效,则继续下去是
没
浏览 3
提问于2017-06-11
得票数 2
回答已采纳
1
回答
akka
流
中
异步
文件
IO的当前状态是什么?
scala
、
file-io
、
akka
、
nio
、
akka-stream
我目前
的
知识状况:由于当前版本
的
Akka
(2.3.x)需要支持JDK6,所以当前提供
的
文件
IO实现无法使用异步
文件
IO操作,因为这些操作是在JDK7 (和更新版本目前版本
的
akka
流
是'2.11‘或'2.12’。在
中
,省略了abhove
的
注释,它只是明确地提到,
文件
IO意味着阻塞由专门
处理</em
浏览 3
提问于2017-08-18
得票数 0
回答已采纳
1
回答
使用
akka
流
和喷雾将
csv
文件
传输到浏览器
scala
、
akka
、
spray
、
akka-stream
我认为来自
的
修改版
的
将运行良好,但我在连接这些部分时遇到了困难。考虑到source: Source[String, Unit]和ctx: RequestContext,我认为修改后
的
StreamingActor应该与actorRefFactory.actorOf(fromSource为供参考,以上要点:import
akka
.util.ByteStringimport
浏览 1
提问于2015-11-05
得票数 0
1
回答
在Apache
中
暂停数据
流
并查看操作符
的
状态
java
、
akka
、
apache-flink
我试图解决以下情况:在弗林克有可能这样做吗?Apache使用
Akka
,即实现JobClient、JobManager和TaskManager作
浏览 0
提问于2018-08-16
得票数 0
回答已采纳
1
回答
akka
流
alpakka
csv
:跳过异常,解析下一
行
scala
、
akka
、
akka-stream
、
alpakka
我正在使用Alpakka来解析
csv
文件
。版本"com.lightbend.
akka
“%% "
akka
-stream-alpakka-
csv
”% 0.20我有
csv
文件
,带有未关闭
的
引号。email"test@emample.comtest@emample.com 我想跳过不好
的
行
,然后转到下一
行
浏览 1
提问于2018-11-30
得票数 0
4
回答
使用
Akka
Streams读取
CSV
文件
scala
、
akka
、
akka-stream
我在读
csv
文件
。我使用
Akka
Streams来做这件事,这样我就可以创建一个在每一
行
上执行
的
动作图。我已经启动并运行了下面的玩具示例。ActorSystem("MyAkkaSystem") val source =
akka
.stream.scaladsl.Source.fromIterator(Source.fromFile("a.
浏览 0
提问于2016-10-25
得票数 15
1
回答
用于发布数据
的
Akka
流
期望
的
是图形,而不是via
中
的
流
。
scala
、
akka-http
、
akka-stream
我正在尝试创建一个示例
akka
流
,该
流
接受
CSV
文件
,将其更改为XML (使用已经存在
的
具有toXml函数
的
对象),然后将其发布到端点。/example.
csv
") FileIO.fromFile(file) .via(Framing.delimiter(ByteString("\[(
akka
.http.scaladsl.model.HttpRequ
浏览 1
提问于2017-05-18
得票数 1
回答已采纳
1
回答
使用
Akka
流
,如何从两个
流
中
形成复合case类对象?
scala
、
csv
、
akka
、
akka-stream
case class UserBookRating(user: User, bookISBN: String, rating: String)我从两个独立
的
csv
文件
中
传输数据: Users.
csv
和BookRatings.
csv
“10”;“美国伊利诺伊州芝加哥”;“26” "
浏览 2
提问于2016-12-03
得票数 0
回答已采纳
1
回答
Mule当
文件
相互依赖时设计一个多
文件
处理
流程
java
、
mule
、
batch-processing
、
esb
Okie.我知道
文件
入站元素
中
的
数据传输、批
处理
和
流
支持。我想知道
的
是集成
的
设计模式: 您可以
处理
多个
文件
(
csv
或xml),例如:1名为products.
csv
的
文件
包含有关产品
的
所有
细节。另一个
文件
images.
csv
具有products.
csv
文件
浏览 2
提问于2015-02-08
得票数 0
回答已采纳
1
回答
合并
文件
时nifi-1.0.0块
apache-nifi
我有一个
处理
csv
文件
的
流程(最大
文件
大小约为700 mB)。我将这些
文件
拆分成一
行
的
流
文件
,然后进行一些
处理
,最后使用ExtendedMergeContent
处理
器作为同步机制。问题是,如果我
处理
每个
csv
文件
,当它们在MergeContent
的
队列
中
时,它会阻塞nifi实例。 当我有超过1
浏览 0
提问于2016-11-12
得票数 1
2
回答
Akka
streams vs Apache Flink
apache-flink
、
akka-stream
在探索
Akka
流
时,我还遇到了Apache哪个
流
处理
引擎。
Akka
流
实现反应
流
并支持背压。 那么,如果我要在两者之间做出决定,我应该选择哪一个呢?它们有何不同之处,相似之处何在?这里
的
标准应该是什么?
浏览 3
提问于2020-04-23
得票数 4
回答已采纳
1
回答
一个
akka
流
函数创建一个接收器,一个源发出接收器接收到
的
任何东西。
scala
、
websocket
、
akka-stream
、
akka-http
目标是实现一个具有此签名
的
函数。返回
的
源发出接收器接收到
的
任何信息。转发器图是:leftEmitter <~ rightReceiver 其中,leftReceiver和leftEmiter是左端点
处理
程序
流
的
进出;rightReceiver和rightEmitter是右端点
处理<
浏览 4
提问于2016-09-21
得票数 2
回答已采纳
1
回答
AKKA
:将本地资源传递给参与者
akka
、
distributed-computing
让我们假设我想使用
AKKA
参与者模型来创建一个程序,
处理
来自
文件
的
数据。据我所知,由于该模型正在获胜,如果参与者真的不知道他们在哪里运行,那么传递消息
中
的
文件
路径应该是错误
的
-some参与者,而应用程序可能无法访问该路径-。相反,由于资源问题,将整个
文件
作为字节传递将不是一个选项(如果
文件
越来越大怎么办?)
处理
这种情况
的
正确策略是什么?在同一个问题上:假设有一个分布式
文件<
浏览 4
提问于2022-02-21
得票数 1
回答已采纳
3
回答
删除标头时将相同
的
CSV
追加在一起
c#
、
csv
、
header
、
append
我想追加6个
CSV
,有相同
的
布局和标题在一起。DataTable table4 = csvToDataTable(@"C:\Program Files\Normalization\Scan4.
csv
"); DataTabletable5 =
浏览 2
提问于2011-07-12
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
以小白眼光观java世界
GrowingIO 响应式编程探索和实践
数据分析指北-基础
怎样让API快速且轻松地提取所有数据?
数据加载、存储与文件格式
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券