腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
处理
Java
Akka
streams
中
的
变更
源
数据
java
、
scala
、
akka
、
akka-stream
processFlowThread对同一List
中
的
值求和,并将求和列表打印到控制台。代码如下: import
akka
.NotUsed;import
akka
.stream.javadsl.Sink;import
java
.util.List; import
浏览 41
提问于2021-04-11
得票数 0
回答已采纳
1
回答
Akka
似乎没有在故障期间重新启动
scala
、
akka
、
akka-stream
我在用可重新启动
的
源
和接收器
处理
akka
流
中
的
错误。newVal + " sink") newVal }} 我是打破
源
和下沉分别与不同
的
情况我首先断开接收器,希望接收器重新启动,并一次又一次地重新
处理
newVal == 3消息。但是似乎接收器
中
的</em
浏览 8
提问于2022-01-10
得票数 1
回答已采纳
1
回答
如何将
akka
.stream.javadsl.Source转换为
java
.util.concurrent.Flow.Publisher
akka-stream
、
java.util.concurrent
、
reactive-streams
我正在试验reactive
Streams
的
Test Compatability Kit (tck),并且我自己测试了几个Publisher,我想测试一个
akka
Source。但为了做到这一点,我需要将
源
(或
源
+
处理
器)转换为
java
.util.concurrent.Flow.Publisher。createFlowPublisher(long elements) { return new FlowPublisher((int) elements);
浏览 1
提问于2019-07-11
得票数 0
1
回答
可以在
Akka
Streams
流之间使用Flink流
处理
器作为
源
和宿吗?
stream
、
akka
、
apache-flink
我希望用Flink替换我
的
基于
Akka
Streams
的
流
处理
器
的
一部分。目前是否可以使用
Akka
Streams
作为Flink
的
源
,然后在同一代码库中使用Flink作为
Akka
Streams
的
源
?
Akka
Streams
的当前流量如下: // Kafka Source -> Re
浏览 2
提问于2019-04-24
得票数 1
2
回答
在
Akka
Streams
Custom Graph Stage
中
包装Pub-Sub
Java
API
scala
、
akka
、
akka-stream
我正在使用一家提供实时流
的
数据
供应商
的
Java
API。我想使用
Akka
streams
来
处理
这个流。
Java
API有一个pub sub设计,其工作原理大致如下: Subscription sub = createSubscription(); buffer.enqueue(e)}
浏览 32
提问于2021-09-28
得票数 1
回答已采纳
1
回答
在
Akka
流
中
处理
ack
architecture
、
akka
、
akka-stream
我已经看到了使用
Akka
Streams
来避免背压
的
例子,但是我想知道如果我需要在下游获得自定义
的
acks,这是如何工作
的
?在我
的
特定情况下,链中有几个
处理
消息
的
flows,当消息到达某个flow时,我想将一个ack传递回
源
,以便发出信号,表明我现在已经“取得了”正在
处理
的
资源
的
所有权。这在
Akka
Streams
中
是如何工作<
浏览 0
提问于2017-04-03
得票数 1
2
回答
Akka
流-基于谓词拆分传入
源
数据
scala
、
akka
、
akka-stream
我是
Akka
Streams
框架
的
新手,我想知道用
Akka
流
的
目标来解决我
的
问题
的
可能性。想象一下这里有一个问题: 文件
中
的
数据
应该由某个谓词进行分区,然后通过分区进行
处理
。分区谓词可以是动态
的
,从
浏览 6
提问于2016-11-17
得票数 2
回答已采纳
1
回答
Akka
:
Java
中流
的
等价物是什么
java
、
scala
、
akka
、
akka-stream
scala
中
的
Akka
streams
提供了流概念。
Java
中
的
等价物是什么?但在
Java
语言中,Source.take(n)返回
的
是
源
,而不是流
浏览 10
提问于2020-02-09
得票数 0
1
回答
使用
akka
流时
的
事件顺序
scala
、
akka-stream
、
akka-actor
channelActorSink }[INFO] [11/10/2017 17:42:20.431] [
akka
-
streams
-
akka
.actor.defaul
浏览 4
提问于2017-11-11
得票数 0
回答已采纳
1
回答
如何在argo和kubernetes
中
运行
akka
流媒体应用?
kubernetes
、
akka
、
akka-stream
、
argo-workflows
、
argoproj
如何在argo和kubernetes
中
运行
akka
streams
应用程序,我找到了关于kubernetes和
akka
集群
的
文档,但我不需要
akka
集群,我只需要运行一个具有许多参与者
的
短暂
akka
应用程序;还是
akka
集群是必要
的
?
浏览 29
提问于2021-02-12
得票数 0
回答已采纳
1
回答
将
Akka
与apache spark streaming和Kafka一起使用?
apache-spark
、
akka
、
akka-stream
下面是我正在尝试
的
高级用例。我们有发布到Kafka主题
的
学生
数据
流,我们
的
模块必须以流
的
形式读取学生ids,并从多个来源获取每个学生
的
关联
数据
,然后为每个学生执行一些计算,并将每个学生
的
关联计算发布到kafka主题中。因此,这里
的
问题是更好地编写一个大
的
Spark作业或使用
Akka
为每个
源
提供单独
的
服务,以便参与者可以并行工作,获取一堆学生it,并从各自
的
浏览 2
提问于2017-07-14
得票数 1
1
回答
使用
akka
进行Zip文件传输
akka
、
akka-stream
、
akka-http
我是
AKKA
的
新手(我使用
的
是
java
)。我不知道如何将zip文件传输到远程参与者。我应该使用
akka
-http吗?我尝试过
akka
-
streams
,但我不能理解如何将二进制文件传输到远程actors。
浏览 1
提问于2017-09-19
得票数 0
1
回答
akka
-http应用javax.servlet.Filter
java
、
scala
、
servlets
、
akka-http
如何在
Akka
-http服务
中
添加实现接口
的
类,例如下面的示例: override implicit().bindAndHandle(routes, config.getString("http.interface"), config.getInt("http.port"))在Scalatra
中
,override def init(context: ServletC
浏览 18
提问于2018-01-18
得票数 1
回答已采纳
1
回答
更改
akka
流
的
源
数据
java
、
scala
、
akka
、
akka-stream
我正在学习
Java
流,并使用定义了以下内容:import
java
.util.List;import
java
.util.concurrent.ExecutionException; static ActorSystem
Akka
流解决了这个代码可以重复执行
的
问
浏览 1
提问于2021-04-10
得票数 0
回答已采纳
1
回答
在
Akka
中
,PersistentView
的
典型用例是什么?
akka
、
system.reactive
、
akka-stream
、
event-sourcing
、
akka-persistence
这里写
的
是: 它与 / RX有何不同? 看上去和我很像。
浏览 4
提问于2017-03-29
得票数 1
回答已采纳
1
回答
将websocket客户端放在
Akka
.NET内部或外部
的
代理
中
的
位置?
c#
、
akka.net
我是
Akka
.NET
的
新手,我正在构建某种websockets,我想使用
Akka
.NET来
处理
(转换和转发)传入
的
流量,使用它
的
参与者系统。但我想知道怎样才是最好
的
办法。我有以下问题: 我是否应该在Actor之外创建主侦听器,并为每个传入
的
“侦听”客户端实例化一个参与者?或者我应该把我
的
主要听众也放在一个演员里面?或者我应该把我
的
客户放在演员之外,并把它放在
Akka
.NET消息
中</em
浏览 1
提问于2017-10-10
得票数 2
回答已采纳
1
回答
卡夫卡到MongoDB
的
Akka
流
mongodb
、
scala
、
apache-kafka
、
akka-stream
我对
Akka
streams
技术非常陌生,我没有找到任何关于我
的
用例
的
信息来源。实现这种行为
的
最佳
浏览 3
提问于2022-03-16
得票数 1
1
回答
Akka
无法启动ActorSystem
scala
、
akka
NotUsed] = Source(1 to 100)} 线程"main“
中
的
异常斯卡拉:13)在sun.reflect.NativeMethodAccessorImpl.invoke0(Native方法
的
streams
_test.Main.main(Main.scala);在sun.reflect.DelegatingMethodAccessorImpl.invoke(De
浏览 4
提问于2016-11-02
得票数 1
回答已采纳
1
回答
阿克卡流与火花流
apache-spark
、
akka-stream
使用
akka
流与火花流进行流
处理
有什么优缺点?比如,内置背压,性能,容错,内置转换,灵活性等。我不是在问
akka
vs火花正反严格流组件。另外,我并不是在问引擎盖框架架构
的
差异。
浏览 1
提问于2016-07-06
得票数 9
回答已采纳
2
回答
akka
-具有
akka
集群
的
流
scala
、
akka
、
akka-cluster
、
akka-stream
我
的
阿克卡流继续学习。我想将我
的
akka
应用程序与集成。class ChatClient(name: String) extends Actor { case ChatClient.Message(from, text) =&
浏览 6
提问于2016-02-03
得票数 4
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
GrowingIO 响应式编程探索和实践
解锁多核处理器的力量:探索数据并行化在 Java 8 Stream 中的应用
浅谈java响应式编程以及Reactor 3框架
如何在生产中为机器学习模型提供服务?
初探Kafka Streams
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券