Akka解释了为什么不使用builder时分区已经连接。添加
我正在尝试Akka Stream API，我不知道为什么这会抛出java.lang.IllegalArgumentException：[Partition.in]已经在第5行连接
val graph = RunnableGraph.fromGraph(GraphDSL.create() { implicit builder: GraphDSL.Builder[NotUsed] =>
import GraphDSL.Implicits._
val intSource = Source.fromIterator(() => Iterator.continually(Random.nextInt(10).toString))
val validateInput: Flow[String, Message, NotUsed] = Flow[String].map(Message.fromString)
val validationPartitioner = Partition[Message](2, { // #5 error here
case _: Data => 0
case _ => 1
})
val outputStream = Sink.foreach[Message](println(_))
val errorStream = Sink.ignore
intSource ~> validateInput ~> validationPartitioner.in
validationPartitioner.out(0) ~> outputStream
validationPartitioner.out(1) ~> errorStream
ClosedShape
})
但如果我将validationPartitioner改为用builder包装。添加（…）然后移除。从
intSource ~> validateInput ~> validationPartitioner.in
一切正常。如果我只是删除. in代码不编译。为什么强制使用构建器，我是否遗漏了什么或者是错误？
共有1个答案
图形的所有组件都必须添加到生成器中，但有~
-
我正在尝试Akka流API，但我不知道为什么它会抛出java。lang.IllegalArgumentException。 这是当前的代码。错误如下 我使用KinesRecord作为源代码的目标。但是，在这段代码中，如果我将outputPorts更改为1并删除 这条线，它起作用了。 我不知道我是错过了什么，还是只是一个错误。
-
问题内容： Spring Boot文档说要使用注释 您还需要列出要在注释中注册的属性类 ，如以下示例所示： 并给出以下代码： 但是在下一段中说： 即使前面的配置为AcmeProperty创建了常规bean，我们也建议仅处理环境，尤其不要从上下文中注入其他bean。话虽如此， 注释也会自动应用到您的项目中，以便从环境配置任何使用@ConfigurationProperties注释的现有bean。 建
-
Akka平台提供哪些有竞争力的特性？ Akka提供可扩展的实时事务处理。 Akka为以下目标提供了一致的运行时与编程模型： 垂直扩展（并发） 水平扩展（远程调用） 高容错 这个模型是唯一需要学习和掌握的，它具有高内聚和高一致的语义。 Akka是一种高度可扩展的软件，这不仅仅表现在性能方面，也表现在它所适用的应用的大小。Akka的核心——akka-actor是非常小的，可以方便地加入你的应用中，提供
-
认证之后，如果我调用任何方法，比如< code>os.compute()。口味()。list()或< code>os.images()。list()，我得到< code >连接超时。为什么会这样？ 我在GoogleCloudsPlataform VM上设置了一个带有RDO包堆栈的OpenStack。我正在对域和项目进行身份验证。我尝试了没有项目的身份验证，方法调用没有超时，但是响应是错误的，例如，
-
问题内容： 我最近遇到了一个Java 8类，该类使用定界符添加String并向其添加前缀和后缀，但是我无法理解此类的需要，因为它也在后端使用，并且执行非常简单的附加操作字符串。 我是否没有真正理解本堂课的真正目的而错过了某些东西？ 问题答案： 当您需要在中将Strings连接时，此功能非常有用。 例如，如果您必须遵循以下字符串列表： 使用起来更简单 就像使用： 六年后编辑 如评论中所述，现在有许多
-
我正在尝试按照本教程实现nodejs mysql数据库。我知道 查询（）是Pool.GetConnection()+Connection.Query()+Connection.Release()的快捷方式。 在本文中,数据库配置为： 这是可以用作： 但是，我真的不明白 如果使用pool会自动释放连接，为什么我们需要这样做呢？