来自：Storm从一开始就被设计成与多种语言兼容。Nimbus是一种Thrift服务，拓扑被定义为Thrift结构。Thrift的使用允许Storm在任何语言中使用。我看到在java中创建的拓扑通过将拓扑(spouts、bolts、ComponentCommon)序列化为Thrift数据类型进行部署，然后部署在Nimbus上。在Java中，很容易将对象及其方法和数据序列化。因此，另一方面，Nimbus只需要创建对象并调用它们。(我可能遗漏了这里的细节，但我希望我没有弄错
浏览 3提问于2013-10-01得票数 10
2回答
c/c++中的网络拓扑
、、、、
我试图用C/C++语言定义网络拓扑。目标是将它从C/C++解析为XML，反之亦然。在这个拓扑中(如图中所示)，路由器与接口相连；每个路由器都有一个ip地址和一个链路容量。是否有类(如图)或结构来更容易地实现网络拓扑？
浏览 8提问于2015-01-23得票数 0
回答已采纳
1回答
Gremlin中的拓扑排序
、、、、
使用查询语言，是否有一种方法可以计算有向无环图的拓扑排序？例如，给定一个具有以下边的图我想要获得以下拓扑顺序之一：a, b, e, c, d或a, e, b, c, d或e, a,b, c, d。
浏览 12提问于2017-02-07得票数 1
回答已采纳
我有一个由多个Map和FlatMap转换组成的Fink拓扑。源/汇是卡夫卡的源/汇。Kakfa记录的类型为Envelope (由其他人定义)，没有标记为“可序列化”。我想要单元测试这个拓扑。我定义了一个简单的SourceFunction，它返回一个Envelope列表作为源代码：I需要使MySource可序列化，因为Flink希望/需要
浏览 2提问于2022-07-17得票数 0
1回答
将DAG转换为二叉树
、、、、
因为A，B，C，E形成一颗钻石，为了把它转换成树，我需要把B和C移动到一条线上。我试过以下几点：拓扑路径给了我们一条直线路径。但是，如果可能的话，我希望保留这个序列，即A -> D。但是，如果有一个菱形，我希望一个节点只有一个父节点，并且对这些父节点进行排序。
对于上述情况，
浏览 3提问于2021-03-09得票数 0
回答已采纳
1回答
我有一个Apache拓扑，如下所示：
B:分裂这个序列并发射n个长序列吗？C:计算子序列是否在所有序列中
现在，如果c看到一个子序列不是在所有序列中，那么它应该向B发送一条指令消息，B可以修剪一些序列，并且不能发送所有的元组，它们比所有列表中的子序列都长。
浏览 1提问于2015-12-07得票数 0
1回答
我有一个spout类，它有几个整数和字符串属性，它们按预期被序列化/反序列化。这个类还有一个LinkedList保存字节数组。当对象被反序列化时，这个LinkedList总是空的。当调用“activate”方法时，没有任何拓扑的重新提交。
风暴使用Kryo进行序列化。Kryo是一个灵活而
浏览 4提问于2015-11-05得票数 0
2回答
拓扑排序在算法中的正确使用
、、、、
给定具有N个单词和标准字典的k个起始字母的外星语言排序字典，任务是完成函数，该函数返回一个字符串，表示语言中字符的顺序。"cab", "cad" }, k = 4Here order of characters is 'b', 'd', 'a', 'c'我已经用拓扑排序实现了一个问题的解决方案，参考了一些在线文章，但是
浏览 1提问于2017-08-07得票数 2
4回答
如何创建3D数学拓扑模拟？
、、、、
我从来没有创建模拟或3D对象的经验，但我想开始学习它们，并创建一个小型应用程序，它将在3D中模拟拓扑对象。我所说的“拓扑对象”是指数学拓扑(代数/一般拓扑)，指的是环面、纽结、莫比乌斯带等。所以，我并不是指任何类似网络拓扑的东西。
我已经在互联网上搜索了一些关于它们的示例代码，但我无法找到任何有用的东西。如果你能给我一些材料，我会很高兴的。另一方面，我想听听您关于我应该使用哪种编程语言/范例/扩展的意见？我还计划在项目中使用CUDA来实现加
浏览 2提问于2012-11-22得票数 2
回答已采纳
我们有一个运行着3个节点和多个拓扑的storm集群。我们在java 1.8.0_162中使用apache-storm-1.2.2 目前我们有一个问题，一个随机拓扑在错误发生后在随机时间停止发射，并且Netty服务器不可用。此外，为什么整个拓扑在出现这样的错误后停止工作，这也是值得怀疑的。 似乎某些HashMap的反序列化有问题。但是我们不知道这是怎么发生的。org.apache.storm.serialization.SerializableSerializer.read(SerializableSerializer.ja
浏览 41提问于2019-09-24得票数 0
我更改了我的项目配置和源代码，如下所示:1.Storm-core和storm-kafka版本在pom.xml中将0.9.6更改为1.0.2，kafka_2.10更改为0.8.2.2。2.更改包路径- backtype -> org.apache - storm.kafka -> org.apache.storm.kafka 3.在自定义方案中将序列化代码byte[]更改为ByteBuffer我的拓扑读取数据是这样的，即使重新启动拓扑，每次重新启动都会消耗相同的数据。数据1 ->数据2 -
浏览 0提问于2016-11-18得票数 1
2回答
我有以下用于拓扑排序的伪代码Find a vertex with no successorPut It at beginning of list
浏览 0提问于2013-01-15得票数 1
回答已采纳
1回答
我正在使用Storm1.1.2、JDK 8 (Storm不喜欢JDK 9编译代码)、Kafka 0.11和Docker Compose开发一个spring应用程序。其想法是拥有一个容器化服务，它可以接收REST调用来创建风暴拓扑，然后将它们提交到风暴集群中。一切都在本地工作，但是将拓扑提交从提交到本地集群转移到StormSubmitter会导致问题。我已经解决了其中的大部分问题，但是有一个奇怪的序列化问题。
我有一个能读到卡夫卡的喷口。它读取Protobuf对象的字节数组，并使用自定义反序列化程序从它们中
浏览 0提问于2018-09-13得票数 0
回答已采纳
1回答
我正在尝试创建一个有序的类别分支列表，这样我就可以找到任何子类别并在开始时添加"-"；还可以找到该类别可能具有的任何子类别并添加"--"等。 public int Id { get; set; } public int ParentId { get; set; }示例：-Special Off
浏览 2提问于2012-08-14得票数 1
回答已采纳
我想使用拓扑排序使用深度优先搜索(DFS)对给定的问题(有向图附在下面)。请您用任何编程语言为给定的问题编写适当的代码，好吗？
浏览 4提问于2022-05-21得票数 -1
目标是对n个未知变量{x0，x1，x2，.x(n-1)}使用m比较结果的列表C(布尔值)。每个比较是在两个n个变量之间进行的，例如x2 < x5，每个比较的对指数都是固定的，并且提前给定。还给出了:C中的所有对都是唯一的(即使翻转时也是如此，例如，对x0，x1表示没有对x1，x0)，而且永远不要将变量与自身进行比较。这意味着C最多有n*(n-1)/2条目。所以问题是，我能证明我的m比较列表C足以对列表X排序吗？显然，如果C是最大的可能长度(有所有可能的比较)。但更短的名单呢？
然后，如果已
浏览 2提问于2015-08-11得票数 4
7回答
我们开发了一个由不同编程语言(C++、C#和Python)实现的组件组成的分布式系统，并通过网络相互通信。系统中的所有组件都使用相同的业务概念进行操作，并根据这些概念相互通信。因此，我们努力应对以下两个挑战：
对于这个问题，一个简单的解决方案就是三次定义相同的数据结构(以及序列化代码)这些框架有一种内部语言，其中定义
浏览 11提问于2012-08-03得票数 17
1回答
构建DAG，以便重新使用节点
、、、、
我用它来用XLA在C++中构造一个图。缓存计算过的节点，然后在节点比较相等的地方重用它们。这是低效的，因为用户知道哪些节点在哪里被重用，因此我们似乎应该能够使用这些信息。方法2:拓扑排序 Lit 1.0 Neg Lit 2.0 | Add Add
因为我在构造它的时候还不清楚如何排序列表中的节点方法2a:具
浏览 5提问于2022-11-07得票数 1
1回答
生成每种拓扑类型的图
、、、
考虑下面这个输入数组，它表示一个图：元素的顺序取决于元素是否有前一个元素。例如，No.7将始终是最后一个，因为它之前有2个元素，没有追随者。<code>A2</code><code>A3</code>
作为另一个例子，数组不能像<code>D4</code>那样排列，因为6之前有一个元素4，因此元素4必须在6
浏览 10提问于2021-06-11得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
