akka-stream 相关问题

用于处理JVM上的流数据的Akka实现

试图了解一些scala语法，以及在何处找到其规格。在下面，我对statefulMapConcat感到困惑。签名是这样的：def statefulMapConcat [T]（f：（）=> Out => inmutable ....

scala akka-stream

回答 2 投票 2

我目前正在实现一个Akka Stream Scala应用程序，该应用程序读取一个包含如下格式推文的压缩文件（使用json）：{“ created_at”：“ Mon Nov 04 14:37:29 +0000 2019”，... } {“ ...

scala akka akka-stream

回答 1 投票 1

流一次处理的有限元素数

[AKKA中的一个人如何能够在不丢弃任何元素的情况下限制流（一部分）中当前存在的元素数量？

scala akka akka-stream

回答 2 投票 0

MergeLatest的默认值

MergeLatest的官方文档指出：MergeLatest会为从某个输入流发出的每个元素发出列表，但仅在每个输入流发出至少一个元素之后。我的...

scala akka akka-stream

回答 2 投票 1

Akka流-在不使用\ n字符的情况下解析json

scala akka akka-stream

回答 1 投票 1

广播将不输出Akka流

我目前正在尝试在Scala中使用具有管道过滤器体系结构的Akka Streams制作程序。我有一个特定的图，它应该接受一个输入并将其输出到多个流。最后...

scala akka akka-stream

回答 1 投票 0

Akka grpc可以使用非Akka服务中的数据吗

我在理解Akka grpc的基本原理时遇到了麻烦。在Akka文档中，我看到了来自Akka protobuf服务器的Akka protobuf客户端使用服务示例。我可以使用Akka吗...

java akka protocol-buffers akka-stream akka-grpc

回答 1 投票 1

Akka流的多个Kafka分区

[嗨，我正在使用Kafka和Akka Streams。在Kafka主题MyTestTopic中，我有3个分区，数据以大约1000 QPS的高并发率被推送到主题中，并且只会更高...

java apache-kafka akka akka-stream

回答 1 投票 0

累积在一个入口上的Fan-in运算符

我希望有一个带有两个入口的akka 流运算符。在一个入口上，它接收有关消息的元数据。在第二个入口上，消息本身。问题是，当元数据为...

akka-stream alpakka

回答 1 投票 0

如何将Source [String，Future [IOResult]]转换为Source [ByteString，Future [IOResult]]] >> [

以便可以将其传递给Result，如图所示。] >

playframework akka-stream

回答 1 投票 0

使用akka流将数据分块写入文件中

java scala memory-management akka-stream sttp

回答 1 投票 3

Akka流-MergeLatest的默认值

MergeLatest的官方文档指出：MergeLatest会为从某个输入流发出的每个元素发出列表，但仅在每个输入流发出至少一个元素之后。我的...

scala akka akka-stream

回答 2 投票 0

如何从Akka Stream读取HDFS文件？

有人可以举个例子，通过Akka Streaming读取HDFS位置上可用的文本文件吗？我是Akka Stream的新手，在搜寻了那么多内容之后，无法找到相同的任何解决方案。 ...

hdfs akka-stream akka-http

回答 1 投票 0

Akka流-限制整个流一次处理的元素数量

我目前正在开发一个必须处理源自压缩文件的元素流的应用程序。此应用程序的限制应该是，只有X数量的元素可以在...

scala akka akka-stream

回答 2 投票 0

akka-http net :: err_incomplete_chunked_encoding 200（确定）

我正在尝试使用Akka-http：将大/经常缓慢的响应发送到浏览器，以呈现为excel文件，即：在ui代码$ http（{方法中：“ post”，url：“ myUrl”，数据：“大量...

angularjs scala akka akka-stream akka-http

回答 1 投票 0

Source.Single（）会提前终止具有2个源的流

我定义了一个简单的图形，该图形将恒定流（通过Source.Single（5000）定义）与非恒定源（例如Source（1至100））组合在一起。我的图通过...

scala akka akka-stream

回答 1 投票 0

[Alpakka S3从存储桶下载文件，保存到文件，并且文件名可用于流程的下一部分

我正在尝试构建使用S3密钥的代码，然后从S3下载这些文件，然后将该数据保存为磁盘上具有密钥名的文件（对于流程的进一步处理是必需的），并作为...

scala amazon-s3 akka-stream alpakka

回答 1 投票 0

如何使用Scala Akka流检测重复的行

我们有一个Scala应用程序，该程序可从文本文件中读取行并使用Akka Stream处理它们。为了获得更好的性能，我们将并行度设置为5。问题是，如果多行包含相同的...

scala akka akka-stream

回答 1 投票 1

无法在Akka Stream中使用GraphStage类运行SourceShape

我正在尝试使用GraphStage构造创建Redis Akka流源。这个想法是，每当我从subscription方法获得更新时，我都会将其推送到下一个组件。另外，如果存在...

scala akka akka-stream

回答 1 投票 2

Akka流2.6。如何创建AactorMaterializer？

从2.6开始，我在此行收到弃用警告：import akka.stream.ActorMaterializer隐式val actorMaterializer = ActorMaterializer（）警告：对象ActorMaterializer中应用的方法是...

scala akka-stream

回答 1 投票 0

akka-stream 相关问题

最新问题