问题标签 [ibm-streams]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
infosphere-spl - SPL 函数可以调用 submit() 吗?
我正在尝试从 SPL 函数(从自定义运算符调用)调用 submit(),但它不起作用。它抱怨我的流的名称:
错误:SPL 程序中引用了未知标识符:MyStream
这支持吗?
infosphere-spl - 我们如何在 IBM InfoSphere Streams 的 Custom() Operator 的 onTuple 上处理两个不同的输入流?
在自定义运算符中,我试图打开一个在启动时提交的文件,并对文件中的值进行标记,并将这些值与其他文件的输入流进行比较。
java - 如何将 RScript 运算符与 IBM Streams Java Application Api 一起使用?
我正在 IBM Streams 中探索 Java Application Api,因此它看起来很有希望。我能够创建拓扑并在分布式模式下独立运行它们。
现在我正在尝试查看如何从 Java 拓扑中调用 R 脚本。我正在考虑的一种方法是在我的 Java 拓扑中使用 com.ibm.streams.rproject::RScript 运算符。
这是我的完整代码:
但是当我在拓扑之上运行时,我收到以下错误:
你能告诉我我做错了什么吗?对在 Java API 中使用 SPL 运算符有任何帮助吗?
谢谢苏德希尔
ibm-cloud - 如何将 IBM Infosphere Streams 应用程序与 IBM Bluemix Watson 集成?
我是 IBM InfoSphere Streams 的新手,我正在使用 InfoSphere Streams 快速入门版。我正在尝试开发一个从 Watson IoT 设备获取输入的应用程序。我浏览了一个教程,该教程告诉我们如何将数据获取到他们只是使用.sab文件的 InfoSphere Streams 控制台。他们使用com.ibm.streamsx.iot工具包从 Watson IoT 设备获取数据。我正在尝试下载并安装streams.iot 工具包以使用Streams studio 开发应用程序。但是我找不到streams.iot 工具包的正确位置。我也找不到将此工具包配置为 Stream Studio 的方法。谁能告诉我在 Streams studio中下载、安装和使用com.ibm.streamsx.iot的步骤。
image-processing - 如何将图像导入 IBM Streams?
显然,为了在 IBM InfoSphere Streams 中导入图像(我目前使用的是 VMware-streams4.1.1),我必须下载 OpenCV 库,并且我已遵循本指南。http://ibmstreams.github.io/streamsx.opencv/doc/html/InstallingToolkit.html
我到了必须使用 CMAKE 的地步,之后,当我在命令行中键入 make 时,创建了一个 make 文件但不是“制作”...
是否需要下载 OpenCV 才能将图像上传到 IBM Streams?还是那里已经有任何内置库?因为显然没有太多关于安装这些库的信息。
这里的主要任务是取 IBM Streams 中图像像素的平均值
java - 在停止流应用程序时恢复内部排队的消息
我们有一个流应用程序(IBM Infosphere Streams),其中应用程序的输入来自 input_queue(JMS 队列),输出再次写入某个 output_queue(JMS 队列)。目前我们正在谈论每小时超过 300k 的消息,但有时,应用程序会被阻塞(由于可用资源有限)并且消息在应用程序内部排队,而 output_queue 不会同时获得消息速度。所以解决这个问题,我们别无选择,只能禁止从 input_queue 将消息摄取到流应用程序中,并在启用摄取的情况下重新启动应用程序。在此期间,内部排队的消息会丢失。因此,我们期待在需要停止流的情况下恢复丢失的消息。我们想到的一种方法是,有另一个队列,它在接收流中的消息时接收它们。并在它们发布到输出队列后将其删除,如果必须停止流,我们可以先在内部队列中重放这些消息,然后开始处理来自 input_queue 的其他消息。
现在的问题是这种方法的效率如何,如果可能的话,任何人都可以提出解决方法。有人告诉我,通过网络发布到队列是一项昂贵的操作。所以我们有什么选择。欢迎提出建议。谢谢。
ibm-streams - ibm infosphere 流中的线程端口和并行注释之间的区别
我试图了解 IBM info-spare 流中的线程端口和@parallel 注释之间的区别,我搜索了很多地方但“无法得到我的答案,根据我的理解,它们都有助于使运算符线程化,但我不确定何时何地使用它们,它们可以一起使用以提高性能。有人可以用例子证实它们的用法吗?
谢谢。
ibm-infosphere - InfoSphere Streams 一致区域何时合并为一个?
我有这个测试问题,我无法弄清楚:
--
关于一致区域,以下哪项不正确?(选一个)
a) @consistent 注释应用于原始运算符
b) 带注释的原语算子是一致区域的起始算子
c) 一致区域由带注释算子的可达图定义
d) 不同带注释的原始算子的相交可达图被视为独立一致区域
--
问题是 - 所有这些对我来说似乎都是真实的,如果我必须选择一个我最不确定的,那将是 D 选项,只是因为这个词intersecting。
所以我正在阅读 InfoSphere Streams 的官方文档,它说如下:
当不同带注释的原语算子的可达图共享一个共同的算子时,它们形成一个单一的一致区域。
我的问题:
1)如果我正确理解了相交这个词,那就是那个意思。或者这是否意味着两个区域“交叉路径”而不是共享一个共同的运营商?在这种情况下,选项 D 将是正确的答案...
2)如果不是,那么也许我被这个问题愚弄了,真正的答案是,例如,b,如果带注释的运算符已经在一致的区域中,那么它不是开始运算符?那么选项b不一定总是正确的?
3)官方文档中是否有错误,其中说:
下图显示了在两个基本运算符(op1 和 op7)上放置 @consistent 注释的示例。每个算子的可达图不会形成一个单一的区域,因为它们不共享一个共同的算子。结果,形成了两个独立的一致区域,这在每个区域的算子上表现出不同的模式。
op4呢?