我想知道我的拓扑仍然是running还是crashed，并且我想使用java代码，那么除了编写一个与拓扑并行运行并发送心跳的线程之外，还有什么方法可以找到相同的东西吗？
浏览 1提问于2015-04-24得票数 0
我已经搜索了一段时间关于如何使用自定义的Java操作符使用infospherepublic class Test extends AbstractOperator
浏览 5提问于2017-01-29得票数 0
回答已采纳
Nimbus是一种Thrift服务，拓扑被定义为Thrift结构。Thrift的使用允许Storm在任何语言中使用。我看到在java中创建的拓扑通过将拓扑(spouts、bolts、ComponentCommon)序列化为Thrift数据类型进行部署，然后部署在Nimbus上。在Java中，很容易将对象及其方法和数据序列化。因此，另一方面，Nimbus只需要创建对象并调用它们。(我可能遗漏了这里的细节，但我希望我没有弄错)
但我想知道如何用C++编写拓扑并以相同的方式部
浏览 3提问于2013-10-01得票数 10
在hazelcast的嵌入式拓扑中，如果数据不存在于IMap中，我们可以使用Mapstore连接到数据库。但我正在使用openshift创建多个hazelcast节点，并尝试使用JAVA客户端连接这些成员。 我的问题是，我需要为此拓扑编写地图存储配置的位置
浏览 10提问于2019-01-29得票数 0
我正在从事一个核心Java项目。我正在编写Apache拓扑，需要在将拓扑绑定到jar时排除Storm。有没有办法不使用maven就可以做到这一点呢？
浏览 4提问于2015-08-11得票数 2
回答已采纳
1回答
我需要做一些地理拓扑(交叉点，包含等)我正在做的一个项目。我想使用Node.js服务器，并尽可能地将数据保存在JSON-esque格式中，这意味着我想使用用JavaScript编写的拓扑库。有没有人有使用这个库或其他拓扑库的经验？此外，如果这是一个糟糕的想法，请让我知道，我将转移到具有JTS拓扑套件的Java服务器。
浏览 4提问于2012-11-01得票数 1
回答已采纳
2回答
我使用Java类向Storm集群提交拓扑，我还计划使用Java类来扼杀拓扑。但是按照的说法，下面的命令是用来杀死拓扑的，并且没有Java (这是有充分理由的)。storm kill {stormname}另外，如何获得风暴群中运行拓扑的状态？
浏览 4提问于2013-12-27得票数 10
回答已采纳
2回答
我是apache风暴的新手，我在寻找测试螺栓的方法，而不需要构建完整的拓扑结构。只是想避免模拟测试。相反，我尝试调用螺栓的方法，以在OutputCollector对象中发出输出。
浏览 4提问于2015-02-05得票数 1
回答已采纳
1回答
具体地说，我正在开发一个用Java (JNS)编写的网络模拟工具。拓扑对象是节点(名称、IPHandlers和IP地址)和DuplexLinks (两端的IP地址、带宽和延迟)。我正在寻找一种动态显示某些拓扑对象(星、环等)的方法。给定不同数量的节点。有没有现成的库可以做到这一点？
我希望在模拟配置过程中无需手动输入画布位置即可实现这一点。我计划使用JNam在绘制的拓扑上设置事件动画(调整为使用JNS而不是ns-2)。
浏览 6提问于2013-08-31得票数 0
我有一个使用Apache storm创建的拓扑。我已经在适当的地方创建了不同的螺栓和喷嘴来执行各种活动。然而，我计划创建一个自动化测试套件来测试拓扑的功能。目前，我的拓扑是Java。
浏览 1提问于2019-05-31得票数 1
1回答
有没有一种方法可以对Ecore EPackage中的类进行拓扑排序，即对类列表进行排序，以便使用另一个类作为超类型的类位于其超类之后？
浏览 1提问于2012-05-30得票数 0
4回答
这是一个关于用Java编写的Storm拓扑中的单元测试螺栓和喷管的一般问题。
单元测试( Spouts？) Bolts 和推荐的实践和指南是什么？例如，我可以为一个JUnit编写一个Bolt测试，但是不完全理解框架(比如一个Bolt的生命周期)和序列化的含义，很容易犯基于构造器创建非序列化成员变量的错误。在JUnit中，这个测试会通过，但是在一个拓扑中，它不能工作。我完全可以想象有很多测试点需要考虑(比如这个带有序列化和生命周期的例子)。因此，如果您使用基于JUnit的单元测试，是否建议您运行一个小的模拟
浏览 2提问于2013-05-14得票数 48
回答已采纳
2回答
我正在运行一个风暴(三叉戟)拓扑结构，从kafka读取avro &用hbase编写记录。拓扑按预期在Local群集模式下运行，但在使用Stormsubmitter时，我面临以下问题。但是没有监督运行拓扑中的喷口/螺栓。我想原因可能是内存不足(4G运行拓扑+ hbase、hdfs、kafka、动物园管理员等)。
at java.util.concurren
浏览 6提问于2014-11-06得票数 1
1回答
我们正在进行风暴和蜂箱集成，strom将通过hive编写数据HDFS。但是，由于我们部署的拓扑是由strom (运行风暴拓扑的集群上创建的用户)运行的。您知道吗，我们可以在编写Hive表时通过java代码模拟用户X？
浏览 1提问于2015-08-20得票数 0
回答已采纳
1回答
我在Storm集群上运行了一个拓扑，其中包含3个监督节点(每个节点32 32GRAM)。在前几天，拓扑进行得很好，一切都很好。但是，以下错误总是发生，并且拓扑在运行了几天之后就会下降：
java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeExceptionKeeperErrorCode = ConnectionLoss for /brokers/topics/TOP
浏览 5提问于2016-09-08得票数 0
回答已采纳
我正在运行用Java编写的拓扑，它调用了一些Clojure代码，我想在那里使用Clojure 1.10.0中的特性。--artifacts "org.clojure:clojure:1.10.0" 在部署拓扑之后，成功地解决了工件，但是在运行代码时，我一直收到来自1.7.0JAR的错误。
浏览 13提问于2019-09-23得票数 0
我想要管理两个拓扑，他们需要通知它们的状态。我是不是不可能理解拓扑的状态是停用的，或者不能在java类中提交另一个拓扑？
浏览 0提问于2013-11-19得票数 3
我有一个问题，高cpu使用率停用apache风暴拓扑。我可以使用下面的步骤可靠地重新创建问题，但我还没有确定确切的原因或解决方案。
浏览 5提问于2017-11-29得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
