问题标签 [trident]

我正在做一个实时数据项目，目前正在使用https://github.com/kstyrc/trident-redis上的 trident-redis 库来存储带有计数的键集。我想存储一些更高级的细分，包括每个键的纬度和经度值。在命令行上使用 Redis，我可以使用：

要得到

和

如何使用 trident-redis 达到同样的效果？我的拓扑目前如下所示：

我需要一些帮助来理解为什么合并两个流会阻塞 class 的一个 spout FixedBatchSpout。

简短描述：我正在尝试合并两个流 s1 和 s2，但调用topology.merge(s1, s2)阻止了FixedBatchSpouts1 起源的（三叉戟喷口），而BaseRichSpout来自 s2 的（风暴喷口）似乎工作正常。

详细信息：在下面的主要方法中，只需添加该行即可topology.merge(s1, s2);防止FixedBatchSpout发出超过其第一批。这multireduce也会发生。

感谢您的帮助，谢谢！雅克

我可以使用标准的 spout、bolt 组合来进行流式聚合，并且在快乐的情况下工作得很好，当使用刻度元组以某个时间间隔保存数据以使用批处理时。现在我自己在做一些故障管理（跟踪未保存的元组等）。（即不是来自storm的ootb）

但我读过三叉戟给你更高的抽象和更好的故障管理。我不明白的是三叉戟中是否有刻度元组支持。基本上我想在当前分钟左右在内存中批处理，并使用 trident 保留前几分钟的任何聚合数据。

此处的任何指示或设计建议都会有所帮助。

谢谢

我尝试Timeline从无Trident父组件的动画库中播放。

在将组件放置在父容器上之前，不会对属性进行插值。

是否有可能强制时间轴在上述环境中执行“场景”

为了在 tridentstorm 中应用一些函数，我们将新创建的实例传递each给在流上调用的方法，如下所示：

其中SomeFunc是 BaseFunc 的后代。

假设我想有一些状态变量SomeFunc：

如果我将 SomeFunc 组件的并行提示设置为大于 1 的某个值，将会创建多个SomeFunc? 在 SomeFunc 中访问/更新 someState 是线程安全操作吗？如果不是将 SomeClass 定义为类，而是将其定义为一个对象，那会改变吗？

编辑 好的，在用户@Shaw 对他的回答的评论的帮助下，我了解到storm为每个执行者创建了一个storm组件实例（storm/bolt/function/aggregator等）。问题是它是如何做到这一点的？我想知道这种行为的机制

I've got a simple Trident Topology running in a LocalDRPC where one of the functions outputs the result field, but when I run it the results I get back seem to be all the information from every tuple, instead of just the result field as I would have expected given the DRPC docs. Eg:

It would be okay to get all the information from every tuple back, but there's no indication of which of the fields is called result. As it stands it's not even valid JSON!

So how can I extract the value that corresponds to a specific field that I specified in the topology?

OpaqueTridentKafkaSpout和 和有什么不一样TransactionalTridentKafkaSpout？您什么时候会使用其中一种？

我有一个从 MQTT 代理接收数据的拓扑，我希望 spout 的行为如下：

1. 每 x 秒发出一批元组（或单个元组中的字符串列表）。我如何实现这一目标？我读了一些关于 Storm Trident 的文章，但它IBatchSpout似乎不允许我以特定的时间间隔批量发出元组。

2. 如果没有新数据进来，spout 应该怎么做？它不能阻塞线程，因为它是 Storm 的主线程，对吧？

我目前正在尝试扩展一个三叉戟拓扑，该拓扑在 groupBy 和 persistentAggregate 之后进行一些后处理，在聚合步骤之后使用 newValueStream 流式传输值。我想知道元组是否像在 groupBy 步骤中那样保持分区，或者它们是否以其他方式重新分配。

相关代码：

有没有办法使用 Trident (IE11) 对象在应用程序中调试 JavaScript？我们有一个嵌入 Trident 实例的 (C++/MFC) 应用程序。它工作正常，右键单击对象会显示通常的 IE11 上下文菜单。但是如何调出调试控制台以便调试嵌入在显示页面中的 JavaScript 并不明显。也许这甚至是不可能的。可以在其他平台上执行此操作（例如 OSX、带有 UIWebView 的 iOS 和带有 WebView 的 Android）。